Versions in this module Expand all Collapse all v1 v1.1.0 Dec 9, 2020 Changes in this version + type IConnManager interface + Add func(conn IConnection) + ClearConn func() + Get func(connID uint64) (IConnection, bool) + Remove func(conn IConnection) + type IConnection interface + GetBytesCache func() *bytes.Buffer + GetConnId func() uint64 + GetPackCount func() int64 + GetProperty func(key string) (interface{}, error) + GetRemoteAddr func() net.Addr + OnCompleted func(data []byte, offset int, count int) + OnReceiveCompleted func(data []byte) + RemoveProperty func(key string) + SendData func(data []byte) error + SendDataCall func(data []byte, param interface{}, ...) error + SetProperty func(key string, value interface{}) + Start func() + Stop func() + type IMsgHandle interface + SendMsgToTaskQueue func(request IRequest) + StartWorkerPool func() + StopWorkerPool func() + type IReceiver interface + IsMeHandle func(conn IConnection, buffer []byte) (isMe bool) + Receiver func(conn IConnection, buffer []byte) ([]byte, int, bool) + type IRequest interface + GetConnection func() IConnection + GetCount func() int + GetData func() []byte + type IService interface + GetConn func(connId uint64) (IConnection, bool) + GetConnMgr func() IConnManager + SetCreateReceiver func(hookFunc func(IConnection, []byte) []IReceiver) + SetErrorHandle func(func(level string, msg string)) + SetOnConnStart func(hookFunc func(IConnection)) + SetOnConnStop func(hookFunc func(IConnection)) + SetOnReceiveCompleted func(hookFunc func(IConnection, []byte)) + Start func() + Stop func()