MockCloser is a function signature which can be used in testing.

MockEstablisher is a function signature which can be used in testing.

New returns a new instance of Listeners.

NewHTTPHealthCheck initializes and returns a new HTTP listener, listening on an address.

NewHTTPStats initializes and returns a new HTTP listener, listening on an address.

NewMockListener returns a new instance of MockListener.

NewNet initialises and returns a listener serving incoming connections on the given net.Listener.

NewTCP initializes and returns a new TCP listener, listening on an address.

NewUnixSock initializes and returns a new UnixSock listener, listening on an address.

NewWebsocket initializes and returns a new Websocket listener, listening on an address.

ErrInvalidMessage indicates that a message payload was not valid.

Config contains configuration values for a listener.

HTTPHealthCheck is a listener for providing an HTTP healthcheck endpoint.

HTTPStats is a listener for presenting the server $SYS stats on a JSON http endpoint.

Listeners contains the network listeners for the broker.

MockListener is a mock listener for establishing client connections.

Net is a listener for establishing client connections on basic TCP protocol.

TCP is a listener for establishing client connections on basic TCP protocol.

UnixSock is a listener for establishing client connections on basic UnixSock protocol.

Websocket is a listener for establishing websocket connections.

Listener is an interface for network listeners.

CloseFn is a callback function for closing all listener clients.

EstablishFn is a callback function for establishing new clients.