Versions in this module Expand all Collapse all v0 v0.2.6 Mar 20, 2019 Changes in this version + type Config struct + NodeName string + OnReplaceAttempt func(string, bool) + Persist persistence.IFace + Systree systree.Provider + TopicsMgr topicsTypes.Provider + type Manager struct + func NewManager(c *Config) (*Manager, error) + func (m *Manager) GetSubscriber(id string) (vlsubscriber.IFace, error) + func (m *Manager) LoadSession(context interface{}, id []byte, state *persistence.SessionState) error + func (m *Manager) OnConnection(conn transport.Conn, authMngr *auth.Manager) (err error) + func (m *Manager) Shutdown() error + func (m *Manager) Stop() error + type StartConfig struct + Auth vlauth.Permissions + Conn net.Conn + Req *mqttp.Connect + Resp *mqttp.ConnAck
Go to main page