Versions in this module Expand all Collapse all v2 v2.0.1 May 24, 2023 Changes in this version + var ErrInvalidMessage = errors.New("message type not binary") + func MockCloser(id string) + func MockEstablisher(id string, c net.Conn) error + type CloseFn func(id string) + type Config struct + TLSConfig *tls.Config + type EstablishFn func(id string, c net.Conn) error + type HTTPStats struct + func NewHTTPStats(id, address string, config *Config, sysInfo *system.Info) *HTTPStats + func (l *HTTPStats) Address() string + func (l *HTTPStats) Close(closeClients CloseFn) + func (l *HTTPStats) ID() string + func (l *HTTPStats) Init(log *zerolog.Logger) error + func (l *HTTPStats) Protocol() string + func (l *HTTPStats) Serve(establish EstablishFn) + type Listener interface + Address func() string + Close func(CloseFn) + ID func() string + Init func(*zerolog.Logger) error + Protocol func() string + Serve func(EstablishFn) + type Listeners struct + func New() *Listeners + func (l *Listeners) Add(val Listener) + func (l *Listeners) Close(id string, closer CloseFn) + func (l *Listeners) CloseAll(closer CloseFn) + func (l *Listeners) Delete(id string) + func (l *Listeners) Get(id string) (Listener, bool) + func (l *Listeners) Len() int + func (l *Listeners) Serve(id string, establisher EstablishFn) + func (l *Listeners) ServeAll(establisher EstablishFn) + type MockListener struct + Config *Config + ErrListen bool + Listening bool + Serving bool + func NewMockListener(id, address string) *MockListener + func (l *MockListener) Address() string + func (l *MockListener) Close(closer CloseFn) + func (l *MockListener) ID() string + func (l *MockListener) Init(log *zerolog.Logger) error + func (l *MockListener) IsListening() bool + func (l *MockListener) IsServing() bool + func (l *MockListener) Protocol() string + func (l *MockListener) Serve(establisher EstablishFn) + type Net struct + func NewNet(id string, listener net.Listener) *Net + func (l *Net) Address() string + func (l *Net) Close(closeClients CloseFn) + func (l *Net) ID() string + func (l *Net) Init(log *zerolog.Logger) error + func (l *Net) Protocol() string + func (l *Net) Serve(establish EstablishFn) + type TCP struct + func NewTCP(id, address string, config *Config) *TCP + func (l *TCP) Address() string + func (l *TCP) Close(closeClients CloseFn) + func (l *TCP) ID() string + func (l *TCP) Init(log *zerolog.Logger) error + func (l *TCP) Protocol() string + func (l *TCP) Serve(establish EstablishFn) + type UnixSock struct + func NewUnixSock(id, address string) *UnixSock + func (l *UnixSock) Address() string + func (l *UnixSock) Close(closeClients CloseFn) + func (l *UnixSock) ID() string + func (l *UnixSock) Init(log *zerolog.Logger) error + func (l *UnixSock) Protocol() string + func (l *UnixSock) Serve(establish EstablishFn) + type Websocket struct + func NewWebsocket(id, address string, config *Config) *Websocket + func (l *Websocket) Address() string + func (l *Websocket) Close(closeClients CloseFn) + func (l *Websocket) ID() string + func (l *Websocket) Init(log *zerolog.Logger) error + func (l *Websocket) Protocol() string + func (l *Websocket) Serve(establish EstablishFn)