datapack

Documentation

Index

• Constants
• type Message
• type PbMessage
  • func NewPbMessage() *PbMessage
  • func NewPbMessageHeader() *PbMessage
  • func NewPbMessageWithEndpoint(src, dest pb.Endpoint) *PbMessage
  • func (m *PbMessage) DeserializeHeader(b []byte)
  • func (m *PbMessage) GetHeader() *pb.Header
  • func (m *PbMessage) GetOriginal() []byte
  • func (m *PbMessage) GetPayload() []byte
  • func (m *PbMessage) SerializeFlag() uint8
  • func (m *PbMessage) SerializeHeader() []byte
  • func (m *PbMessage) SerializePayload() []byte
• type TcpPackage
  • func (pkg *TcpPackage) GetMessage() Message
  • func (pkg *TcpPackage) MsgLen() uint64
  • func (pkg *TcpPackage) Pack(data Message) []byte
  • func (pkg *TcpPackage) UnPackFrameData(data []byte)
  • func (pkg *TcpPackage) UnPackFrameHeader(data []byte) error

Constants

const (
	FIXED_HEADER_LEN = 15 //fixed header len

)

Types

type Message

type Message interface {
	SerializeFlag() uint8
	SerializeHeader() []byte
	SerializePayload() []byte

	DeserializeHeader([]byte)

	GetOriginal() []byte
	GetHeader() *pb.Header
	GetPayload() []byte
}

Message 消息数据

type PbMessage

type PbMessage struct {
	Original      []byte
	PayloadOffset uint32

	HeaderPb  *pb.Header
	PayloadPb proto.Message
}

func NewPbMessage

func NewPbMessage() *PbMessage

func NewPbMessageHeader

func NewPbMessageHeader() *PbMessage

func NewPbMessageWithEndpoint

func NewPbMessageWithEndpoint(src, dest pb.Endpoint) *PbMessage

func (*PbMessage) DeserializeHeader

func (m *PbMessage) DeserializeHeader(b []byte)

func (*PbMessage) GetHeader

func (m *PbMessage) GetHeader() *pb.Header

func (*PbMessage) GetOriginal

func (m *PbMessage) GetOriginal() []byte

func (*PbMessage) GetPayload

func (m *PbMessage) GetPayload() []byte

func (*PbMessage) SerializeFlag

func (m *PbMessage) SerializeFlag() uint8

func (*PbMessage) SerializeHeader

func (m *PbMessage) SerializeHeader() []byte

func (*PbMessage) SerializePayload

func (m *PbMessage) SerializePayload() []byte

type TcpPackage

type TcpPackage struct {
	// contains filtered or unexported fields
}

TcpPackage tcp data

|mg|flag|header len|pkg len|var header|payload| |2byte|1byte|4byte|8byte|var|var|

flag |预留|序列化类型 |4bit|4bit

func (*TcpPackage) GetMessage

func (pkg *TcpPackage) GetMessage() Message

GetMessage TcpPackage --> Message

func (*TcpPackage) MsgLen

func (pkg *TcpPackage) MsgLen() uint64

func (*TcpPackage) Pack

func (pkg *TcpPackage) Pack(data Message) []byte

func (*TcpPackage) UnPackFrameData

func (pkg *TcpPackage) UnPackFrameData(data []byte)

func (*TcpPackage) UnPackFrameHeader

func (pkg *TcpPackage) UnPackFrameHeader(data []byte) error