Versions in this module Expand all Collapse all v1 v1.1.0 Jun 3, 2021 Changes in this version + const Version + var ErrConnectNotAuthorized = errors.New("Connect packet was not authorized") + var ErrInvalidTopic = errors.New("Cannot publish to $ and $SYS topics") + var ErrListenerIDExists = errors.New("Listener id already exists") + var ErrReadConnectInvalid = errors.New("Connect packet was not valid") + var SysTopicInterval time.Duration = 30000 + type Server struct + Clients *clients.Clients + Listeners *listeners.Listeners + Store persistence.Store + System *system.Info + Topics *topics.Index + func New() *Server + func (s *Server) AddListener(listener listeners.Listener, config *listeners.Config) error + func (s *Server) AddStore(p persistence.Store) error + func (s *Server) Close() error + func (s *Server) EstablishConnection(lid string, c net.Conn, ac auth.Controller) error + func (s *Server) ResendClientInflight(cl *clients.Client, force bool) error + func (s *Server) Serve() error
Go to main page