message

Documentation

Index

• func Marshal(m IMessage) ([]byte, error)
• func Unmarshal(b []byte, m IMessage) error
• type IMessage
• type Message
  • func NewMessage(routeType Type, messageType Type, verion uint32, seqID uint32, msgID uint16, ...) (this *Message)
  • func NewMessageDirect(routeType Type, messageType Type, verion uint32, seqID uint32, msgID uint16, ...) (this *Message)
  • func NewMessageWith(data []byte) (this *Message)
  • func (msg *Message) Decode(e interface{}) (valid bool)
  • func (msg *Message) Encode() (ret interface{})
  • func (msg *Message) GetMsgData() []byte
  • func (msg *Message) GetMsgID() uint16
  • func (msg *Message) GetSecurityType() int8
  • func (msg *Message) GetSeqID() uint32
  • func (msg *Message) GetSerializeType() int8
  • func (msg *Message) String() string
• type MessageFactory
  • func NewMessageFactory() (this *MessageFactory)
  • func (factory *MessageFactory) GetProtocol(buf []byte) (valid bool, ret protocol.Protocol)
• type Type

Functions

func Marshal

func Marshal(m IMessage) ([]byte, error)

func Unmarshal

func Unmarshal(b []byte, m IMessage) error

Types

type IMessage

type IMessage interface {
	Decode(b []byte) error

	Encode() ([]byte, error)
}

type Message

type Message struct {
	RouteType   Type   // 路由类型: 0-close,1-client,2-hall
	MessageType Type   // 协议类型: 1-proto,2-json
	Verion      uint32 // 协议版本
	SeqID       uint32 // 消息唯一ID,从0开始递增
	Time        int64  // 时间戳
	MsgID       uint16 // 协议ID
	Data        []byte // 协议数据
	ProtoData   protoiface.MessageV1
}

Message represents a unmarshaled message or a message which to be marshaled

func NewMessage

func NewMessage(routeType Type, messageType Type,
	verion uint32, seqID uint32, msgID uint16,
	protoData protoreflect.ProtoMessage) (this *Message)

func NewMessageDirect

func NewMessageDirect(routeType Type, messageType Type,
	verion uint32, seqID uint32, msgID uint16,
	protoData []byte) (this *Message)

func NewMessageWith

func NewMessageWith(data []byte) (this *Message)

func (*Message) Decode

func (msg *Message) Decode(e interface{}) (valid bool)

func (*Message) Encode

func (msg *Message) Encode() (ret interface{})

func (*Message) GetMsgData

func (msg *Message) GetMsgData() []byte

func (*Message) GetMsgID

func (msg *Message) GetMsgID() uint16

func (*Message) GetSecurityType

func (msg *Message) GetSecurityType() int8

func (*Message) GetSeqID

func (msg *Message) GetSeqID() uint32

func (*Message) GetSerializeType

func (msg *Message) GetSerializeType() int8

func (*Message) String

func (msg *Message) String() string

type MessageFactory

type MessageFactory struct {
}

func NewMessageFactory

func NewMessageFactory() (this *MessageFactory)

func (*MessageFactory) GetProtocol

func (factory *MessageFactory) GetProtocol(buf []byte) (valid bool, ret protocol.Protocol)

type Type

type Type byte