clients

Jul 11, 2018

Changes in this version

type Manager

+ func (m *Manager) Stop() error

Jun 15, 2018

Changes in this version

type Manager

+ func (m *Manager) GetSubscriber(id string) (vlsubscriber.IFace, error)

Apr 22, 2018

Changes in this version

type Manager

+ func (m *Manager) LoadSession(context interface{}, id []byte, state *persistence.SessionState) error

+ func (m *Manager) OnConnection(conn transport.Conn, authMngr *auth.Manager) error

+ func (m *Manager) Publish(id string, p *packet.Publish)

Sep 21, 2017

Changes in this version

+ type Config struct

+ AllowReplace bool

+ AvailableRetain bool

+ AvailableSharedSubscription bool

+ AvailableSubscriptionID bool

+ AvailableWildcardSubscription bool

+ ConnectTimeout int

+ ForceKeepAlive bool

+ KeepAlive int

+ MaxPacketSize uint32

+ MaximumQoS packet.QosType

+ NodeName string

+ OfflineQoS0 bool

+ OnReplaceAttempt func(string, bool)

+ Persist persistence.Provider

+ ReceiveMax uint16

+ Systree systree.Provider

+ TopicAliasMaximum uint16

+ TopicsMgr topicsTypes.Provider

+ type Manager struct

+ func NewManager(c *Config) (*Manager, error)

+ func (m *Manager) NewSession(config *StartConfig)

+ func (m *Manager) Shutdown() error

+ type StartConfig struct

+ Auth auth.SessionPermissions

+ Conn net.Conn

+ Req *packet.Connect

+ Resp *packet.ConnAck