netInterface

Oct 18, 2022

Changes in this version

type IConnection

+ GetSendTime func() time.Time

type IService

+ ToMap func() map[string]int64

Jan 7, 2022

Changes in this version

type IService

+ GetIsStart func() bool

Nov 22, 2021

Changes in this version

type IConnection

+ Incr func(val int64) int64

Nov 12, 2021

Changes in this version

+ var AcceptTask TaskTypeCode = 1

+ var ReceiveTask TaskTypeCode = 2

+ var ReplyTask TaskTypeCode = 4

+ var TaskErr TaskErrCode = 1

+ var TaskOutTime TaskErrCode = 0

+ 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{}))

Oct 7, 2021

Changes in this version

type IConnection

+ GetNetwork func() string

+ GetRequest func() *http.Request

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

+ GetScheme func() string

Sep 8, 2021

Changes in this version

type IConnection

+ GetPropertyKeys func() []string

type IService

+ SetOnConnAuth func(hookStart func(conn IConnection, w http.ResponseWriter, r *http.Request) bool)

+ SetOnOneReceive func(hookFunc func(IConnection, int, []byte))

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

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

May 27, 2021

Changes in this version

+ type ErrLevel int

+ const Error

+ const Fatal

+ const Info

+ const Warn

+ type IConnManager interface

+ Add func(conn IConnection)

+ ClearConn func()

+ Count func() int

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

+ Range func(hFunc func(key uint64, value IConnection) bool)

+ Remove func(conn IConnection)

+ type IConnection interface

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

+ GetConnId func() uint64

+ GetHeartTime func() time.Time

+ GetIsClosed func() bool

+ GetLocalAddr func() net.Addr

+ GetNetConn func() interface{}

+ GetPath func() string

+ GetProperty func(key string) (interface{}, error)

+ GetRecInfo func() (count, byteSize uint64)

+ GetRemoteAddr func() net.Addr

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

+ GetStartTime func() time.Time

+ OnReceiveCompleted func(messageType int, data []byte)

+ RemoveProperty func(key string)

+ SendData func(msgType int, data []byte) error

+ SendDataCall func(msgType int, data []byte, param interface{}, ...) error

+ SetProperty func(key string, value interface{})

+ Start func()

+ Stop func()

+ type IService interface

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

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

+ GetConnMgr func() IConnManager

+ GetRecInfo func() (count, byteSize uint64)

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

+ GetStartTime func() time.Time

+ GetTotalQueueCount func() (receiveCount int64, receiveTotalCount uint64, replyCount int64, ...)

+ SetLogHandle func(func(level ErrLevel, msg ...interface{}))

+ SetOnConnStart func(hookFunc func(IConnection))

+ SetOnConnStop func(hookFunc func(IConnection))

+ SetOnOneReceiveCompleted func(hookFunc func(IConnection, int, []byte))

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

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

+ Start func()

+ Stop func()