netService

Oct 18, 2022

Changes in this version

type Config

+ KeepTime time.Duration

+ Upgraded *websocket.Upgrader

type Connection

+ func (c *Connection) GetSendTime() time.Time

type Service

+ func (s *Service) ToMap() map[string]int64

Jan 7, 2022

Changes in this version

type Service

+ func (s *Service) GetIsStart() bool

Nov 22, 2021

Changes in this version

type Connection

+ func (c *Connection) Incr(val int64) int64

Oct 20, 2021

Changes in this version

type Service

+ func (s *Service) CallRunTaskError(conn netInterface.IConnection, taskType, taskCode int, task interface{})

+ func (s *Service) SetRunTaskError(...)

Oct 7, 2021

Changes in this version

+ var AcceptPool = NewAcceptTaskPool()

+ var ReceivePool = NewReceiveTaskPool()

+ var ReplyPool = NewReplyTaskPool()

type AcceptTask

+ Conn *websocket.Conn

+ ConnId uint64

+ Duration time.Duration

+ OnAccept func(accept *AcceptTask)

+ Request *http.Request

+ Response http.ResponseWriter

+ RunOutTime func(accept *AcceptTask)

+ type AcceptTaskPool struct

+ func NewAcceptTaskPool() *AcceptTaskPool

+ func (a *AcceptTaskPool) Get() *AcceptTask

+ func (a *AcceptTaskPool) Put(acceptTask *AcceptTask)

type Connection

+ func (c *Connection) GetNetwork() string

+ func (c *Connection) GetRequest() *http.Request

type ReceiveTask

+ ConnId uint64

+ Data []byte

+ Duration time.Duration

+ MsgType int

+ OnCompleted func(receive *ReceiveTask)

+ RunOutTime func(receive *ReceiveTask)

+ type ReceiveTaskPool struct

+ func NewReceiveTaskPool() *ReceiveTaskPool

+ func (r *ReceiveTaskPool) Get() *ReceiveTask

+ func (r *ReceiveTaskPool) Put(receiveTask *ReceiveTask)

type ReplyTask

+ CallFunc func(netInterface.IConnection, int, []byte, bool, string, interface{}, error)

+ CmdCode string

+ ConnId uint64

+ Data []byte

+ Duration time.Duration

+ MsgType int

+ Param interface{}

+ RunOutTime func(replyTask *ReplyTask)

+ RunReplyTask func(replyTask *ReplyTask)

+ type ReplyTaskPool struct

+ func NewReplyTaskPool() *ReplyTaskPool

+ func (r *ReplyTaskPool) Get() *ReplyTask

+ func (r *ReplyTaskPool) Put(receiveTask *ReplyTask)

Sep 23, 2021

Changes in this version

type Config

+ OverflowDiscard bool

Sep 17, 2021

Changes in this version

type ConnManager

+ func (c *ConnManager) RemoveById(connId uint64)

type Service

+ func (s *Service) GetAcceptWorkerPool() pools.ITaskWorkerPool

+ func (s *Service) GetReceiveWorkerPool() pools.ITaskWorkerPool

+ func (s *Service) GetReplyWorkerPool() pools.ITaskWorkerPool

Sep 10, 2021

Changes in this version

type AcceptTask

+ func (a *AcceptTask) GetDuration() time.Duration

type ReceiveTask

+ func (r *ReceiveTask) GetDuration() time.Duration

type ReplyTask

+ func (r *ReplyTask) GetDuration() time.Duration

Sep 9, 2021

Changes in this version

type Connection

+ func (c *Connection) GetScheme() string

Sep 8, 2021

Changes in this version

type Connection

+ func (c *Connection) GetPropertyKeys() []string

+ func (c *Connection) OnReceive(messageType int, data []byte)

type ReceiveTask

+ OnReceive func(int, []byte)

type Service

+ OnConnAuth func(netInterface.IConnection, http.ResponseWriter, *http.Request) bool

+ func (s *Service) CallOnOneReceive(conn netInterface.IConnection, msgType int, data []byte)

+ func (s *Service) CallOnReceive(conn netInterface.IConnection, msgType int, data []byte)

+ func (s *Service) CallOnReply(conn netInterface.IConnection, msgType int, data []byte, param interface{}, ...)

+ func (s *Service) SetOnConnAuth(...)

+ func (s *Service) SetOnOneReceive(hookFunc func(netInterface.IConnection, int, []byte))

+ func (s *Service) SetOnReceive(hookFunc func(netInterface.IConnection, int, []byte))

+ func (s *Service) SetOnReply(hookFunc func(netInterface.IConnection, int, []byte, interface{}, bool, error))

May 27, 2021

Changes in this version

+ func NewConnManager() netInterface.IConnManager

+ func NewService(config *Config) netInterface.IService

+ type AcceptTask struct

+ func (a *AcceptTask) CallOutTime()

+ func (a *AcceptTask) GetTaskId() uint64

+ func (a *AcceptTask) RunTask()

+ type Config struct

+ AcceptOutTime time.Duration

+ AcceptTaskQueueSize uint

+ AcceptWorkerSize uint

+ AddrAry []string

+ CertFile string

+ IsOutTime bool

+ KeyFile string

+ PathAry []string

+ RBufferSize int

+ ReceiveOutTime time.Duration

+ ReceiveTaskQueueSize uint

+ ReceiveWorkerSize uint

+ ReplyOutTime time.Duration

+ ReplyTaskQueueSize uint

+ ReplyWorkerSize uint

+ Scheme string

+ SendOutTime time.Duration

+ WBufferSize int

+ func DefaultConfig(scheme string, addrAry []string, pathAry []string) *Config

+ type ConnManager struct

+ func (c *ConnManager) Add(conn netInterface.IConnection)

+ func (c *ConnManager) ClearConn()

+ func (c *ConnManager) Count() int

+ func (c *ConnManager) Get(connID uint64) (netInterface.IConnection, bool)

+ func (c *ConnManager) Range(hFunc func(key uint64, value netInterface.IConnection) bool)

+ func (c *ConnManager) Remove(conn netInterface.IConnection)

+ type Connection struct

+ Conn *websocket.Conn

+ ConnID uint64

+ func NewConnection(server *Service, conn *websocket.Conn, connID uint64, path string, ...) *Connection

+ func (c *Connection) CallLogHandle(level netInterface.ErrLevel, msgAry ...interface{})

+ func (c *Connection) GetConnId() uint64

+ func (c *Connection) GetHeartTime() time.Time

+ func (c *Connection) GetIsClosed() bool

+ func (c *Connection) GetLocalAddr() net.Addr

+ func (c *Connection) GetNetConn() interface{}

+ func (c *Connection) GetPath() string

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

+ func (c *Connection) GetRecInfo() (count, byteSize uint64)

+ func (c *Connection) GetRemoteAddr() net.Addr

+ func (c *Connection) GetRepInfo() (count, byteSize, errCount uint64)

+ func (c *Connection) GetStartTime() time.Time

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

+ func (c *Connection) RemoveProperty(key string)

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

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

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

+ func (c *Connection) Start()

+ func (c *Connection) StartReader()

+ func (c *Connection) Stop()

+ type ReceiveTask struct

+ func (r *ReceiveTask) CallOutTime()

+ func (r *ReceiveTask) GetTaskId() uint64

+ func (r *ReceiveTask) RunTask()

+ type ReplyTask struct

+ func (r *ReplyTask) CallOutTime()

+ func (r *ReplyTask) GetTaskId() uint64

+ func (r *ReplyTask) RunTask()

+ type Service struct

+ AcceptHandle pools.ITaskWorkerPool

+ ConnMgr netInterface.IConnManager

+ OnConnStart func(netInterface.IConnection)

+ OnConnStop func(netInterface.IConnection)

+ func (s *Service) AddConnId() uint64

+ func (s *Service) CallLogHandle(level netInterface.ErrLevel, msgAry ...interface{})

+ func (s *Service) CallOnConnStart(conn netInterface.IConnection)

+ func (s *Service) CallOnConnStop(conn netInterface.IConnection)

+ func (s *Service) CallOnOneReceiveCompleted(conn netInterface.IConnection, msgType int, data []byte)

+ func (s *Service) CallOnReceiveCompleted(conn netInterface.IConnection, msgType int, data []byte)

+ func (s *Service) CallOnReplyCompleted(conn netInterface.IConnection, msgType int, data []byte, param interface{}, ...)

+ func (s *Service) GetAcceptQueueCount() (count int64, totalCount uint64)

+ func (s *Service) GetConn(connId uint64) (netInterface.IConnection, bool)

+ func (s *Service) GetConnMgr() netInterface.IConnManager

+ func (s *Service) GetRecInfo() (count, byteSize uint64)

+ func (s *Service) GetRepInfo() (count, byteSize, errCount uint64)

+ func (s *Service) GetStartTime() time.Time

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

+ func (s *Service) SetLogHandle(hookFunc func(level netInterface.ErrLevel, msg ...interface{}))

+ func (s *Service) SetOnConnStart(hookStart func(conn netInterface.IConnection))

+ func (s *Service) SetOnConnStop(hookStop func(conn netInterface.IConnection))

+ func (s *Service) SetOnOneReceiveCompleted(hookFunc func(netInterface.IConnection, int, []byte))

+ func (s *Service) SetOnReceiveCompleted(hookFunc func(netInterface.IConnection, int, []byte))

+ func (s *Service) SetOnReplyCompleted(hookFunc func(netInterface.IConnection, int, []byte, interface{}, bool, error))

+ func (s *Service) Start()

+ func (s *Service) Stop()