message_fbs

Documentation

Index

• func MessageAddData(builder *flatbuffers.Builder, data flatbuffers.UOffsetT)
• func MessageAddKey(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)
• func MessageAddProperties(builder *flatbuffers.Builder, properties flatbuffers.UOffsetT)
• func MessageAddSeqDelta(builder *flatbuffers.Builder, seqDelta int32)
• func MessageAddTsMsDelta(builder *flatbuffers.Builder, tsMsDelta int32)
• func MessageBatchAddFlags(builder *flatbuffers.Builder, flags int32)
• func MessageBatchAddMessages(builder *flatbuffers.Builder, messages flatbuffers.UOffsetT)
• func MessageBatchAddProducerEpoch(builder *flatbuffers.Builder, producerEpoch int32)
• func MessageBatchAddProducerId(builder *flatbuffers.Builder, producerId int32)
• func MessageBatchAddSegmentId(builder *flatbuffers.Builder, segmentId int32)
• func MessageBatchAddSegmentSeqBase(builder *flatbuffers.Builder, segmentSeqBase int64)
• func MessageBatchAddSegmentSeqMaxDelta(builder *flatbuffers.Builder, segmentSeqMaxDelta int32)
• func MessageBatchAddTsMsBase(builder *flatbuffers.Builder, tsMsBase int64)
• func MessageBatchAddTsMsMaxDelta(builder *flatbuffers.Builder, tsMsMaxDelta int32)
• func MessageBatchEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
• func MessageBatchStart(builder *flatbuffers.Builder)
• func MessageBatchStartMessagesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
• func MessageEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
• func MessageStart(builder *flatbuffers.Builder)
• func MessageStartPropertiesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
• func NameValueAddName(builder *flatbuffers.Builder, name flatbuffers.UOffsetT)
• func NameValueAddValue(builder *flatbuffers.Builder, value flatbuffers.UOffsetT)
• func NameValueEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
• func NameValueStart(builder *flatbuffers.Builder)
• type Message
  • func GetRootAsMessage(buf []byte, offset flatbuffers.UOffsetT) *Message
  • func GetSizePrefixedRootAsMessage(buf []byte, offset flatbuffers.UOffsetT) *Message
  • func (rcv *Message) Data() []byte
  • func (rcv *Message) Init(buf []byte, i flatbuffers.UOffsetT)
  • func (rcv *Message) Key() []byte
  • func (rcv *Message) MutateSeqDelta(n int32) bool
  • func (rcv *Message) MutateTsMsDelta(n int32) bool
  • func (rcv *Message) Properties(obj *NameValue, j int) bool
  • func (rcv *Message) PropertiesLength() int
  • func (rcv *Message) SeqDelta() int32
  • func (rcv *Message) Table() flatbuffers.Table
  • func (rcv *Message) TsMsDelta() int32
• type MessageBatch
  • func GetRootAsMessageBatch(buf []byte, offset flatbuffers.UOffsetT) *MessageBatch
  • func GetSizePrefixedRootAsMessageBatch(buf []byte, offset flatbuffers.UOffsetT) *MessageBatch
  • func (rcv *MessageBatch) Flags() int32
  • func (rcv *MessageBatch) Init(buf []byte, i flatbuffers.UOffsetT)
  • func (rcv *MessageBatch) Messages(obj *Message, j int) bool
  • func (rcv *MessageBatch) MessagesLength() int
  • func (rcv *MessageBatch) MutateFlags(n int32) bool
  • func (rcv *MessageBatch) MutateProducerEpoch(n int32) bool
  • func (rcv *MessageBatch) MutateProducerId(n int32) bool
  • func (rcv *MessageBatch) MutateSegmentId(n int32) bool
  • func (rcv *MessageBatch) MutateSegmentSeqBase(n int64) bool
  • func (rcv *MessageBatch) MutateSegmentSeqMaxDelta(n int32) bool
  • func (rcv *MessageBatch) MutateTsMsBase(n int64) bool
  • func (rcv *MessageBatch) MutateTsMsMaxDelta(n int32) bool
  • func (rcv *MessageBatch) ProducerEpoch() int32
  • func (rcv *MessageBatch) ProducerId() int32
  • func (rcv *MessageBatch) SegmentId() int32
  • func (rcv *MessageBatch) SegmentSeqBase() int64
  • func (rcv *MessageBatch) SegmentSeqMaxDelta() int32
  • func (rcv *MessageBatch) Table() flatbuffers.Table
  • func (rcv *MessageBatch) TsMsBase() int64
  • func (rcv *MessageBatch) TsMsMaxDelta() int32
• type NameValue
  • func GetRootAsNameValue(buf []byte, offset flatbuffers.UOffsetT) *NameValue
  • func GetSizePrefixedRootAsNameValue(buf []byte, offset flatbuffers.UOffsetT) *NameValue
  • func (rcv *NameValue) Init(buf []byte, i flatbuffers.UOffsetT)
  • func (rcv *NameValue) Name() []byte
  • func (rcv *NameValue) Table() flatbuffers.Table
  • func (rcv *NameValue) Value() []byte

Functions

func MessageAddData

func MessageAddData(builder *flatbuffers.Builder, data flatbuffers.UOffsetT)

func MessageAddKey

func MessageAddKey(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)

func MessageAddProperties

func MessageAddProperties(builder *flatbuffers.Builder, properties flatbuffers.UOffsetT)

func MessageAddSeqDelta

func MessageAddSeqDelta(builder *flatbuffers.Builder, seqDelta int32)

func MessageAddTsMsDelta

func MessageAddTsMsDelta(builder *flatbuffers.Builder, tsMsDelta int32)

func MessageBatchAddFlags

func MessageBatchAddFlags(builder *flatbuffers.Builder, flags int32)

func MessageBatchAddMessages

func MessageBatchAddMessages(builder *flatbuffers.Builder, messages flatbuffers.UOffsetT)

func MessageBatchAddProducerEpoch

func MessageBatchAddProducerEpoch(builder *flatbuffers.Builder, producerEpoch int32)

func MessageBatchAddProducerId

func MessageBatchAddProducerId(builder *flatbuffers.Builder, producerId int32)

func MessageBatchAddSegmentId

func MessageBatchAddSegmentId(builder *flatbuffers.Builder, segmentId int32)

func MessageBatchAddSegmentSeqBase

func MessageBatchAddSegmentSeqBase(builder *flatbuffers.Builder, segmentSeqBase int64)

func MessageBatchAddSegmentSeqMaxDelta

func MessageBatchAddSegmentSeqMaxDelta(builder *flatbuffers.Builder, segmentSeqMaxDelta int32)

func MessageBatchAddTsMsBase

func MessageBatchAddTsMsBase(builder *flatbuffers.Builder, tsMsBase int64)

func MessageBatchAddTsMsMaxDelta

func MessageBatchAddTsMsMaxDelta(builder *flatbuffers.Builder, tsMsMaxDelta int32)

func MessageBatchEnd

func MessageBatchEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func MessageBatchStart

func MessageBatchStart(builder *flatbuffers.Builder)

func MessageBatchStartMessagesVector

func MessageBatchStartMessagesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func MessageEnd

func MessageEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func MessageStart

func MessageStart(builder *flatbuffers.Builder)

func MessageStartPropertiesVector

func MessageStartPropertiesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func NameValueAddName

func NameValueAddName(builder *flatbuffers.Builder, name flatbuffers.UOffsetT)

func NameValueAddValue

func NameValueAddValue(builder *flatbuffers.Builder, value flatbuffers.UOffsetT)

func NameValueEnd

func NameValueEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func NameValueStart

func NameValueStart(builder *flatbuffers.Builder)

Types

type Message

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

func GetRootAsMessage

func GetRootAsMessage(buf []byte, offset flatbuffers.UOffsetT) *Message

func GetSizePrefixedRootAsMessage

func GetSizePrefixedRootAsMessage(buf []byte, offset flatbuffers.UOffsetT) *Message

func (*Message) Data

func (rcv *Message) Data() []byte

func (*Message) Init

func (rcv *Message) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Message) Key

func (rcv *Message) Key() []byte

func (*Message) MutateSeqDelta

func (rcv *Message) MutateSeqDelta(n int32) bool

func (*Message) MutateTsMsDelta

func (rcv *Message) MutateTsMsDelta(n int32) bool

func (*Message) Properties

func (rcv *Message) Properties(obj *NameValue, j int) bool

func (*Message) PropertiesLength

func (rcv *Message) PropertiesLength() int

func (*Message) SeqDelta

func (rcv *Message) SeqDelta() int32

func (*Message) Table

func (rcv *Message) Table() flatbuffers.Table

func (*Message) TsMsDelta

func (rcv *Message) TsMsDelta() int32

type MessageBatch

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

func GetRootAsMessageBatch

func GetRootAsMessageBatch(buf []byte, offset flatbuffers.UOffsetT) *MessageBatch

func GetSizePrefixedRootAsMessageBatch

func GetSizePrefixedRootAsMessageBatch(buf []byte, offset flatbuffers.UOffsetT) *MessageBatch

func (*MessageBatch) Flags

func (rcv *MessageBatch) Flags() int32

func (*MessageBatch) Init

func (rcv *MessageBatch) Init(buf []byte, i flatbuffers.UOffsetT)

func (*MessageBatch) Messages

func (rcv *MessageBatch) Messages(obj *Message, j int) bool

func (*MessageBatch) MessagesLength

func (rcv *MessageBatch) MessagesLength() int

func (*MessageBatch) MutateFlags

func (rcv *MessageBatch) MutateFlags(n int32) bool

func (*MessageBatch) MutateProducerEpoch

func (rcv *MessageBatch) MutateProducerEpoch(n int32) bool

func (*MessageBatch) MutateProducerId

func (rcv *MessageBatch) MutateProducerId(n int32) bool

func (*MessageBatch) MutateSegmentId

func (rcv *MessageBatch) MutateSegmentId(n int32) bool

func (*MessageBatch) MutateSegmentSeqBase

func (rcv *MessageBatch) MutateSegmentSeqBase(n int64) bool

func (*MessageBatch) MutateSegmentSeqMaxDelta

func (rcv *MessageBatch) MutateSegmentSeqMaxDelta(n int32) bool

func (*MessageBatch) MutateTsMsBase

func (rcv *MessageBatch) MutateTsMsBase(n int64) bool

func (*MessageBatch) MutateTsMsMaxDelta

func (rcv *MessageBatch) MutateTsMsMaxDelta(n int32) bool

func (*MessageBatch) ProducerEpoch

func (rcv *MessageBatch) ProducerEpoch() int32

func (*MessageBatch) ProducerId

func (rcv *MessageBatch) ProducerId() int32

func (*MessageBatch) SegmentId

func (rcv *MessageBatch) SegmentId() int32

func (*MessageBatch) SegmentSeqBase

func (rcv *MessageBatch) SegmentSeqBase() int64

func (*MessageBatch) SegmentSeqMaxDelta

func (rcv *MessageBatch) SegmentSeqMaxDelta() int32

func (*MessageBatch) Table

func (rcv *MessageBatch) Table() flatbuffers.Table

func (*MessageBatch) TsMsBase

func (rcv *MessageBatch) TsMsBase() int64

func (*MessageBatch) TsMsMaxDelta

func (rcv *MessageBatch) TsMsMaxDelta() int32

type NameValue

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

func GetRootAsNameValue

func GetRootAsNameValue(buf []byte, offset flatbuffers.UOffsetT) *NameValue

func GetSizePrefixedRootAsNameValue

func GetSizePrefixedRootAsNameValue(buf []byte, offset flatbuffers.UOffsetT) *NameValue

func (*NameValue) Init

func (rcv *NameValue) Init(buf []byte, i flatbuffers.UOffsetT)

func (*NameValue) Name

func (rcv *NameValue) Name() []byte

func (*NameValue) Table

func (rcv *NameValue) Table() flatbuffers.Table

func (*NameValue) Value

func (rcv *NameValue) Value() []byte