upgrades

Dec 16, 2020

Changes in this version

+ const TCPBufferSize

+ const WebsocketBufferSize

+ func ReleaseTCP(up Interface)

+ func ReleaseWebsocket(up Interface)

+ type Interface interface

+ Manage func(ctx context.Context, clientConn, netlocConn net.Conn)

+ func AcquireTCP(reactor TCPReactor) Interface

+ func AcquireWebsocket(reactor WebsocketReactor) Interface

+ func NewTCP(reactor TCPReactor) Interface

+ func NewWebsocket(reactor WebsocketReactor) Interface

+ type NoopTCPReactor struct

+ func (n NoopTCPReactor) ClientBytes(_ context.Context, _ []byte)

+ func (n NoopTCPReactor) ClientError(_ context.Context, _ error)

+ func (n NoopTCPReactor) NetlocBytes(_ context.Context, _ []byte)

+ func (n NoopTCPReactor) NetlocError(_ context.Context, _ error)

+ type NoopWebsocketReactor struct

+ func (n NoopWebsocketReactor) ClientError(_ context.Context, _ error)

+ func (n NoopWebsocketReactor) ClientMessage(_ context.Context, _ wsutil.Message)

+ func (n NoopWebsocketReactor) NetlocError(_ context.Context, _ error)

+ func (n NoopWebsocketReactor) NetlocMessage(_ context.Context, _ wsutil.Message)

+ type TCPReactor interface

+ ClientBytes func(context.Context, []byte)

+ ClientError func(context.Context, error)

+ NetlocBytes func(context.Context, []byte)

+ NetlocError func(context.Context, error)

+ type WebsocketReactor interface

+ ClientError func(context.Context, error)

+ ClientMessage func(context.Context, wsutil.Message)

+ NetlocError func(context.Context, error)

+ NetlocMessage func(context.Context, wsutil.Message)