netService

Jul 20, 2023

Changes in this version

type UdpService

+ func (s *UdpService) Clear(connId uint64, odExpTime time.Time)

Oct 28, 2022

Changes in this version

+ const HKey

Oct 28, 2022

Changes in this version

type AddrConfig

+ TlsConfig *tls.Config

type Config

+ KeepTime time.Duration

+ SendRetryCount int

type Connection

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

type Service

+ func (s *Service) SetHandleStrategy(hookFunc func(netInterface.IConnection, []byte) *netInterface.StrategyData)

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

type UdpConnection

+ func (u *UdpConnection) GetSendTime() time.Time

type UdpService

+ func (s *UdpService) SetHandleStrategy(hookFunc func(netInterface.IConnection, []byte) *netInterface.StrategyData)

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

Jan 7, 2022

Changes in this version

type Service

+ func (s *Service) GetIsStart() bool

type UdpService

+ func (u *UdpService) GetIsStart() bool

Nov 22, 2021

Changes in this version

type Connection

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

type UdpConnection

+ func (u *UdpConnection) Incr(val int64) int64

Oct 25, 2021

Changes in this version

type Config

+ HandleOutTime time.Duration

+ HandleTaskQueueSize uint

+ HandleWorkerSize uint

type Connection

+ func (c *Connection) PackageHandle(handleTask *handleTask)

type Service

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

type UdpService

+ func (u *UdpService) GetHandleWorkerPool() pools.ITaskWorkerPool

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(...)

type UdpService

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

+ func (u *UdpService) SetRunTaskError(...)

Oct 8, 2021

Changes in this version

+ var AcceptPool = NewAcceptTaskPool()

+ var ReceivePool = NewReceiveTaskPool()

+ var ReplyPool = NewReplyTaskPool()

type AcceptTask

+ Conn net.Conn

+ ConnId uint64

+ Duration time.Duration

+ OnAccept func(accept *AcceptTask)

+ RunOutTime func(accept *AcceptTask)

+ type AcceptTaskPool struct

+ func NewAcceptTaskPool() *AcceptTaskPool

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

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

type ReceiveTask

+ ConnId uint64

+ Count int

+ Data []byte

+ Duration time.Duration

+ 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, []byte, bool, string, interface{}, error)

+ CmdCode string

+ ConnId uint64

+ Data []byte

+ Duration time.Duration

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

type UdpConnection

+ func (u *UdpConnection) RunReceiveOutTime(receive *ReceiveTask)

Sep 24, 2021

Changes in this version

type Config

+ MaxPackageSize int

+ MinPackageSize int

Sep 22, 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

type UdpService

+ func (u *UdpService) GetAcceptWorkerPool() pools.ITaskWorkerPool

+ func (u *UdpService) GetReceiveWorkerPool() pools.ITaskWorkerPool

+ func (u *UdpService) 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

type UdpReceiveTask

+ func (u *UdpReceiveTask) GetDuration() time.Duration

type UdpReplyTask

+ func (u *UdpReplyTask) GetDuration() time.Duration

Sep 9, 2021

Changes in this version

type Connection

+ func (c *Connection) GetNetwork() string

type UdpConnection

+ func (u *UdpConnection) GetNetwork() string

Sep 5, 2021

Changes in this version

type ReceiveTask

+ OnCompleted func(data []byte, count int)

type UdpReceiveTask

+ OnCompleted func(data []byte, count int)

Sep 4, 2021

Changes in this version

type Connection

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

type UdpConnection

+ func (u *UdpConnection) GetPropertyKeys() []string

Aug 30, 2021

Changes in this version

type Connection

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

type Service

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

+ func (s *Service) CallOnReply(conn netInterface.IConnection, data []byte, isOk bool, cmdCode string, ...)

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

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

type UdpConnection

+ func (u *UdpConnection) OnReceive(data []byte)

type UdpService

+ func (u *UdpService) CallOnReceive(conn netInterface.IConnection, data []byte)

+ func (u *UdpService) CallOnReply(conn netInterface.IConnection, data []byte, isOk bool, cmdCode string, ...)

+ func (u *UdpService) SetOnReceive(hookFunc func(netInterface.IConnection, []byte))

+ func (u *UdpService) SetOnReply(...)

Aug 18, 2021

Changes in this version

type Config

+ HDataCache bool

Jul 28, 2021

Changes in this version

+ type AddrConfig struct

+ Addr string

+ CertFile string

+ ClientCer string

+ IsTls bool

+ KeyFile string

type Config

+ func NewConfig(network string, addrAry []*AddrConfig) *Config

Jun 3, 2021

Changes in this version

+ type AcceptTask struct

+ func (a *AcceptTask) CallOutTime()

+ func (a *AcceptTask) GetTaskId() uint64

+ func (a *AcceptTask) RunTask() int

type Config

+ AcceptOutTime time.Duration

+ AcceptTaskQueueSize uint

+ AcceptWorkerSize uint

+ IsOutTime bool

+ ReceiveOutTime time.Duration

+ ReplyOutTime time.Duration

type ConnManager

+ func (c *ConnManager) Count() int

type Connection

+ func (c *Connection) GetIsClosed() bool

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

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

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

+ type ReceiveTask struct

+ func (r *ReceiveTask) CallOutTime()

+ func (r *ReceiveTask) GetTaskId() uint64

+ func (r *ReceiveTask) RunTask() int

+ type ReplyTask struct

+ func (r *ReplyTask) CallOutTime()

+ func (r *ReplyTask) GetTaskId() uint64

+ func (r *ReplyTask) RunTask() int

type Service

+ AcceptHandle pools.ITaskWorkerPool

+ func (s *Service) AddConnId() uint64

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

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

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

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

type UdpConnection

+ func (u *UdpConnection) GetIsClosed() bool

+ func (u *UdpConnection) GetRecInfo() (count, byteSize uint64)

+ func (u *UdpConnection) GetRecPackCount() uint64

+ func (u *UdpConnection) GetRepInfo() (count, byteSize, errCount uint64)

+ func (u *UdpConnection) GetStartTime() time.Time

+ type UdpReceiveTask struct

+ func (u *UdpReceiveTask) CallOutTime()

+ func (u *UdpReceiveTask) GetConnection() (netInterface.IConnection, bool)

+ func (u *UdpReceiveTask) GetTaskId() uint64

+ func (u *UdpReceiveTask) RunTask() int

+ type UdpReplyTask struct

+ func (u *UdpReplyTask) CallOutTime()

+ func (u *UdpReplyTask) GetTaskId() uint64

+ func (u *UdpReplyTask) RunTask() int

type UdpService

+ func (u *UdpService) AddConnId() uint64

+ func (u *UdpService) GetAcceptQueueCount() (count int64, totalCount, outTimeCount uint64)

+ func (u *UdpService) GetRecInfo() (count, byteSize uint64)

+ func (u *UdpService) GetRepInfo() (count, byteSize, errCount uint64)

+ func (u *UdpService) GetStartTime() time.Time

Feb 26, 2021

Changes in this version

type ConnManager

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

Dec 24, 2020

Changes in this version

type Config

+ SendOutTime time.Duration

Dec 15, 2020

Changes in this version

type Connection

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

type UdpConnection

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

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

Dec 14, 2020

Changes in this version

type Config

+ ReceiveTaskQueueSize uint

+ ReceiveWorkerSize uint

+ ReplyTaskQueueSize uint

+ ReplyWorkerSize uint

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

type Connection

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

+ type RequestTask struct

+ func (r *RequestTask) Execute()

+ func (r *RequestTask) GetTaskId() uint64

+ type ResponseTask struct

+ func (s *ResponseTask) Execute()

+ func (s *ResponseTask) GetTaskId() uint64

type Service

+ OnLogHandle func(level netConn.ErrLevel, msg string)

+ OnReplyCompleted func(conn netConn.IConnection, data []byte, param interface{}, ok bool, err error)

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

+ func (s *Service) CallOnReplyCompleted(conn netConn.IConnection, data []byte, param interface{}, ok bool, err error)

+ func (s *Service) GetTotalQueueCount() (receiveCount int32, replyCount int32)

+ func (s *Service) SetLogHandle(hookFunc func(level netConn.ErrLevel, msg string))

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

type UdpConnection

+ func (c *UdpConnection) CallLogHandle(level netConn.ErrLevel, msgAry ...interface{})

+ type UdpRequestTask struct

+ func (r *UdpRequestTask) Execute()

+ func (r *UdpRequestTask) GetConnection() (netConn.IConnection, bool)

+ func (r *UdpRequestTask) GetTaskId() uint64

+ type UdpResponseTask struct

+ func (s *UdpResponseTask) Execute()

+ func (s *UdpResponseTask) GetTaskId() uint64

type UdpService

+ OnLogHandle func(level netConn.ErrLevel, msg string)

+ OnReplyCompleted func(conn netConn.IConnection, data []byte, param interface{}, ok bool, err error)

+ func (s *UdpService) CallLogHandle(level netConn.ErrLevel, msgAry ...interface{})

+ func (s *UdpService) CallOnReplyCompleted(conn netConn.IConnection, data []byte, param interface{}, ok bool, err error)

+ func (s *UdpService) GetTotalQueueCount() (receiveCount int32, replyCount int32)

+ func (s *UdpService) SetLogHandle(hookFunc func(level netConn.ErrLevel, msg string))

+ func (s *UdpService) SetOnReplyCompleted(hookFunc func(netConn.IConnection, []byte, interface{}, bool, error))

Dec 11, 2020

Changes in this version

type Config

+ BytesCacheSize uint

type Connection

+ func (c *Connection) RecoveryBytesCache()

Dec 10, 2020

Changes in this version

type Config

+ BytesCache int

type ConnManager

+ func (connMgr *ConnManager) GetOvertimeConn(overtimeSecond float64) []netConn.IConnection

type Connection

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

type Request

+ func (r *Request) GetConnId() uint64

type UdpConnection

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

+ type UdpRequest struct

+ ConnId uint64

+ Count int

+ Data []byte

+ func (r *UdpRequest) GetConnId() uint64

+ func (r *UdpRequest) GetConnection() (netConn.IConnection, bool)

+ func (r *UdpRequest) GetCount() int

+ func (r *UdpRequest) GetData() []byte

Dec 9, 2020

Changes in this version

+ func NewConnManager() netConn.IConnManager

+ func NewConnection(server *Service, conn net.Conn, connId uint64, msgHandler netConn.IMsgHandle, ...) netConn.IConnection

+ func NewMsgHandle(workerSize int, taskQueueSize int) netConn.IMsgHandle

+ func NewService(config *Config) netConn.IService

+ func NewUdpConnection(server *UdpService, conn *net.UDPConn, connId uint64, remoteAddr net.Addr, ...) netConn.IConnection

+ func NewUdpService(config *Config) netConn.IService

+ type CallSendHandle struct

+ Buf []byte

+ CallFunc func(netConn.IConnection, bool, interface{}, error)

+ Param interface{}

+ type Config struct

+ AddrAry []string

+ BufferCount uint

+ BufferSize uint

+ Network string

+ SendDataCount int

+ TaskQueueSize int

+ WorkerSize int

+ type ConnManager struct

+ func (connMgr *ConnManager) Add(conn netConn.IConnection)

+ func (connMgr *ConnManager) ClearConn()

+ func (connMgr *ConnManager) Get(connID uint64) (netConn.IConnection, bool)

+ func (connMgr *ConnManager) Len() int

+ func (connMgr *ConnManager) Remove(conn netConn.IConnection)

+ type Connection struct

+ Conn net.Conn

+ ConnId uint64

+ ExitBuffChan chan bool

+ HeartTime time.Time

+ MsgHandler netConn.IMsgHandle

+ PackCount int64

+ Receiver []netConn.IReceiver

+ Server *Service

+ func (c *Connection) GetBytesCache() *bytes.Buffer

+ func (c *Connection) GetConnId() uint64

+ func (c *Connection) GetNetConn() net.Conn

+ func (c *Connection) GetPackCount() int64

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

+ func (c *Connection) GetReceiver() []netConn.IReceiver

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

+ func (c *Connection) OnCompleted(data []byte, offset int, count int)

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

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

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

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

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

+ func (c *Connection) Start()

+ func (c *Connection) Stop()

+ type MsgHandle struct

+ ExitMsgChan []chan bool

+ TaskQueue []chan netConn.IRequest

+ func (mh *MsgHandle) DoMsgHandler(request netConn.IRequest)

+ func (mh *MsgHandle) SendMsgToTaskQueue(request netConn.IRequest)

+ func (mh *MsgHandle) StartOneWorker(workerID int, taskQueue chan netConn.IRequest)

+ func (mh *MsgHandle) StartWorkerPool()

+ func (mh *MsgHandle) StopWorkerPool()

+ type Request struct

+ Conn netConn.IConnection

+ Count int

+ Data []byte

+ func (r *Request) GetConnection() netConn.IConnection

+ func (r *Request) GetCount() int

+ func (r *Request) GetData() []byte

+ type Service struct

+ BufferPool *util.BufferPool

+ ConnId uint64

+ ConnMgr netConn.IConnManager

+ CreateReceiver func(conn netConn.IConnection, data []byte) []netConn.IReceiver

+ ExitServiceChan chan bool

+ OnConnStart func(conn netConn.IConnection)

+ OnConnStop func(conn netConn.IConnection)

+ OnErrorHandle func(level string, msg string)

+ OnReceiveCompleted func(conn netConn.IConnection, data []byte)

+ func (s *Service) CallErrorhandle(level string, msg ...string)

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

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

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

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

+ func (s *Service) GetConnId() uint64

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

+ func (s *Service) SetCreateReceiver(hookFunc func(netConn.IConnection, []byte) []netConn.IReceiver)

+ func (s *Service) SetErrorHandle(hookFunc func(level string, msg string))

+ func (s *Service) SetOnConnStart(hookFunc func(netConn.IConnection))

+ func (s *Service) SetOnConnStop(hookFunc func(netConn.IConnection))

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

+ func (s *Service) Start()

+ func (s *Service) Stop()

+ type UdpConnection struct

+ Conn *net.UDPConn

+ ConnId uint64

+ ExitBuffChan chan bool

+ HeartTime time.Time

+ MsgHandler netConn.IMsgHandle

+ PackCount int64

+ RemoteAddr net.Addr

+ Server *UdpService

+ func (c *UdpConnection) GetBytesCache() *bytes.Buffer

+ func (c *UdpConnection) GetConnId() uint64

+ func (c *UdpConnection) GetPackCount() int64

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

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

+ func (c *UdpConnection) OnCompleted(data []byte, offset int, count int)

+ func (c *UdpConnection) OnReceiveCompleted(data []byte)

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

+ func (c *UdpConnection) SendData(data []byte) error

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

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

+ func (c *UdpConnection) Start()

+ func (c *UdpConnection) Stop()

+ type UdpService struct

+ BufferPool *util.BufferPool

+ ConnId uint64

+ ConnMgr netConn.IConnManager

+ ConnectionsMap map[string]uint64

+ CreateReceiver func(conn netConn.IConnection, data []byte) []netConn.IReceiver

+ ExitServiceChan chan bool

+ OnConnStart func(conn netConn.IConnection)

+ OnConnStop func(conn netConn.IConnection)

+ OnErrorHandle func(level string, msg string)

+ OnReceiveCompleted func(conn netConn.IConnection, data []byte)

+ func (s *UdpService) CallErrorhandle(level string, msgs ...string)

+ func (s *UdpService) CallOnConnStart(conn netConn.IConnection)

+ func (s *UdpService) CallOnConnStop(conn netConn.IConnection)

+ func (s *UdpService) CallOnReceiveCompleted(conn netConn.IConnection, data []byte)

+ func (s *UdpService) GetConn(connId uint64) (netConn.IConnection, bool)

+ func (s *UdpService) GetConnId() uint64

+ func (s *UdpService) GetConnMgr() netConn.IConnManager

+ func (s *UdpService) SetCreateReceiver(hookFunc func(netConn.IConnection, []byte) []netConn.IReceiver)

+ func (s *UdpService) SetErrorHandle(hookFunc func(level string, msg string))

+ func (s *UdpService) SetOnConnStart(hookFunc func(netConn.IConnection))

+ func (s *UdpService) SetOnConnStop(hookFunc func(netConn.IConnection))

+ func (s *UdpService) SetOnReceiveCompleted(hookFunc func(netConn.IConnection, []byte))

+ func (s *UdpService) Start()

+ func (s *UdpService) Stop()