tdmsg

Documentation

Index

• Constants
• type DataItem
• type TubeMQTDMsg
  • func New(data []byte) (*TubeMQTDMsg, error)
  • func (m *TubeMQTDMsg) ParseAttrValue(attr string) (map[string]string, error)

Constants

const (
	TubeMQTDMsgV4MsgFormatSize     = 29
	TubeMQTDMsgV4MsgCountOffset    = 15
	TubeMQTDMsgV4MsgExtFieldOffset = 9
)

Types

type DataItem

type DataItem struct {
	Length uint32
	Data   []byte
}

DataItem represents the parsed data.

type TubeMQTDMsg

type TubeMQTDMsg struct {
	IsNumBid   bool
	Version    int32
	CreateTime uint64
	MsgCount   uint32
	AttrCount  uint32
	Attr2Data  map[string][]*DataItem
}

TubeMQTDMsg represents the structure of td msg.

func New

func New(data []byte) (*TubeMQTDMsg, error)

New decodes a TubeMQTDMsg from the given bytes.

func (*TubeMQTDMsg) ParseAttrValue

func (m *TubeMQTDMsg) ParseAttrValue(attr string) (map[string]string, error)

ParseAttrValue parses the given attrs to a map of attr to value.