Versions in this module Expand all Collapse all v2 v2.0.2 Jul 7, 2019 v2.0.0 Jul 7, 2019 Changes in this version + const BodySizePosition + const Compress + const FlagPostion + const KeySep + const MagicCode + const MagicCodePostion + const MultiTags + const NameValueSep + const PhysicOffsetPostion + const PropertyBuyerID + const PropertyConsumeStartTimestamp + const PropertyCorrectionFlag + const PropertyDelayTimeLevel + const PropertyKeys + const PropertyMQ2Flag + const PropertyMaxOffset + const PropertyMaxReconsumeTimes + const PropertyMinOffset + const PropertyMsgRegion + const PropertyOriginMessageID + const PropertyProducerGroup + const PropertyRealQueueID + const PropertyRealTopic + const PropertyReconsumeTime + const PropertyRetryTopic + const PropertySep + const PropertyTags + const PropertyTraceSwitch + const PropertyTransactionPrepared + const PropertyTransferFlag + const PropertyUniqClientMessageIDKeyidx + const PropertyWaitStoreMsgOK + const StoreTimestampPostion + const TransactionCommitType + const TransactionNotType + const TransactionPreparedType + const TransactionRollbackType + func CreateMessageID(storeHost *Addr, commitOffset int64) string + func CreateUniqID() string + func GetUniqID(properties map[string]string) string + func IsMessageID(id string) bool + func Properties2Bytes(properties map[string]string) []byte + func Properties2String(properties map[string]string) string + func SortQueue(queues []*Queue) + func String2Properties(properties string) map[string]string + type Addr struct + Host []byte + Port uint16 + func ParseMessageID(id string) (addr Addr, commitOffset int64, err error) + func (addr *Addr) String() string + type Batch struct + Datas []Data + Flag int32 + Properties map[string]string + Topic string + func (b *Batch) ToMessage() (*Message, error) + type Data struct + Body []byte + Flag int32 + Properties map[string]string + type Ext struct + BodyCRC int32 + BornHost Addr + BornTimestamp int64 + CommitLogOffset int64 + MsgID string + PreparedTransactionOffset int64 + QueueID uint8 + QueueOffset int64 + ReconsumeTimes int32 + StoreHost Addr + StoreSize int32 + StoreTimestamp int64 + SysFlag int32 + func Decode(d []byte) (msgs []*Ext, err error) + func (m *Ext) String() string + type GUID struct + func NewGenerator() *GUID + func (g *GUID) Create() string + type Message struct + Body []byte + Flag int32 + Properties map[string]string + Topic string + func (m *Message) ClearProperty(k string) + func (m *Message) GetConsumeStartTimestamp() (timestamp int64, ok bool) + func (m *Message) GetDelayTimeLevel() int + func (m *Message) GetProperty(k string) string + func (m *Message) GetTags() string + func (m *Message) GetUniqID() string + func (m *Message) GetWaitStoreMsgOK() bool + func (m *Message) PutProperty(k, v string) + func (m *Message) SetConsumeStartTimestamp(timestamp int64) + func (m *Message) SetDelayTimeLevel(l int) + func (m *Message) SetKey(keys string) + func (m *Message) SetKeys(ks []string) + func (m *Message) SetTags(tags string) + func (m *Message) SetUniqID(uniqID string) + func (m *Message) SetWaitStoreMsgOK(ok bool) + func (m *Message) String() string + type Queue struct + BrokerName string + QueueID uint8 + Topic string + func (q *Queue) HashKey() string + func (q *Queue) String() string
Go to main page