Versions in this module Expand all Collapse all v0 v0.1.1 Aug 24, 2023 v0.1.0 Aug 9, 2023 Changes in this version + const RecordBatchIdentifier + func FinishRecordBatchBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT) + func FinishRecordBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT) + func FinishSizePrefixedRecordBatchBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT) + func FinishSizePrefixedRecordBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT) + func RecordAddFunctionCall(builder *flatbuffers.Builder, functionCall flatbuffers.UOffsetT) + func RecordAddFunctionId(builder *flatbuffers.Builder, functionId uint32) + func RecordAddTimestamp(builder *flatbuffers.Builder, timestamp int64) + func RecordBatchAddChecksum(builder *flatbuffers.Builder, checksum uint32) + func RecordBatchAddCompressedSize(builder *flatbuffers.Builder, compressedSize uint32) + func RecordBatchAddCompression(builder *flatbuffers.Builder, compression types.Compression) + func RecordBatchAddFirstOffset(builder *flatbuffers.Builder, firstOffset int64) + func RecordBatchAddFirstTimestamp(builder *flatbuffers.Builder, firstTimestamp int64) + func RecordBatchAddLastTimestamp(builder *flatbuffers.Builder, lastTimestamp int64) + func RecordBatchAddNumRecords(builder *flatbuffers.Builder, numRecords uint32) + func RecordBatchAddUncompressedSize(builder *flatbuffers.Builder, uncompressedSize uint32) + func RecordBatchBufferHasIdentifier(buf []byte) bool + func RecordBatchEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT + func RecordBatchStart(builder *flatbuffers.Builder) + func RecordEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT + func RecordStart(builder *flatbuffers.Builder) + func RecordStartFunctionCallVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT + func SizePrefixedRecordBatchBufferHasIdentifier(buf []byte) bool + type Record struct + func GetRootAsRecord(buf []byte, offset flatbuffers.UOffsetT) *Record + func GetSizePrefixedRootAsRecord(buf []byte, offset flatbuffers.UOffsetT) *Record + func (rcv *Record) FunctionCall(j int) byte + func (rcv *Record) FunctionCallBytes() []byte + func (rcv *Record) FunctionCallLength() int + func (rcv *Record) FunctionId() uint32 + func (rcv *Record) Init(buf []byte, i flatbuffers.UOffsetT) + func (rcv *Record) MutateFunctionCall(j int, n byte) bool + func (rcv *Record) MutateFunctionId(n uint32) bool + func (rcv *Record) MutateTimestamp(n int64) bool + func (rcv *Record) Table() flatbuffers.Table + func (rcv *Record) Timestamp() int64 + type RecordBatch struct + func GetRootAsRecordBatch(buf []byte, offset flatbuffers.UOffsetT) *RecordBatch + func GetSizePrefixedRootAsRecordBatch(buf []byte, offset flatbuffers.UOffsetT) *RecordBatch + func (rcv *RecordBatch) Checksum() uint32 + func (rcv *RecordBatch) CompressedSize() uint32 + func (rcv *RecordBatch) Compression() types.Compression + func (rcv *RecordBatch) FirstOffset() int64 + func (rcv *RecordBatch) FirstTimestamp() int64 + func (rcv *RecordBatch) Init(buf []byte, i flatbuffers.UOffsetT) + func (rcv *RecordBatch) LastTimestamp() int64 + func (rcv *RecordBatch) MutateChecksum(n uint32) bool + func (rcv *RecordBatch) MutateCompressedSize(n uint32) bool + func (rcv *RecordBatch) MutateCompression(n types.Compression) bool + func (rcv *RecordBatch) MutateFirstOffset(n int64) bool + func (rcv *RecordBatch) MutateFirstTimestamp(n int64) bool + func (rcv *RecordBatch) MutateLastTimestamp(n int64) bool + func (rcv *RecordBatch) MutateNumRecords(n uint32) bool + func (rcv *RecordBatch) MutateUncompressedSize(n uint32) bool + func (rcv *RecordBatch) NumRecords() uint32 + func (rcv *RecordBatch) Table() flatbuffers.Table + func (rcv *RecordBatch) UncompressedSize() uint32