sessions

Documentation

Index

• func PrefixMountPoint(mountPoint string, t []byte) []byte
• func TrimMountPoint(mountPoint string, t []byte) []byte
• type Session
  • func NewSession(c io.WriteCloser, stats encoder.StatRecorder) *Session
  • func (s *Session) AddTopic(t []byte)
  • func (s *Session) Close() error
  • func (s *Session) GetTopics() [][]byte
  • func (s *Session) ProcessConnect(connect *packet.Connect) error
  • func (s *Session) RemoveTopic(t []byte)
  • func (s *Session) Send(publish *packet.Publish) error
• type Store
  • func NewStore() Store

Functions

func PrefixMountPoint

func PrefixMountPoint(mountPoint string, t []byte) []byte

func TrimMountPoint

func TrimMountPoint(mountPoint string, t []byte) []byte

Types

type Session

type Session struct {
	ID         string
	ClientID   string
	MountPoint string
	Lwt        *packet.Publish

	Encoder      *encoder.Encoder
	Disconnected bool
	// contains filtered or unexported fields
}

func NewSession

func NewSession(c io.WriteCloser, stats encoder.StatRecorder) *Session

func (*Session) AddTopic

func (s *Session) AddTopic(t []byte)

func (*Session) Close

func (s *Session) Close() error

func (*Session) GetTopics

func (s *Session) GetTopics() [][]byte

func (*Session) ProcessConnect

func (s *Session) ProcessConnect(connect *packet.Connect) error

func (*Session) RemoveTopic

func (s *Session) RemoveTopic(t []byte)

func (*Session) Send

func (s *Session) Send(publish *packet.Publish) error

type Store

type Store interface {
	Get(id string) *Session
	Save(id string, session *Session)
	Delete(id string)
}

func NewStore

func NewStore() Store