logsegment

package
v0.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 24, 2023 License: AGPL-3.0 Imports: 2 Imported by: 0

Documentation

Overview

Package logsegment contains the definition of the flatbuffers file format for log segments.

Index

Constants

View Source 
const RecordBatchIdentifier = "TL.0"

Variables

This section is empty.

Functions

func FinishRecordBatchBuffer 

func FinishRecordBatchBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)

func FinishRecordBuffer 

func FinishRecordBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)

func FinishSizePrefixedRecordBatchBuffer 

func FinishSizePrefixedRecordBatchBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)

func FinishSizePrefixedRecordBuffer 

func FinishSizePrefixedRecordBuffer(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)

func RecordAddFunctionCall 

func RecordAddFunctionCall(builder *flatbuffers.Builder, functionCall flatbuffers.UOffsetT)

func RecordAddFunctionId 

func RecordAddFunctionId(builder *flatbuffers.Builder, functionId uint32)

func RecordAddTimestamp 

func RecordAddTimestamp(builder *flatbuffers.Builder, timestamp int64)

func RecordBatchAddChecksum 

func RecordBatchAddChecksum(builder *flatbuffers.Builder, checksum uint32)

func RecordBatchAddCompressedSize 

func RecordBatchAddCompressedSize(builder *flatbuffers.Builder, compressedSize uint32)

func RecordBatchAddCompression 

func RecordBatchAddCompression(builder *flatbuffers.Builder, compression types.Compression)

func RecordBatchAddFirstOffset 

func RecordBatchAddFirstOffset(builder *flatbuffers.Builder, firstOffset int64)

func RecordBatchAddFirstTimestamp 

func RecordBatchAddFirstTimestamp(builder *flatbuffers.Builder, firstTimestamp int64)

func RecordBatchAddLastTimestamp 

func RecordBatchAddLastTimestamp(builder *flatbuffers.Builder, lastTimestamp int64)

func RecordBatchAddNumRecords 

func RecordBatchAddNumRecords(builder *flatbuffers.Builder, numRecords uint32)

func RecordBatchAddUncompressedSize 

func RecordBatchAddUncompressedSize(builder *flatbuffers.Builder, uncompressedSize uint32)

func RecordBatchBufferHasIdentifier 

func RecordBatchBufferHasIdentifier(buf []byte) bool

func RecordBatchEnd 

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

func RecordBatchStart 

func RecordBatchStart(builder *flatbuffers.Builder)

func RecordEnd 

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

func RecordStart 

func RecordStart(builder *flatbuffers.Builder)

func RecordStartFunctionCallVector 

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

func SizePrefixedRecordBatchBufferHasIdentifier 

func SizePrefixedRecordBatchBufferHasIdentifier(buf []byte) bool

Types

type Record 

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

func GetRootAsRecord 

func GetRootAsRecord(buf []byte, offset flatbuffers.UOffsetT) *Record

func GetSizePrefixedRootAsRecord 

func GetSizePrefixedRootAsRecord(buf []byte, offset flatbuffers.UOffsetT) *Record

func (*Record) FunctionCall 

func (rcv *Record) FunctionCall(j int) byte

func (*Record) FunctionCallBytes 

func (rcv *Record) FunctionCallBytes() []byte

func (*Record) FunctionCallLength 

func (rcv *Record) FunctionCallLength() int

func (*Record) FunctionId 

func (rcv *Record) FunctionId() uint32

func (*Record) Init 

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

func (*Record) MutateFunctionCall 

func (rcv *Record) MutateFunctionCall(j int, n byte) bool

func (*Record) MutateFunctionId 

func (rcv *Record) MutateFunctionId(n uint32) bool

func (*Record) MutateTimestamp 

func (rcv *Record) MutateTimestamp(n int64) bool

func (*Record) Table 

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

func (*Record) Timestamp 

func (rcv *Record) Timestamp() int64

type RecordBatch 

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

func GetRootAsRecordBatch 

func GetRootAsRecordBatch(buf []byte, offset flatbuffers.UOffsetT) *RecordBatch

func GetSizePrefixedRootAsRecordBatch 

func GetSizePrefixedRootAsRecordBatch(buf []byte, offset flatbuffers.UOffsetT) *RecordBatch

func (*RecordBatch) Checksum 

func (rcv *RecordBatch) Checksum() uint32

func (*RecordBatch) CompressedSize 

func (rcv *RecordBatch) CompressedSize() uint32

func (*RecordBatch) Compression 

func (rcv *RecordBatch) Compression() types.Compression

func (*RecordBatch) FirstOffset 

func (rcv *RecordBatch) FirstOffset() int64

func (*RecordBatch) FirstTimestamp 

func (rcv *RecordBatch) FirstTimestamp() int64

func (*RecordBatch) Init 

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

func (*RecordBatch) LastTimestamp 

func (rcv *RecordBatch) LastTimestamp() int64

func (*RecordBatch) MutateChecksum 

func (rcv *RecordBatch) MutateChecksum(n uint32) bool

func (*RecordBatch) MutateCompressedSize 

func (rcv *RecordBatch) MutateCompressedSize(n uint32) bool

func (*RecordBatch) MutateCompression 

func (rcv *RecordBatch) MutateCompression(n types.Compression) bool

func (*RecordBatch) MutateFirstOffset 

func (rcv *RecordBatch) MutateFirstOffset(n int64) bool

func (*RecordBatch) MutateFirstTimestamp 

func (rcv *RecordBatch) MutateFirstTimestamp(n int64) bool

func (*RecordBatch) MutateLastTimestamp 

func (rcv *RecordBatch) MutateLastTimestamp(n int64) bool

func (*RecordBatch) MutateNumRecords 

func (rcv *RecordBatch) MutateNumRecords(n uint32) bool

func (*RecordBatch) MutateUncompressedSize 

func (rcv *RecordBatch) MutateUncompressedSize(n uint32) bool

func (*RecordBatch) NumRecords 

func (rcv *RecordBatch) NumRecords() uint32

func (*RecordBatch) Table 

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

func (*RecordBatch) UncompressedSize 

func (rcv *RecordBatch) UncompressedSize() uint32

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.