ws_handlereq

Documentation

Index

• Constants
• Variables
• type ServeClientConn
  • func NewServeClientConn(remoteAddr string) *ServeClientConn
  • func (c2sc *ServeClientConn) HandleRecvPacket(header ws_packet.Header, rbody []byte) error
  • func (c2sc *ServeClientConn) StartServeClientConn(mainctx context.Context, wsConn *websocket.Conn)
  • func (c2sc *ServeClientConn) String() string

Constants

const (
	SendBufferSize = 10

	PacketReadTimeoutSec  = 6 * time.Second
	PacketWriteTimeoutSec = 3 * time.Second
)

service const

Variables

var DemuxReq2BytesAPIFnMap = [...]func(
	me interface{}, hd ws_packet.Header, rbody []byte) (
	ws_packet.Header, interface{}, error){
	ws_idcmd.InvalidCmd: bytesAPIFn_ReqInvalidCmd,
	ws_idcmd.Login:      bytesAPIFn_ReqLogin,
	ws_idcmd.Heartbeat:  bytesAPIFn_ReqHeartbeat,
	ws_idcmd.Chat:       bytesAPIFn_ReqChat,

} // DemuxReq2BytesAPIFnMap

Types

type ServeClientConn

type ServeClientConn struct {
	RemoteAddr string
	// contains filtered or unexported fields
}

func NewServeClientConn

func NewServeClientConn(remoteAddr string) *ServeClientConn

func (*ServeClientConn) HandleRecvPacket

func (c2sc *ServeClientConn) HandleRecvPacket(header ws_packet.Header, rbody []byte) error

func (*ServeClientConn) StartServeClientConn

func (c2sc *ServeClientConn) StartServeClientConn(mainctx context.Context, wsConn *websocket.Conn)

func (*ServeClientConn) String

func (c2sc *ServeClientConn) String() string