Versions in this module Expand all Collapse all v0 v0.1.1 May 25, 2022 Changes in this version + func NewSession(conn *kcp.UDPSession, sid uint32) face.ISession + func NewTestStruct() face.ITest + func ServerStartWork() + type Request struct + func NewRequest(message []byte, session face.ISession) Request + func (request *Request) GetMessage() []byte + func (request *Request) GetSession() face.ISession + type Server struct + IP string + UDPIP string + func (server *Server) AddSession(conn *kcp.UDPSession) + func (server *Server) GetSession(sid uint32) face.ISession + func (server *Server) Init() + func (server *Server) ListenKCP() + func (server *Server) ListenUDP() + func (server *Server) PrintLogo() + func (server *Server) RemoveSession(sid uint32) + func (server *Server) Serve() + func (server *Server) Start() + func (server *Server) Stop() + type Session struct + func (session *Session) ChangeRoomId(roomId uint32) + func (session *Session) CheckAlive() + func (session *Session) GetConnection() net.Conn + func (session *Session) GetCurrentRoomId() uint32 + func (session *Session) GetRemoteAddress() string + func (session *Session) GetSid() uint32 + func (session *Session) SendMessage(data []byte) + func (session *Session) Start() + func (session *Session) StartReader() + func (session *Session) StartWriter() + func (session *Session) Stop() + type TestStruct struct + func (test *TestStruct) Print() + func (test *TestStruct) Test() + type WorkerPool struct + TaskQueue []chan Request + WorkerPoolSize uint32 + func (workerPool *WorkerPool) AddToTaskQueue(request Request) + func (workerPool *WorkerPool) DoMessageHandler(request Request) + func (workerPool *WorkerPool) Init() + func (workerPool *WorkerPool) ResponseLogin(sid uint32) + func (workerPool *WorkerPool) ResponseTest(session face.ISession) + func (workerPool *WorkerPool) StartOneWorker(workerID int, taskQueue chan Request) + func (workerPool *WorkerPool) StartWorkerPool()
Go to main page