Documentation ¶
Index ¶
- Constants
- func AddSession(s defs.ISession)
- func DelSession(sessionId string)
- func GetSession(sessionId string) defs.ISession
- func ListenTcp(addr string) net.Listener
- func RangeSession(f func(sId string, s defs.ISession) bool)
- func WaitExit()
- type Connection
- func (c *Connection) Close() bool
- func (c *Connection) DelContext(key interface{})
- func (c *Connection) GetConn() net.Conn
- func (c *Connection) GetContext(key interface{}) interface{}
- func (c *Connection) GetId() string
- func (c *Connection) IsClosed() bool
- func (c *Connection) LocalAddr() string
- func (c *Connection) OnConnection()
- func (c *Connection) ReadPacket(packet defs.IPacket)
- func (c *Connection) RemoteAddr() string
- func (c *Connection) SetAuthorizedCallback(cb defs.AuthorizedCallback)
- func (c *Connection) SetCloseCallback(cb defs.CloseCallback)
- func (c *Connection) SetCodec(codec defs.ICodec)
- func (c *Connection) SetConnCallback(cb defs.ConnCallback)
- func (c *Connection) SetContext(key, value interface{})
- func (c *Connection) SetIOModule(ioModule defs.IIOModule)
- func (c *Connection) SetMsgCallback(cb defs.MsgCallback)
- func (c *Connection) SetWriteCompleteCallback(cb defs.WriteCompleteCallback)
- func (c *Connection) Start() bool
- func (c *Connection) UpdateCodec(codec defs.ICodec)
- func (c *Connection) WriteComplete()
- func (c *Connection) WriteData(data []byte)
- func (c *Connection) WriteDataAwait(data []byte) (defs.IPacket, error)
- func (c *Connection) WriteDataById(id string, data []byte)
- func (c *Connection) WriteDataByIdAwait(id string, data []byte) (defs.IPacket, error)
- func (c *Connection) WritePacket(packet defs.IPacket)
- func (c *Connection) WritePacketAwait(packet defs.IPacket) (defs.IPacket, error)
- type ConnectionMgr
- type Connector
- type Map
- type Server
- func (s *Server) AddRemoteClient(cfg *conf.ServerConfig) *TcpClient
- func (s *Server) GetCfg() *conf.ServerConfig
- func (s *Server) GetConn(connId string) defs.ISession
- func (s *Server) GetConnNum() int64
- func (s *Server) GetRemoteClient(name string) *TcpClient
- func (s *Server) Host() string
- func (s *Server) OnDisConn(conn defs.IConnection)
- func (s *Server) OnNewConn(conn defs.IConnection)
- func (s *Server) OnServiceHandle(session defs.ISession, packet defs.IPacket) bool
- func (s *Server) RangeConn(f func(string, defs.ISession) bool)
- func (s *Server) RegisterService(rcvr interface{}, cb ...defs.ParseMethodNameCallback)
- func (s *Server) SetDisConnCallback(cb defs.ConnCallback)
- func (s *Server) SetNewConnCallback(cb defs.ConnCallback)
- func (s *Server) Start()
- type ServerMgr
- func (sm *ServerMgr) AddServer(server defs.IServer)
- func (sm *ServerMgr) AllDelete()
- func (sm *ServerMgr) AllStop()
- func (sm *ServerMgr) DelServer(server defs.IServer)
- func (sm *ServerMgr) DelServerByName(name string)
- func (sm *ServerMgr) StopServer(server defs.IServer)
- func (sm *ServerMgr) StopServerByName(name string)
- type ServiceHandle
- type Session
- func (s *Session) Close() bool
- func (s *Session) CloseSession() bool
- func (s *Session) GetConn() defs.IConnection
- func (s *Session) GetConnId() string
- func (s *Session) GetContext(key interface{}) interface{}
- func (s *Session) GetPacket() defs.IPacket
- func (s *Session) GetSessionId() string
- func (s *Session) OnService(session defs.ISession, packet defs.IPacket) bool
- func (s *Session) SetContext(key, value interface{})
- func (s *Session) SetPacket(packet defs.IPacket)
- func (s *Session) WriteData(data []byte)
- func (s *Session) WriteDataAwait(data []byte) (defs.IPacket, error)
- func (s *Session) WriteDataById(id string, data []byte)
- func (s *Session) WriteDataByIdAwait(id string, data []byte) (defs.IPacket, error)
- func (s *Session) WritePacket(packet defs.IPacket)
- func (s *Session) WritePacketAwait(packet defs.IPacket) (defs.IPacket, error)
- type SessionMgr
- func (sm *SessionMgr) AddSession(s defs.ISession)
- func (sm *SessionMgr) DelConnSession(connId string) []defs.ISession
- func (sm *SessionMgr) DelSession(sessionId string) defs.ISession
- func (sm *SessionMgr) GetSession(sessionId string) defs.ISession
- func (sm *SessionMgr) RangeSession(f func(string, defs.ISession) bool)
- func (sm *SessionMgr) SessionCount() int64
- type TcpClient
- func (tcpClient *TcpClient) Cancel()
- func (tcpClient *TcpClient) Close() bool
- func (tcpClient *TcpClient) CloseConnection(conn defs.IConnection)
- func (tcpClient *TcpClient) Connect() defs.IConnection
- func (tcpClient *TcpClient) GetConn() defs.IConnection
- func (tcpClient *TcpClient) IsWorking() bool
- func (tcpClient *TcpClient) Name() string
- func (tcpClient *TcpClient) SendData(data []byte)
- func (tcpClient *TcpClient) SendDataAwait(data []byte) (defs.IPacket, error)
- func (tcpClient *TcpClient) SendDataById(id string, data []byte)
- func (tcpClient *TcpClient) SendDataByIdAwait(id string, data []byte) (defs.IPacket, error)
- func (tcpClient *TcpClient) SendPacket(packet defs.IPacket)
- func (tcpClient *TcpClient) SendPacketAwait(packet defs.IPacket) (defs.IPacket, error)
- func (tcpClient *TcpClient) SetCodec(codec defs.ICodec)
- func (tcpClient *TcpClient) SetConnCallback(cb defs.ConnCallback)
- func (tcpClient *TcpClient) SetIOModule(ioModule defs.IIOModule)
- func (tcpClient *TcpClient) SetMsgCallback(cb defs.MsgCallback)
- func (tcpClient *TcpClient) SetOneStep(val bool)
- func (tcpClient *TcpClient) SetRetry(v bool)
- func (tcpClient *TcpClient) SetTimeout(val time.Duration)
- func (tcpClient *TcpClient) Start()
- type TcpServer
- func (tcpServer *TcpServer) CloseConnection(conn defs.IConnection)
- func (tcpServer *TcpServer) Host() string
- func (tcpServer *TcpServer) Name() string
- func (tcpServer *TcpServer) Serve()
- func (tcpServer *TcpServer) SetAuthorizedCallback(cb defs.AuthorizedCallback)
- func (tcpServer *TcpServer) SetCodec(codec defs.ICodec)
- func (tcpServer *TcpServer) SetConnCallback(cb defs.ConnCallback)
- func (tcpServer *TcpServer) SetExitCallback(cb defs.ExitCallback)
- func (tcpServer *TcpServer) SetMsgCallback(cb defs.MsgCallback)
- func (tcpServer *TcpServer) SetNewIOModuleCallback(newCallback defs.NewIOModuleCallback)
- func (tcpServer *TcpServer) SetWriteCompleteCallback(cb defs.WriteCompleteCallback)
- func (tcpServer *TcpServer) Stop()
- type WSClient
- func (wsclient *WSClient) Close() bool
- func (wsclient *WSClient) CloseConnection(conn defs.IConnection)
- func (wsclient *WSClient) Connect() defs.IConnection
- func (wsclient *WSClient) Name() string
- func (wsclient *WSClient) SendData(data []byte)
- func (wsclient *WSClient) SendPacket(packet defs.IPacket)
- func (wsclient *WSClient) SetCodec(codec defs.ICodec)
- func (wsclient *WSClient) SetConnCallback(cb defs.ConnCallback)
- func (wsclient *WSClient) SetIOModule(ioModule defs.IIOModule)
- func (wsclient *WSClient) SetMsgCallback(cb defs.MsgCallback)
- func (wsclient *WSClient) SetMsgType(msgType int)
- func (wsclient *WSClient) SetRetry(v bool)
- type WSConnection
- func (wsc *WSConnection) Close() bool
- func (wsc *WSConnection) DelContext(key interface{})
- func (wsc *WSConnection) GetConn() *websocket.Conn
- func (wsc *WSConnection) GetContext(key interface{}) interface{}
- func (wsc *WSConnection) GetId() string
- func (wsc *WSConnection) GetMsgType() int
- func (wsc *WSConnection) IsClosed() bool
- func (wsc *WSConnection) LocalAddr() string
- func (wsc *WSConnection) OnConnection()
- func (wsc *WSConnection) ReadPacket(packet defs.IPacket)
- func (wsc *WSConnection) RemoteAddr() string
- func (wsc *WSConnection) SetAuthorized(val bool)
- func (wsc *WSConnection) SetAuthorizedCallback(cb defs.AuthorizedCallback)
- func (wsc *WSConnection) SetCloseCallback(cb defs.CloseCallback)
- func (wsc *WSConnection) SetCodec(codec defs.ICodec)
- func (wsc *WSConnection) SetConnCallback(cb defs.ConnCallback)
- func (wsc *WSConnection) SetContext(key, value interface{})
- func (wsc *WSConnection) SetIOModule(ioModule defs.IIOModule)
- func (wsc *WSConnection) SetMsgCallback(cb defs.MsgCallback)
- func (wsc *WSConnection) SetMsgType(msgType int)
- func (wsc *WSConnection) SetWriteCompleteCallback(cb defs.WriteCompleteCallback)
- func (wsc *WSConnection) Start() bool
- func (wsc *WSConnection) UpdateCodec(codec defs.ICodec)
- func (wsc *WSConnection) WriteComplete()
- func (wsc *WSConnection) WriteData(data []byte)
- func (wsc *WSConnection) WriteDataAwait(data []byte) (defs.IPacket, error)
- func (wsc *WSConnection) WriteDataById(id string, data []byte)
- func (wsc *WSConnection) WriteDataByIdAwait(id string, data []byte) (defs.IPacket, error)
- func (wsc *WSConnection) WritePacket(packet defs.IPacket)
- func (wsc *WSConnection) WritePacketAwait(packet defs.IPacket) (defs.IPacket, error)
- type WSServer
- func (ws *WSServer) EnablePong(val bool)
- func (ws *WSServer) Host() string
- func (ws *WSServer) Name() string
- func (ws *WSServer) Serve()
- func (ws *WSServer) ServeHTTP(w http.ResponseWriter, r *http.Request)
- func (ws *WSServer) SetAuthorizedCallback(cb defs.AuthorizedCallback)
- func (ws *WSServer) SetCodec(codec defs.ICodec)
- func (ws *WSServer) SetConnCallback(cb defs.ConnCallback)
- func (ws *WSServer) SetExitCallback(cb defs.ExitCallback)
- func (ws *WSServer) SetMsgCallback(cb defs.MsgCallback)
- func (ws *WSServer) SetMsgType(msgType int)
- func (ws *WSServer) SetNewIOModuleCallback(newCallback defs.NewIOModuleCallback)
- func (ws *WSServer) SetWriteCompleteCallback(cb defs.WriteCompleteCallback)
- func (ws *WSServer) Stop()
Constants ¶
View Source
const ReAcceptDelay = 5
Variables ¶
This section is empty.
Functions ¶
func AddSession ¶
func DelSession ¶
func DelSession(sessionId string)
func GetSession ¶
Types ¶
type Connection ¶
type Connection struct {
// contains filtered or unexported fields
}
func NewConnection ¶
func NewConnection(conn net.Conn) *Connection
func (*Connection) Close ¶
func (c *Connection) Close() bool
func (*Connection) DelContext ¶
func (c *Connection) DelContext(key interface{})
func (*Connection) GetConn ¶
func (c *Connection) GetConn() net.Conn
func (*Connection) GetContext ¶
func (c *Connection) GetContext(key interface{}) interface{}
func (*Connection) GetId ¶
func (c *Connection) GetId() string
func (*Connection) IsClosed ¶
func (c *Connection) IsClosed() bool
func (*Connection) LocalAddr ¶
func (c *Connection) LocalAddr() string
func (*Connection) OnConnection ¶
func (c *Connection) OnConnection()
func (*Connection) ReadPacket ¶
func (c *Connection) ReadPacket(packet defs.IPacket)
func (*Connection) RemoteAddr ¶
func (c *Connection) RemoteAddr() string
func (*Connection) SetAuthorizedCallback ¶
func (c *Connection) SetAuthorizedCallback(cb defs.AuthorizedCallback)
func (*Connection) SetCloseCallback ¶
func (c *Connection) SetCloseCallback(cb defs.CloseCallback)
func (*Connection) SetCodec ¶
func (c *Connection) SetCodec(codec defs.ICodec)
func (*Connection) SetConnCallback ¶
func (c *Connection) SetConnCallback(cb defs.ConnCallback)
func (*Connection) SetContext ¶
func (c *Connection) SetContext(key, value interface{})
func (*Connection) SetIOModule ¶
func (c *Connection) SetIOModule(ioModule defs.IIOModule)
func (*Connection) SetMsgCallback ¶
func (c *Connection) SetMsgCallback(cb defs.MsgCallback)
func (*Connection) SetWriteCompleteCallback ¶
func (c *Connection) SetWriteCompleteCallback(cb defs.WriteCompleteCallback)
func (*Connection) Start ¶
func (c *Connection) Start() bool
func (*Connection) UpdateCodec ¶
func (c *Connection) UpdateCodec(codec defs.ICodec)
func (*Connection) WriteComplete ¶
func (c *Connection) WriteComplete()
func (*Connection) WriteData ¶
func (c *Connection) WriteData(data []byte)
func (*Connection) WriteDataAwait ¶
func (c *Connection) WriteDataAwait(data []byte) (defs.IPacket, error)
func (*Connection) WriteDataById ¶
func (c *Connection) WriteDataById(id string, data []byte)
func (*Connection) WriteDataByIdAwait ¶
func (*Connection) WritePacket ¶
func (c *Connection) WritePacket(packet defs.IPacket)
func (*Connection) WritePacketAwait ¶
type ConnectionMgr ¶
type ConnectionMgr struct {
// contains filtered or unexported fields
}
func NewConnMgr ¶
func NewConnMgr() *ConnectionMgr
func (*ConnectionMgr) AddConn ¶
func (cm *ConnectionMgr) AddConn(conn defs.IConnection)
func (*ConnectionMgr) Clean ¶
func (cm *ConnectionMgr) Clean()
func (*ConnectionMgr) ConnCount ¶
func (cm *ConnectionMgr) ConnCount() int
func (*ConnectionMgr) DelConn ¶
func (cm *ConnectionMgr) DelConn(connId string)
func (*ConnectionMgr) GetConn ¶
func (cm *ConnectionMgr) GetConn(connId string) defs.IConnection
type Connector ¶
type Connector struct {
// contains filtered or unexported fields
}
func NewConnector ¶
func (*Connector) CancelHandle ¶
func (c *Connector) CancelHandle()
func (*Connector) SetCancelCallback ¶
func (c *Connector) SetCancelCallback(cb func())
func (*Connector) SetConnCallback ¶
func (c *Connector) SetConnCallback(cb defs.ClientConnCallback)
type Server ¶
type Server struct { *TcpServer // contains filtered or unexported fields }
func (*Server) AddRemoteClient ¶
func (s *Server) AddRemoteClient(cfg *conf.ServerConfig) *TcpClient
func (*Server) GetCfg ¶
func (s *Server) GetCfg() *conf.ServerConfig
func (*Server) GetConnNum ¶
func (*Server) GetRemoteClient ¶
func (*Server) OnDisConn ¶
func (s *Server) OnDisConn(conn defs.IConnection)
func (*Server) OnNewConn ¶
func (s *Server) OnNewConn(conn defs.IConnection)
func (*Server) OnServiceHandle ¶
func (*Server) RegisterService ¶
func (s *Server) RegisterService(rcvr interface{}, cb ...defs.ParseMethodNameCallback)
func (*Server) SetDisConnCallback ¶
func (s *Server) SetDisConnCallback(cb defs.ConnCallback)
func (*Server) SetNewConnCallback ¶
func (s *Server) SetNewConnCallback(cb defs.ConnCallback)
type ServerMgr ¶
type ServerMgr struct {
// contains filtered or unexported fields
}
func (*ServerMgr) DelServerByName ¶
func (*ServerMgr) StopServer ¶
func (*ServerMgr) StopServerByName ¶
type Session ¶
type Session struct {
// contains filtered or unexported fields
}
func NewSession ¶
func NewSession(conn defs.IConnection, sessionId string, serviceHandle ServiceHandle, async ...bool) *Session
func NewSession(conn defs.IConnection, sessionId string, serve defs.ServeObj, async ...bool) *Session {
func (*Session) CloseSession ¶
func (*Session) GetConn ¶
func (s *Session) GetConn() defs.IConnection
func (*Session) GetContext ¶
func (s *Session) GetContext(key interface{}) interface{}
func (*Session) GetSessionId ¶
func (*Session) SetContext ¶
func (s *Session) SetContext(key, value interface{})
func (*Session) WriteDataAwait ¶
func (*Session) WriteDataById ¶
func (*Session) WriteDataByIdAwait ¶
func (*Session) WritePacket ¶
type SessionMgr ¶
type SessionMgr struct {
// contains filtered or unexported fields
}
func GetSessionMgr ¶
func GetSessionMgr() *SessionMgr
func NewSessionMgr ¶
func NewSessionMgr() *SessionMgr
func (*SessionMgr) AddSession ¶
func (sm *SessionMgr) AddSession(s defs.ISession)
func (*SessionMgr) DelConnSession ¶
func (sm *SessionMgr) DelConnSession(connId string) []defs.ISession
func (*SessionMgr) DelSession ¶
func (sm *SessionMgr) DelSession(sessionId string) defs.ISession
func (*SessionMgr) GetSession ¶
func (sm *SessionMgr) GetSession(sessionId string) defs.ISession
func (*SessionMgr) RangeSession ¶
func (sm *SessionMgr) RangeSession(f func(string, defs.ISession) bool)
func (*SessionMgr) SessionCount ¶
func (sm *SessionMgr) SessionCount() int64
type TcpClient ¶
type TcpClient struct {
// contains filtered or unexported fields
}
func NewTcpClient ¶
func (*TcpClient) CloseConnection ¶
func (tcpClient *TcpClient) CloseConnection(conn defs.IConnection)
func (*TcpClient) Connect ¶
func (tcpClient *TcpClient) Connect() defs.IConnection
func (*TcpClient) GetConn ¶
func (tcpClient *TcpClient) GetConn() defs.IConnection
func (*TcpClient) SendDataAwait ¶
func (*TcpClient) SendDataById ¶
func (*TcpClient) SendDataByIdAwait ¶
func (*TcpClient) SendPacket ¶
func (*TcpClient) SendPacketAwait ¶
func (*TcpClient) SetConnCallback ¶
func (tcpClient *TcpClient) SetConnCallback(cb defs.ConnCallback)
func (*TcpClient) SetIOModule ¶
func (*TcpClient) SetMsgCallback ¶
func (tcpClient *TcpClient) SetMsgCallback(cb defs.MsgCallback)
func (*TcpClient) SetOneStep ¶
func (*TcpClient) SetTimeout ¶
type TcpServer ¶
type TcpServer struct {
// contains filtered or unexported fields
}
func NewTcpServer ¶
func (*TcpServer) CloseConnection ¶
func (tcpServer *TcpServer) CloseConnection(conn defs.IConnection)
func (*TcpServer) SetAuthorizedCallback ¶
func (tcpServer *TcpServer) SetAuthorizedCallback(cb defs.AuthorizedCallback)
func (*TcpServer) SetConnCallback ¶
func (tcpServer *TcpServer) SetConnCallback(cb defs.ConnCallback)
func (*TcpServer) SetExitCallback ¶
func (tcpServer *TcpServer) SetExitCallback(cb defs.ExitCallback)
func (*TcpServer) SetMsgCallback ¶
func (tcpServer *TcpServer) SetMsgCallback(cb defs.MsgCallback)
func (*TcpServer) SetNewIOModuleCallback ¶
func (tcpServer *TcpServer) SetNewIOModuleCallback(newCallback defs.NewIOModuleCallback)
func (*TcpServer) SetWriteCompleteCallback ¶
func (tcpServer *TcpServer) SetWriteCompleteCallback(cb defs.WriteCompleteCallback)
type WSClient ¶
type WSClient struct {
// contains filtered or unexported fields
}
func NewWSClient ¶
func (*WSClient) CloseConnection ¶
func (wsclient *WSClient) CloseConnection(conn defs.IConnection)
func (*WSClient) Connect ¶
func (wsclient *WSClient) Connect() defs.IConnection
func (*WSClient) SendPacket ¶
func (*WSClient) SetConnCallback ¶
func (wsclient *WSClient) SetConnCallback(cb defs.ConnCallback)
func (*WSClient) SetIOModule ¶
func (*WSClient) SetMsgCallback ¶
func (wsclient *WSClient) SetMsgCallback(cb defs.MsgCallback)
func (*WSClient) SetMsgType ¶
type WSConnection ¶
type WSConnection struct {
// contains filtered or unexported fields
}
func NewWSConnection ¶
func NewWSConnection(conn *websocket.Conn) *WSConnection
func (*WSConnection) Close ¶
func (wsc *WSConnection) Close() bool
func (*WSConnection) DelContext ¶
func (wsc *WSConnection) DelContext(key interface{})
func (*WSConnection) GetConn ¶
func (wsc *WSConnection) GetConn() *websocket.Conn
func (*WSConnection) GetContext ¶
func (wsc *WSConnection) GetContext(key interface{}) interface{}
func (*WSConnection) GetId ¶
func (wsc *WSConnection) GetId() string
func (*WSConnection) GetMsgType ¶
func (wsc *WSConnection) GetMsgType() int
func (*WSConnection) IsClosed ¶
func (wsc *WSConnection) IsClosed() bool
func (*WSConnection) LocalAddr ¶
func (wsc *WSConnection) LocalAddr() string
func (*WSConnection) OnConnection ¶
func (wsc *WSConnection) OnConnection()
func (*WSConnection) ReadPacket ¶
func (wsc *WSConnection) ReadPacket(packet defs.IPacket)
func (*WSConnection) RemoteAddr ¶
func (wsc *WSConnection) RemoteAddr() string
func (*WSConnection) SetAuthorized ¶
func (wsc *WSConnection) SetAuthorized(val bool)
func (*WSConnection) SetAuthorizedCallback ¶
func (wsc *WSConnection) SetAuthorizedCallback(cb defs.AuthorizedCallback)
func (*WSConnection) SetCloseCallback ¶
func (wsc *WSConnection) SetCloseCallback(cb defs.CloseCallback)
func (*WSConnection) SetCodec ¶
func (wsc *WSConnection) SetCodec(codec defs.ICodec)
func (*WSConnection) SetConnCallback ¶
func (wsc *WSConnection) SetConnCallback(cb defs.ConnCallback)
func (*WSConnection) SetContext ¶
func (wsc *WSConnection) SetContext(key, value interface{})
func (*WSConnection) SetIOModule ¶
func (wsc *WSConnection) SetIOModule(ioModule defs.IIOModule)
func (*WSConnection) SetMsgCallback ¶
func (wsc *WSConnection) SetMsgCallback(cb defs.MsgCallback)
func (*WSConnection) SetMsgType ¶
func (wsc *WSConnection) SetMsgType(msgType int)
func (*WSConnection) SetWriteCompleteCallback ¶
func (wsc *WSConnection) SetWriteCompleteCallback(cb defs.WriteCompleteCallback)
func (*WSConnection) Start ¶
func (wsc *WSConnection) Start() bool
func (*WSConnection) UpdateCodec ¶
func (wsc *WSConnection) UpdateCodec(codec defs.ICodec)
func (*WSConnection) WriteComplete ¶
func (wsc *WSConnection) WriteComplete()
func (*WSConnection) WriteData ¶
func (wsc *WSConnection) WriteData(data []byte)
func (*WSConnection) WriteDataAwait ¶
func (wsc *WSConnection) WriteDataAwait(data []byte) (defs.IPacket, error)
func (*WSConnection) WriteDataById ¶
func (wsc *WSConnection) WriteDataById(id string, data []byte)
func (*WSConnection) WriteDataByIdAwait ¶
func (*WSConnection) WritePacket ¶
func (wsc *WSConnection) WritePacket(packet defs.IPacket)
func (*WSConnection) WritePacketAwait ¶
type WSServer ¶
type WSServer struct {
// contains filtered or unexported fields
}
func (*WSServer) EnablePong ¶
func (*WSServer) SetAuthorizedCallback ¶
func (ws *WSServer) SetAuthorizedCallback(cb defs.AuthorizedCallback)
func (*WSServer) SetConnCallback ¶
func (ws *WSServer) SetConnCallback(cb defs.ConnCallback)
func (*WSServer) SetExitCallback ¶
func (ws *WSServer) SetExitCallback(cb defs.ExitCallback)
func (*WSServer) SetMsgCallback ¶
func (ws *WSServer) SetMsgCallback(cb defs.MsgCallback)
func (*WSServer) SetMsgType ¶
func (*WSServer) SetNewIOModuleCallback ¶
func (ws *WSServer) SetNewIOModuleCallback(newCallback defs.NewIOModuleCallback)
func (*WSServer) SetWriteCompleteCallback ¶
func (ws *WSServer) SetWriteCompleteCallback(cb defs.WriteCompleteCallback)
Click to show internal directories.
Click to hide internal directories.