Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { configuration.MqttConfig TopicsMgr topicsTypes.Provider Persist persistence.Provider Systree systree.Provider OnReplaceAttempt func(string, bool) NodeName string }
Config manager configuration
type Manager ¶
type Manager struct { Config // contains filtered or unexported fields }
Manager clients manager
func NewManager ¶
NewManager create new clients manager
func (*Manager) LoadSession ¶ added in v0.0.4
func (m *Manager) LoadSession(context interface{}, id []byte, state *persistence.SessionState) error
LoadSession load persisted session. Invoked by persistence provider
func (*Manager) OnConnection ¶ added in v0.0.4
OnConnection implements transport.Handler interface and handles incoming connection
type StartConfig ¶
type StartConfig struct { Req *packet.Connect Resp *packet.ConnAck Conn net.Conn Auth vlauth.Permissions }
StartConfig used to reconfigure session after connection is created
Click to show internal directories.
Click to hide internal directories.