Versions in this module Expand all Collapse all v1 v1.3.0 Aug 23, 2021 Changes in this version + func NewDataPack() ziface.Packet + func NewServer(opts ...Option) ziface.IServer + type BaseRouter struct + func (br *BaseRouter) Handle(req ziface.IRequest) + func (br *BaseRouter) PostHandle(req ziface.IRequest) + func (br *BaseRouter) PreHandle(req ziface.IRequest) + type ConnManager struct + func NewConnManager() *ConnManager + func (connMgr *ConnManager) Add(conn ziface.IConnection) + func (connMgr *ConnManager) ClearConn() + func (connMgr *ConnManager) ClearOneConn(connID uint32) + func (connMgr *ConnManager) Get(connID uint32) (ziface.IConnection, error) + func (connMgr *ConnManager) Len() int + func (connMgr *ConnManager) Remove(conn ziface.IConnection) + type Connection struct + Conn *net.TCPConn + ConnID uint32 + MsgHandler ziface.IMsgHandle + TCPServer ziface.IServer + func NewConnection(server ziface.IServer, conn *net.TCPConn, connID uint32, ...) *Connection + func (c *Connection) Context() context.Context + func (c *Connection) GetConnID() uint32 + func (c *Connection) GetProperty(key string) (interface{}, error) + func (c *Connection) GetTCPConnection() *net.TCPConn + func (c *Connection) RemoteAddr() net.Addr + func (c *Connection) RemoveProperty(key string) + func (c *Connection) SendBuffMsg(msgID uint32, data []byte) error + func (c *Connection) SendMsg(msgID uint32, data []byte) error + func (c *Connection) SetProperty(key string, value interface{}) + func (c *Connection) Start() + func (c *Connection) StartReader() + func (c *Connection) StartWriter() + func (c *Connection) Stop() + type DataPack struct + func (dp *DataPack) GetHeadLen() uint32 + func (dp *DataPack) Pack(msg ziface.IMessage) ([]byte, error) + func (dp *DataPack) Unpack(binaryData []byte) (ziface.IMessage, error) + type Message struct + Data []byte + DataLen uint32 + ID uint32 + func NewMsgPackage(ID uint32, data []byte) *Message + func (msg *Message) GetData() []byte + func (msg *Message) GetDataLen() uint32 + func (msg *Message) GetMsgID() uint32 + func (msg *Message) SetData(data []byte) + func (msg *Message) SetDataLen(len uint32) + func (msg *Message) SetMsgID(msgID uint32) + type MsgHandle struct + Apis map[uint32]ziface.IRouter + TaskQueue []chan ziface.IRequest + WorkerPoolSize uint32 + func NewMsgHandle() *MsgHandle + func (mh *MsgHandle) AddRouter(msgID uint32, router ziface.IRouter) + func (mh *MsgHandle) DoMsgHandler(request ziface.IRequest) + func (mh *MsgHandle) SendMsgToTaskQueue(request ziface.IRequest) + func (mh *MsgHandle) StartOneWorker(workerID int, taskQueue chan ziface.IRequest) + func (mh *MsgHandle) StartWorkerPool() + type Option func(s *Server) + func WithPacket(pack ziface.Packet) Option + type Request struct + func (r *Request) GetConnection() ziface.IConnection + func (r *Request) GetData() []byte + func (r *Request) GetMsgID() uint32 + type Server struct + ConnMgr ziface.IConnManager + IP string + IPVersion string + Name string + OnConnStart func(conn ziface.IConnection) + OnConnStop func(conn ziface.IConnection) + Port int + func (s *Server) AddRouter(msgID uint32, router ziface.IRouter) + func (s *Server) CallOnConnStart(conn ziface.IConnection) + func (s *Server) CallOnConnStop(conn ziface.IConnection) + func (s *Server) GetConnMgr() ziface.IConnManager + func (s *Server) Packet() ziface.Packet + func (s *Server) Serve() + func (s *Server) SetOnConnStart(hookFunc func(ziface.IConnection)) + func (s *Server) SetOnConnStop(hookFunc func(ziface.IConnection)) + func (s *Server) Start() + func (s *Server) Stop()
Go to main page