protocol

package
v0.2.0-alpha.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 12, 2023 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// MaxBodySize max proto body size
	MaxBodySize = int32(1 << 14)
)

Variables

View Source 
var (
	// ErrProtoPackLen proto packet len error
	ErrProtoPackLen = errors.New("default server codec pack length error")
	// ErrProtoHeaderLen proto header len error
	ErrProtoHeaderLen = errors.New("default server codec header length error")
)
View Source 
var (
	// ProtoReady proto ready
	ProtoReady = &Proto{Op: int32(Op_ProtoReady)}
	// ProtoFinish proto finish
	ProtoFinish = &Proto{Op: int32(Op_ProtoFinish)}
	// ProtoResend proto resend
	ProtoResend = &Proto{Op: int32(Op_ProtoResend)}
)
View Source 
var (
	Op_name = map[int32]string{
		0:  "Undefined",
		1:  "Auth",
		2:  "AuthReply",
		3:  "Heartbeat",
		4:  "HeartbeatReply",
		5:  "Disconnect",
		6:  "DisconnectReply",
		7:  "Message",
		8:  "MessageReply",
		20: "ProtoReady",
		21: "ProtoFinish",
		22: "ProtoResend",
		23: "Raw",
	}
	Op_value = map[string]int32{
		"Undefined":       0,
		"Auth":            1,
		"AuthReply":       2,
		"Heartbeat":       3,
		"HeartbeatReply":  4,
		"Disconnect":      5,
		"DisconnectReply": 6,
		"Message":         7,
		"MessageReply":    8,
		"ProtoReady":      20,
		"ProtoFinish":     21,
		"ProtoResend":     22,
		"Raw":             23,
	}
)

Enum value maps for Op.

View Source 
var File_protocol_protocol_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AuthBody 

type AuthBody struct {
	AppId string `protobuf:"bytes,1,opt,name=appId,proto3" json:"appId,omitempty"`
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	Ext   []byte `protobuf:"bytes,3,opt,name=ext,proto3" json:"ext,omitempty"` // 其它业务方可能需要的信息
	// contains filtered or unexported fields
}

Proto 中 Op 为 OpAuth 时， body 必须可以反序列化为 AuthMsg

func (*AuthBody) Descriptor deprecated 

func (*AuthBody) Descriptor() ([]byte, []int)

Deprecated: Use AuthBody.ProtoReflect.Descriptor instead.

func (*AuthBody) GetAppId 

func (x *AuthBody) GetAppId() string

func (*AuthBody) GetExt 

func (x *AuthBody) GetExt() []byte

func (*AuthBody) GetToken 

func (x *AuthBody) GetToken() string

func (*AuthBody) ProtoMessage 

func (*AuthBody) ProtoMessage()

func (*AuthBody) ProtoReflect 

func (x *AuthBody) ProtoReflect() protoreflect.Message

func (*AuthBody) Reset 

func (x *AuthBody) Reset()

func (*AuthBody) String 

func (x *AuthBody) String() string

type Op 

type Op int32
const (
	Op_Undefined       Op = 0
	Op_Auth            Op = 1
	Op_AuthReply       Op = 2
	Op_Heartbeat       Op = 3
	Op_HeartbeatReply  Op = 4
	Op_Disconnect      Op = 5
	Op_DisconnectReply Op = 6
	Op_Message         Op = 7
	Op_MessageReply    Op = 8
	Op_ProtoReady      Op = 20
	Op_ProtoFinish     Op = 21
	Op_ProtoResend     Op = 22
	Op_Raw             Op = 23
)

func (Op) Descriptor 

func (Op) Descriptor() protoreflect.EnumDescriptor

func (Op) Enum 

func (x Op) Enum() *Op

func (Op) EnumDescriptor deprecated 

func (Op) EnumDescriptor() ([]byte, []int)

Deprecated: Use Op.Descriptor instead.

func (Op) Number 

func (x Op) Number() protoreflect.EnumNumber

func (Op) String 

func (x Op) String() string

func (Op) Type 

func (Op) Type() protoreflect.EnumType

type Proto 

type Proto struct {
	Ver  int32  `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	Op   int32  `protobuf:"varint,2,opt,name=op,proto3" json:"op,omitempty"`
	Seq  int32  `protobuf:"varint,3,opt,name=seq,proto3" json:"seq,omitempty"`
	Ack  int32  `protobuf:"varint,4,opt,name=ack,proto3" json:"ack,omitempty"`
	Body []byte `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*Proto) Descriptor deprecated 

func (*Proto) Descriptor() ([]byte, []int)

Deprecated: Use Proto.ProtoReflect.Descriptor instead.

func (*Proto) GetAck 

func (x *Proto) GetAck() int32

func (*Proto) GetBody 

func (x *Proto) GetBody() []byte

func (*Proto) GetOp 

func (x *Proto) GetOp() int32

func (*Proto) GetSeq 

func (x *Proto) GetSeq() int32

func (*Proto) GetVer 

func (x *Proto) GetVer() int32

func (*Proto) ProtoMessage 

func (*Proto) ProtoMessage()

func (*Proto) ProtoReflect 

func (x *Proto) ProtoReflect() protoreflect.Message

func (*Proto) ReadTCP 

func (p *Proto) ReadTCP(rr *bufio.Reader) (err error)

ReadTCP read a proto from TCP reader.

func (*Proto) ReadWebsocket 

func (p *Proto) ReadWebsocket(ws *websocket.Conn) (err error)

ReadWebsocket read a proto from websocket connection.

func (*Proto) ReadWebsocket2 

func (p *Proto) ReadWebsocket2(ws *gws.Conn) (err error)

ReadWebsocket read a proto from websocket connection.

func (*Proto) Reset 

func (x *Proto) Reset()

func (*Proto) String 

func (x *Proto) String() string

func (*Proto) WriteTCP 

func (p *Proto) WriteTCP(wr *bufio.Writer) (err error)

WriteTCP write a proto to TCP writer.

func (*Proto) WriteTCPHeart 

func (p *Proto) WriteTCPHeart(wr *bufio.Writer, online int32) (err error)

WriteTCPHeart write TCP heartbeat with room online.

func (*Proto) WriteTo 

func (p *Proto) WriteTo(b *bytes.Writer)

WriteTo write a proto to bytes writer.

func (*Proto) WriteWebsocket 

func (p *Proto) WriteWebsocket(ws *websocket.Conn) (err error)

WriteWebsocket write a proto to websocket connection.

func (*Proto) WriteWebsocket2 

func (p *Proto) WriteWebsocket2(ws *gws.Conn) (err error)

WriteWebsocket write a proto to websocket connection.

func (*Proto) WriteWebsocketHeart 

func (p *Proto) WriteWebsocketHeart(wr *websocket.Conn, online int32) (err error)

WriteWebsocketHeart write websocket heartbeat with room online.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.