netInterface

Oct 28, 2022

Changes in this version

+ var ClosedErr = errors.New("连接关闭，不能发送消息")

+ var NotKey = errors.New("扩展参数没有找到对应的Key")

+ var PackageMaxLen = 64 * 1024

+ var PackageMinLen = 1024

type IConnection

+ GetSendTime func() time.Time

type IService

+ SetHandleStrategy func(h func(IConnection, []byte) *StrategyData)

+ ToMap func() map[string]int64

+ type StrategyData struct

+ ExtData map[string]interface{}

+ Key string

+ Receivers []IReceiver

Jan 7, 2022

Changes in this version

type IService

+ GetIsStart func() bool

Dec 16, 2021

Changes in this version

type IReceiver

+ Reset func()

Nov 22, 2021

Changes in this version

type IConnection

+ Incr func(val int64) int64

Oct 25, 2021

Changes in this version

+ var AcceptTask TaskTypeCode = 1

+ var HandleTask TaskTypeCode = 3

+ var ReceiveTask TaskTypeCode = 2

+ var ReplyTask TaskTypeCode = 4

+ var TaskErr TaskErrCode = 1

+ var TaskOutTime TaskErrCode = 0

type IService

+ GetHandleWorkerPool func() pools.ITaskWorkerPool

+ type TaskErrCode int

+ type TaskTypeCode int

Oct 20, 2021

Changes in this version

type IService

+ SetRunTaskError func(h func(conn IConnection, taskType, taskCode int, task interface{}))

Sep 17, 2021

Changes in this version

type IConnManager

+ RemoveById func(connId uint64)

type IService

+ GetAcceptWorkerPool func() pools.ITaskWorkerPool

+ GetReceiveWorkerPool func() pools.ITaskWorkerPool

+ GetReplyWorkerPool func() pools.ITaskWorkerPool

Sep 9, 2021

Changes in this version

type IConnection

+ GetNetwork func() string

Sep 4, 2021

Changes in this version

type IConnection

+ GetPropertyKeys func() []string

Aug 30, 2021

Changes in this version

type IConnection

+ OnReceive func(data []byte)

type IService

+ SetOnReceive func(hookFunc func(IConnection, []byte))

+ SetOnReply func(hookFunc func(IConnection, []byte, bool, string, interface{}, error))

Aug 18, 2021

Changes in this version

+ var MultiSizeBufferPool = pools.NewBufferPoolMany(128, 65536, 2)

Aug 18, 2021

Changes in this version

type IReceiver

+ CanHandle func(conn IConnection, buffer []byte) bool

+ GetHeadLen func() int

Jun 3, 2021

Changes in this version

type IConnManager

+ Count func() int

type IConnection

+ GetIsClosed func() bool

+ GetRecInfo func() (count, byteSize uint64)

+ GetRepInfo func() (count, byteSize, errCount uint64)

+ GetStartTime func() time.Time

type IService

+ GetAcceptQueueCount func() (count int64, totalCount, outTimeCount uint64)

+ GetRecInfo func() (count, byteSize uint64)

+ GetRepInfo func() (count, byteSize, errCount uint64)

+ GetStartTime func() time.Time

Feb 26, 2021

Changes in this version

type IConnManager

+ Range func(hFunc func(key, value interface{}) bool)

Feb 1, 2021

Changes in this version

+ type ErrLevel int32

+ const Error

+ const Fatal

+ const Info

+ const Warn

+ type IConnManager interface

+ Add func(conn IConnection)

+ ClearConn func()

+ Get func(connID uint64) (IConnection, bool)

+ GetOvertimeConn func(overtimeSecond float64) []IConnection

+ Len func() int

+ Remove func(conn IConnection)

+ type IConnection interface

+ CallLogHandle func(level ErrLevel, msgAry ...interface{})

+ GetBytesCache func() *bytes.Buffer

+ GetConnId func() uint64

+ GetHeartTime func() time.Time

+ GetLocalAddr func() net.Addr

+ GetNetConn func() interface{}

+ 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 IReceiver interface

+ IsMeHandle func(conn IConnection, buffer []byte) (isMe bool)

+ Receiver func(conn IConnection, buffer []byte) ([]byte, int, bool)

+ type IService interface

+ GetConn func(connId uint64) (IConnection, bool)

+ GetConnMgr func() IConnManager

+ GetTotalQueueCount func() (receiveCount int32, replyCount int32)

+ SetCreateReceiver func(hookFunc func(IConnection, []byte) []IReceiver)

+ SetLogHandle func(func(level ErrLevel, msg string))

+ SetOnConnStart func(hookFunc func(IConnection))

+ SetOnConnStop func(hookFunc func(IConnection))

+ SetOnReceiveCompleted func(hookFunc func(IConnection, []byte))

+ SetOnReplyCompleted func(hookFunc func(IConnection, []byte, interface{}, bool, error))

+ Start func()

+ Stop func()