segment

Documentation

Index

• type MessageBatchBuilder
  • func NewMessageBatchBuilder(b *flatbuffers.Builder, producerId int32, producerEpoch int32, segmentId int32, ...) *MessageBatchBuilder
  • func (builder *MessageBatchBuilder) AddMessage(segmentSeq int64, tsMs int64, properties map[string][]byte, key []byte, ...)
  • func (builder *MessageBatchBuilder) BuildMessageBatch()
  • func (builder *MessageBatchBuilder) GetBytes() []byte

Types

type MessageBatchBuilder

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

func NewMessageBatchBuilder

func NewMessageBatchBuilder(b *flatbuffers.Builder,
	producerId int32,
	producerEpoch int32,
	segmentId int32,
	flags int32) *MessageBatchBuilder

func (*MessageBatchBuilder) AddMessage

func (builder *MessageBatchBuilder) AddMessage(segmentSeq int64, tsMs int64, properties map[string][]byte, key []byte, value []byte)

func (*MessageBatchBuilder) BuildMessageBatch

func (builder *MessageBatchBuilder) BuildMessageBatch()

func (*MessageBatchBuilder) GetBytes

func (builder *MessageBatchBuilder) GetBytes() []byte