Versions in this module Expand all Collapse all v0 v0.1.0 Dec 14, 2021 Changes in this version + var ErrInvalidMessage = errors.New("Message type not binary") + func MockCloser(id string) + func MockEstablisher(id string, c net.Conn, auth mqtt.Auth) error + type HTTPStats struct + func NewHTTPStats(id, address string) *HTTPStats + func NewHTTPStatsWithTLS(id, address string, tls *tls.Config) *HTTPStats + func (l *HTTPStats) Auth() mqtt.Auth + func (l *HTTPStats) Close(closeClients mqtt.CloseFunc) + func (l *HTTPStats) ID() string + func (l *HTTPStats) Listen(s *system.Info) error + func (l *HTTPStats) Serve(establish mqtt.EstablishFunc) error + type MockListener struct + ErrListen bool + Listening bool + Serving bool + func NewMockListener(id, address string) *MockListener + func (l *MockListener) Close(closer mqtt.CloseFunc) + func (l *MockListener) ID() string + func (l *MockListener) IsListening() bool + func (l *MockListener) IsServing() bool + func (l *MockListener) Listen(s *system.Info) error + func (l *MockListener) Serve(establisher mqtt.EstablishFunc) error + type TCP struct + func NewTCP(id, address string, auth mqtt.Auth) *TCP + func NewTCPWithTLS(id, address string, auth mqtt.Auth, tls *tls.Config) *TCP + func (l *TCP) Auth() mqtt.Auth + func (l *TCP) Close(closeClients mqtt.CloseFunc) + func (l *TCP) ID() string + func (l *TCP) Listen(s *system.Info) error + func (l *TCP) Serve(establish mqtt.EstablishFunc) error + type Websocket struct + func NewWebsocket(id, address string, auth mqtt.Auth) *Websocket + func NewWebsocketWithTLS(id, address string, auth mqtt.Auth, tls *tls.Config) *Websocket + func (l *Websocket) Auth() mqtt.Auth + func (l *Websocket) Close(closeClients mqtt.CloseFunc) + func (l *Websocket) ID() string + func (l *Websocket) Listen(s *system.Info) error + func (l *Websocket) Serve(establish mqtt.EstablishFunc) error
Go to main page