Versions in this module Expand all Collapse all v1 v1.0.2 Aug 2, 2022 v1.0.1 Aug 2, 2022 v1.0.0 Jul 29, 2022 Changes in this version + const HeartBeatTime + const Http + const MaxResTime + const Tcp + const WebSocket + var RouteItemMgr = &msgRouteMgr + type ConnCallback func(conn IConnection) + type ConnManager struct + func NewConnManager() *ConnManager + func (c *ConnManager) Add(conn IConnection) + func (c *ConnManager) BroadcastMsg(msgId uint32, data []byte) + func (c *ConnManager) ClearConn() + func (c *ConnManager) ClearOneConn(connID uint32) + func (c *ConnManager) Get(connID uint32) (IConnection, error) + func (c *ConnManager) Len() int32 + func (c *ConnManager) Remove(conn IConnection) + type Group struct + func (g *Group) AddRoute(path string, callback HandlerCallback) + type HandlerCallback interface + type HandlerFunc func(request *Request, msg proto.Message) + type IConnection interface + GetConnID func() uint32 + GetProtocolType func() ProtocolType + GetSocket func() ISocket + GetTcpConnection func() *net.TCPConn + GetWsConnection func() *websocket.Conn + IsClosed func() bool + RemoteAddr func() net.Addr + SendMsg func(msgId uint32, data []byte) error + SetClosed func() bool + Start func() + Stop func() + type ISocket interface + CallOnConnStart func(conn IConnection) + CallOnConnStop func(conn IConnection) + GetConnMgr func() *ConnManager + GetHost func() string + GetId func() string + GetName func() string + GetPort func() int32 + GetRouter func() *Router + Run func() + SetOnConnStart func(startCallBack ConnCallback) + SetOnConnStop func(stopCallback ConnCallback) + Start func() + Stop func() + type Msg struct + Data []byte + DataLen uint32 + ID uint32 + func NewMsg(msgId uint32, data []byte) *Msg + func (m *Msg) GetData() []byte + func (m *Msg) GetDataLen() uint32 + func (m *Msg) GetMsgId() uint32 + func (m *Msg) SetData(data []byte) + func (m *Msg) SetDataLen(len uint32) + func (m *Msg) SetMsgId(msgId uint32) + func (m *Msg) WithData(data []byte) *Msg + func (m *Msg) WithMsgId(msgId uint32) *Msg + type MsgHandler struct + Router *Router + TaskExit []chan bool + TaskQueue []chan *Request + WorkerPoolSize uint32 + WorkerTaskSize uint32 + func NewMsgHandler(workerPoolSize uint32, workerTaskSize uint32) *MsgHandler + func (mh *MsgHandler) HandleMsg(req *Request) + func (mh *MsgHandler) SendMsgToTaskQueue(request *Request) + func (mh *MsgHandler) SetRouter(router *Router) + func (mh *MsgHandler) StartWorkerPool() + func (mh *MsgHandler) StopWorkerPool() + type ProtocolType uint8 + type Request struct + Conn IConnection + Msg *Msg + func NewRequest(conn IConnection, msg *Msg) *Request + func (r *Request) GetConnId() uint32 + func (r *Request) GetConnection() IConnection + func (r *Request) GetMessage() *Msg + type RouteItem struct + MsgId uint32 + Proto string + Route string + type Router struct + func (r *Router) Group(prefix string) *Group + func (r *Router) Run(req *Request)
Go to main page