clients

Documentation

Index

• type Config
• type Manager
  • func NewManager(c *Config) (*Manager, error)
  • func (m *Manager) GetSubscriber(id string) (vlsubscriber.IFace, error)
  • func (m *Manager) LoadSession(context interface{}, id []byte, state *vlpersistence.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

Types

type Config

type Config struct {
	configuration.MqttConfig
	TopicsMgr        topicsTypes.Provider
	Persist          vlpersistence.IFace
	Metrics          metrics.Informer
	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

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

NewManager create new clients manager

func (*Manager) GetSubscriber

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

GetSubscriber ...

func (*Manager) LoadSession

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

LoadSession load persisted session. Invoked by persistence provider

func (*Manager) OnConnection

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

OnConnection implements transport.Handler interface and handles incoming connection

func (*Manager) Shutdown

func (m *Manager) Shutdown() error

Shutdown gracefully by stopping all active sessions and persist states

func (*Manager) Stop

func (m *Manager) Stop() error

Stop session manager. Stops any existing connections

type StartConfig

type StartConfig struct {
	Req  *mqttp.Connect
	Resp *mqttp.ConnAck
	Conn net.Conn
	Auth vlauth.Permissions
}

StartConfig used to reconfigure session after connection is created