hj212

Aug 30, 2024

Changes in this version

type Session

+ func (session *Session) DataReply(message protocol.Message) error

Mar 12, 2023

Changes in this version

+ var BuffPool *buffPool

type Option

+ Protocol link.Protocol

Mar 10, 2023

Changes in this version

+ type MessageHandler func(session *Session, message *protocol.Message)

+ type Option struct

+ CloseHandler func(session *Session)

+ Keepalive int

+ ListenAddress string

+ SendChanSize int

+ type Protocol struct

+ func (protocol *Protocol) NewCodec(rw io.ReadWriter) (link.Codec, error)

+ type ProtocolCodec struct

+ func (codec *ProtocolCodec) Close() error

+ func (codec *ProtocolCodec) Receive() (interface{}, error)

+ func (codec *ProtocolCodec) Send(msg interface{}) error

+ type Server struct

+ func NewServer(option Option) *Server

+ func (server *Server) AddHandler(st, cn uint16, handler MessageHandler)

+ func (server *Server) GetSession(sessionID uint64) (*Session, bool)

+ func (server *Server) RemoveHandler(st, cn uint16)

+ func (server *Server) Run() error

+ func (server *Server) SessionCount() uint64

+ func (server *Server) Stop()

+ type Session struct

+ func (session *Session) ID() uint64

+ func (session *Session) Send(entity protocol.Entity) error