easysocket

Oct 19, 2022

Changes in this version

type IMessageHandler

+ AddPreRouter func(handle PreRouterHandle)

type IServer

+ AddPreRouter func(handle PreRouterHandle)

type MessageHandler

+ func (m *MessageHandler) AddPreRouter(handle PreRouterHandle)

+ type PreRouterHandle func(request IRequest, message proto.Message) bool

type Server

+ func (s *Server) AddPreRouter(handle PreRouterHandle)

Oct 8, 2022

Changes in this version

type ISession

+ RemoteIP func() string

type TCPSession

+ func (s *TCPSession) RemoteIP() string

type WsSession

+ func (s *WsSession) RemoteIP() string

Sep 27, 2022

Changes in this version

+ var DP = DataPack

type IRequest

+ SetMsg func(msgId int32, data []byte)

type IServer

+ SendBufferMsg func(request IRequest)

+ SendMsg func(msgId int32, message proto.Message)

type Request

+ func (r *Request) SetMsg(msgId int32, data []byte)

type Server

+ func (s *Server) SendBufferMsg(request IRequest)

+ func (s *Server) SendMsg(msgId int32, message proto.Message)

Sep 26, 2022

Changes in this version

+ type GateHandler func(request IRequest)

type IMessageHandler

+ SetGateHandler func(handler GateHandler)

type IServer

+ SetGateHandler func(handler GateHandler)

type MessageHandler

+ func (m *MessageHandler) SetGateHandler(handler GateHandler)

type Server

+ func (s *Server) SetGateHandler(handler GateHandler)

Apr 8, 2022

Changes in this version

type IRequest

+ SendMsg func(msgId int32, message proto.Message) error

type Request

+ func (r *Request) SendMsg(msgId int32, message proto.Message) error

Apr 8, 2022

Changes in this version

type MessageHandler

+ func (m *MessageHandler) ReflectProto(request IRequest) proto.Message

+ type Option func(options *Options)

+ func CertFile(v string) Option

+ func KeyFile(v string) Option

+ type Options struct

Apr 7, 2022

Changes in this version

+ const MsgLenSize

+ const MsgTypeSize

+ type BaseRouter struct

+ func (r *BaseRouter) Handle(request IRequest)

+ func (r *BaseRouter) PostHandle(request IRequest)

+ func (r *BaseRouter) PreHandle(request IRequest)

+ type DataPack struct

+ func (dp *DataPack) GetHeadLen() uint32

+ func (dp *DataPack) Pack(message IMessage) []byte

+ func (dp *DataPack) UnPack(data []byte) IMessage

+ type EventType int

+ type HookFunc func(session ISession)

+ type IDataPack interface

+ GetHeadLen func() uint32

+ Pack func(message IMessage) []byte

+ UnPack func(data []byte) IMessage

+ func NewDataPack() IDataPack

+ type IMessage interface

+ GetData func() []byte

+ GetDataLen func() uint32

+ GetMsgId func() int32

+ SetData func(data []byte)

+ SetDataLen func(len uint32)

+ SetMsgId func(msgType int32)

+ type IMessageHandler interface

+ AddRouter func(msgId int32, router IRouter)

+ DoMsgHandler func(request IRequest)

+ SendMsgToTaskQueue func(request IRequest)

+ StartWorkerPool func()

+ type IRequest interface

+ GetData func() []byte

+ GetMsgId func() int32

+ GetSession func() ISession

+ type IRouter interface

+ Handle func(request IRequest)

+ PostHandle func(request IRequest)

+ PreHandle func(request IRequest)

+ type IServer interface

+ AddRouter func(msgId int32, router IRouter)

+ CallOnConnStart func(session ISession)

+ CallOnConnStop func(session ISession)

+ DataPack func() IDataPack

+ GetSessMgr func() ISessionManager

+ Serve func()

+ SetOnConnStart func(hookFunc HookFunc)

+ SetOnConnStop func(hookFunc HookFunc)

+ Stop func()

+ type ISession interface

+ Context func() context.Context

+ GetConnId func() uint32

+ GetProperty func(key string) (interface{}, error)

+ RemoteAddr func() net.Addr

+ RemoveProperty func(key string)

+ SendBuffMsg func(msgId int32, data []byte) error

+ SendMsg func(msgId int32, data []byte) error

+ SetProperty func(key string, value interface{}) error

+ Start func()

+ Stop func()

+ type ISessionManager interface

+ Add func(session ISession)

+ Clear func()

+ Count func() int

+ Get func(connId uint32) (ISession, error)

+ Remove func(session ISession)

+ type Message struct

+ func NewMessage(id int32, data []byte) *Message

+ func (m *Message) GetData() []byte

+ func (m *Message) GetDataLen() uint32

+ func (m *Message) GetMsgId() int32

+ func (m *Message) SetData(data []byte)

+ func (m *Message) SetDataLen(len uint32)

+ func (m *Message) SetMsgId(id int32)

+ type MessageHandler struct

+ func NewMessageHandler() *MessageHandler

+ func (m *MessageHandler) AddRouter(msgId int32, router IRouter)

+ func (m *MessageHandler) DoMsgHandler(request IRequest)

+ func (m *MessageHandler) SendMsgToTaskQueue(request IRequest)

+ func (m *MessageHandler) StartWorkerPool()

+ type Request struct

+ func (r *Request) GetData() []byte

+ func (r *Request) GetMsgId() int32

+ func (r *Request) GetSession() ISession

+ type Server struct

+ OnConnStart HookFunc

+ OnConnStop HookFunc

+ ServerType ServerType

+ func NewServer(name string, serverType ServerType, host string, port int) *Server

+ func (s *Server) AddRouter(msgId int32, router IRouter)

+ func (s *Server) CallOnConnStart(session ISession)

+ func (s *Server) CallOnConnStop(session ISession)

+ func (s *Server) DataPack() IDataPack

+ func (s *Server) GetSessMgr() ISessionManager

+ func (s *Server) Serve()

+ func (s *Server) SetOnConnStart(hookFunc HookFunc)

+ func (s *Server) SetOnConnStop(hookFunc HookFunc)

+ func (s *Server) Stop()

+ type ServerType uint32

+ const NullServer

+ const TcpClient

+ const TcpServer

+ const WsServer

+ type Session struct

+ func (s *Session) Context() context.Context

+ func (s *Session) GetConnId() uint32

+ func (s *Session) GetProperty(key string) (interface{}, error)

+ func (s *Session) RemoveProperty(key string)

+ func (s *Session) SendBuffMsg(msgId int32, data []byte) error

+ func (s *Session) SetProperty(key string, value interface{}) error

+ func (s *Session) Stop()

+ type SessionManager struct

+ func NewSessionManager() *SessionManager

+ func (m *SessionManager) Add(session ISession)

+ func (m *SessionManager) Clear()

+ func (m *SessionManager) Count() int

+ func (m *SessionManager) Get(connId uint32) (ISession, error)

+ func (m *SessionManager) Remove(session ISession)

+ type TCPSession struct

+ func NewTCPSession(server IServer, conn net.Conn, connId uint32, handler IMessageHandler) *TCPSession

+ func (s *TCPSession) GetConn() net.Conn

+ func (s *TCPSession) RemoteAddr() net.Addr

+ func (s *TCPSession) SendMsg(msgId int32, data []byte) error

+ func (s *TCPSession) Start()

+ type WsSession struct

+ func NewWsSession(server IServer, conn *websocket.Conn, connId uint32, handler IMessageHandler) *WsSession

+ func (s *WsSession) RemoteAddr() net.Addr

+ func (s *WsSession) SendMsg(msgId int32, data []byte) error

+ func (s *WsSession) Start()