sess

Documentation

Index

• func NewMemManager(sessionStore store.SessionStore) sess.Manager
• func NewMemSession(cMsg *message.ConnectMessage, op ...Option) (*session, error)
• func WithOfflineMsgToSess(s *session, offlineMsg []message.Message)
• func WithOldTopicToSess(s *session, sub []topic.Sub)
• type AckQueues
• type Option
  • func WithOfflineMsg(offlineMsg []message.Message) Option
  • func WithOldTopic(subs []topic.Sub) Option

Functions

func NewMemManager

func NewMemManager(sessionStore store.SessionStore) sess.Manager

func NewMemSession

func NewMemSession(cMsg *message.ConnectMessage, op ...Option) (*session, error)

func WithOfflineMsgToSess

func WithOfflineMsgToSess(s *session, offlineMsg []message.Message)

func WithOldTopicToSess

func WithOldTopicToSess(s *session, sub []topic.Sub)

Types

type AckQueues

type AckQueues struct {
	// contains filtered or unexported fields
}

type Option

type Option func(s *session)

func WithOfflineMsg

func WithOfflineMsg(offlineMsg []message.Message) Option

func WithOldTopic

func WithOldTopic(subs []topic.Sub) Option