Versions in this module Expand all Collapse all v1 v1.0.1 Aug 31, 2021 Changes in this version + func NewDataPack() ziface.Packet + func NewLimiter() ziface.ILimiter + func NewServer(opts ...Option) ziface.IServer + type BaseRouter struct + func (br *BaseRouter) Handle(ziface.IRequest) + func (br *BaseRouter) PostHandle(ziface.IRequest) + func (br *BaseRouter) PreHandle(ziface.IRequest) + type ConnManager struct + func NewConnManager() *ConnManager + func (connMgr *ConnManager) Add(conn ziface.IConnection) + func (connMgr *ConnManager) ClearConn() + func (connMgr *ConnManager) ClearOneConn(connID int64) + func (connMgr *ConnManager) Get(connID int64) (ziface.IConnection, error) + func (connMgr *ConnManager) Len() int + func (connMgr *ConnManager) Remove(conn ziface.IConnection) + type Connection struct + CPublicKey sm2.PublicKey + Conn *net.TCPConn + ConnID int64 + MsgHandler ziface.IMsgHandle + SPrivateKey sm2.PrivateKey + ServerPem utils.ServerPem + TcpServer ziface.IServer + func NewConntion(server ziface.IServer, conn *net.TCPConn, connID int64, ...) *Connection + func (c *Connection) GetConnID() int64 + func (c *Connection) GetProperty(key string) (interface{}, error) + func (c *Connection) GetTCPConnection() *net.TCPConn + func (c *Connection) GetTcpServer() ziface.IServer + func (c *Connection) IsAlive() bool + func (c *Connection) KeepAlive() + 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) SendServerPem(msgId uint32, data []byte) error + func (c *Connection) SetProperty(key string, value interface{}) + func (c *Connection) SetSPublicKey(key sm2.PublicKey) + 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 Gate struct + Name string + PublicKey []byte + Sign []byte + UA []byte + type Limier struct + Interval time.Duration + MaxCount int + ReqCount int + func (l *Limier) Increase() + func (l *Limier) IsAvailable() bool + 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 int64 + 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()