Versions in this module Expand all Collapse all v0 v0.2.0-alpha.0 Jun 12, 2023 v0.1.0 Feb 6, 2023 Changes in this version + const MaxBodySize + var ErrProtoHeaderLen = errors.New("default server codec header length error") + var ErrProtoPackLen = errors.New("default server codec pack length error") + var File_protocol_protocol_proto protoreflect.FileDescriptor + var Op_name = map[int32]string + var Op_value = map[string]int32 + var ProtoFinish = &Proto + var ProtoReady = &Proto + type Op int32 + const Op_Auth + const Op_AuthReply + const Op_Disconnect + const Op_DisconnectReply + const Op_Heartbeat + const Op_HeartbeatReply + const Op_ProtoFinish + const Op_ProtoReady + const Op_Raw + const Op_RePush + const Op_ReceiveMsg + const Op_ReceiveMsgReply + const Op_SendMsg + const Op_SendMsgReply + const Op_SyncMsgReply + const Op_SyncMsgReq + const Op_Undefined + func (Op) Descriptor() protoreflect.EnumDescriptor + func (Op) EnumDescriptor() ([]byte, []int) + func (Op) Type() protoreflect.EnumType + func (x Op) Enum() *Op + func (x Op) Number() protoreflect.EnumNumber + func (x Op) String() string + type Proto struct + Ack int32 + Body []byte + Op int32 + Seq int32 + Ver int32 + func (*Proto) Descriptor() ([]byte, []int) + func (*Proto) ProtoMessage() + func (p *Proto) ReadTCP(rr *bufio.Reader) (err error) + func (p *Proto) ReadWebsocket(ws *websocket.Conn) (err error) + func (p *Proto) ReadWebsocket2(ws *gws.Conn) (err error) + func (p *Proto) WriteTCP(wr *bufio.Writer) (err error) + func (p *Proto) WriteTCPHeart(wr *bufio.Writer, online int32) (err error) + func (p *Proto) WriteTo(b *bytes.Writer) + func (p *Proto) WriteWebsocket(ws *websocket.Conn) (err error) + func (p *Proto) WriteWebsocket2(ws *gws.Conn) (err error) + func (p *Proto) WriteWebsocketHeart(wr *websocket.Conn, online int32) (err error) + func (x *Proto) GetAck() int32 + func (x *Proto) GetBody() []byte + func (x *Proto) GetOp() int32 + func (x *Proto) GetSeq() int32 + func (x *Proto) GetVer() int32 + func (x *Proto) ProtoReflect() protoreflect.Message + func (x *Proto) Reset() + func (x *Proto) String() string
Go to main page