ttgstream

package
v0.0.0-...-319f178 Latest Latest
Warning

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

 Go to latest Published: Apr 28, 2019 License: MIT Imports: 1 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func SeriesFooter1AddBytesLength 

func SeriesFooter1AddBytesLength(builder *flatbuffers.Builder, bytesLength uint64)

func SeriesFooter1AddCreatedEpoch 

func SeriesFooter1AddCreatedEpoch(builder *flatbuffers.Builder, createdEpoch uint64)

func SeriesFooter1AddDataFnv1aChecksum 

func SeriesFooter1AddDataFnv1aChecksum(builder *flatbuffers.Builder, dataFnv1aChecksum uint32)

func SeriesFooter1AddHeadRecordEpoch 

func SeriesFooter1AddHeadRecordEpoch(builder *flatbuffers.Builder, headRecordEpoch uint64)

func SeriesFooter1AddRecordCount 

func SeriesFooter1AddRecordCount(builder *flatbuffers.Builder, recordCount uint64)

func SeriesFooter1AddSourceSha1 

func SeriesFooter1AddSourceSha1(builder *flatbuffers.Builder, sourceSha1 flatbuffers.UOffsetT)

func SeriesFooter1AddTailRecordEpoch 

func SeriesFooter1AddTailRecordEpoch(builder *flatbuffers.Builder, tailRecordEpoch uint64)

func SeriesFooter1AddUpdatedEpoch 

func SeriesFooter1AddUpdatedEpoch(builder *flatbuffers.Builder, updatedEpoch uint64)

func SeriesFooter1AddUuid 

func SeriesFooter1AddUuid(builder *flatbuffers.Builder, uuid flatbuffers.UOffsetT)

func SeriesFooter1End 

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

func SeriesFooter1Start 

func SeriesFooter1Start(builder *flatbuffers.Builder)

func StreamFooter1AddSeries 

func StreamFooter1AddSeries(builder *flatbuffers.Builder, series flatbuffers.UOffsetT)

func StreamFooter1End 

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

func StreamFooter1Start 

func StreamFooter1Start(builder *flatbuffers.Builder)

func StreamFooter1StartSeriesVector 

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

func StreamIndexedSequenceInfoAddAbsolutePosition 

func StreamIndexedSequenceInfoAddAbsolutePosition(builder *flatbuffers.Builder, absolutePosition int64)

func StreamIndexedSequenceInfoAddHeadRecordEpoch 

func StreamIndexedSequenceInfoAddHeadRecordEpoch(builder *flatbuffers.Builder, headRecordEpoch uint64)

func StreamIndexedSequenceInfoAddTailRecordEpoch 

func StreamIndexedSequenceInfoAddTailRecordEpoch(builder *flatbuffers.Builder, tailRecordEpoch uint64)

func StreamIndexedSequenceInfoAddUuid 

func StreamIndexedSequenceInfoAddUuid(builder *flatbuffers.Builder, uuid flatbuffers.UOffsetT)

func StreamIndexedSequenceInfoEnd 

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

func StreamIndexedSequenceInfoStart 

func StreamIndexedSequenceInfoStart(builder *flatbuffers.Builder)

Types

type SeriesFooter1 

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

func GetRootAsSeriesFooter1 

func GetRootAsSeriesFooter1(buf []byte, offset flatbuffers.UOffsetT) *SeriesFooter1

func (*SeriesFooter1) BytesLength 

func (rcv *SeriesFooter1) BytesLength() uint64

func (*SeriesFooter1) CreatedEpoch 

func (rcv *SeriesFooter1) CreatedEpoch() uint64

func (*SeriesFooter1) DataFnv1aChecksum 

func (rcv *SeriesFooter1) DataFnv1aChecksum() uint32

func (*SeriesFooter1) HeadRecordEpoch 

func (rcv *SeriesFooter1) HeadRecordEpoch() uint64

func (*SeriesFooter1) Init 

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

func (*SeriesFooter1) MutateBytesLength 

func (rcv *SeriesFooter1) MutateBytesLength(n uint64) bool

func (*SeriesFooter1) MutateCreatedEpoch 

func (rcv *SeriesFooter1) MutateCreatedEpoch(n uint64) bool

func (*SeriesFooter1) MutateDataFnv1aChecksum 

func (rcv *SeriesFooter1) MutateDataFnv1aChecksum(n uint32) bool

func (*SeriesFooter1) MutateHeadRecordEpoch 

func (rcv *SeriesFooter1) MutateHeadRecordEpoch(n uint64) bool

func (*SeriesFooter1) MutateRecordCount 

func (rcv *SeriesFooter1) MutateRecordCount(n uint64) bool

func (*SeriesFooter1) MutateTailRecordEpoch 

func (rcv *SeriesFooter1) MutateTailRecordEpoch(n uint64) bool

func (*SeriesFooter1) MutateUpdatedEpoch 

func (rcv *SeriesFooter1) MutateUpdatedEpoch(n uint64) bool

func (*SeriesFooter1) RecordCount 

func (rcv *SeriesFooter1) RecordCount() uint64

func (*SeriesFooter1) SourceSha1 

func (rcv *SeriesFooter1) SourceSha1() []byte

func (*SeriesFooter1) Table 

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

func (*SeriesFooter1) TailRecordEpoch 

func (rcv *SeriesFooter1) TailRecordEpoch() uint64

func (*SeriesFooter1) UpdatedEpoch 

func (rcv *SeriesFooter1) UpdatedEpoch() uint64

func (*SeriesFooter1) Uuid 

func (rcv *SeriesFooter1) Uuid() []byte

type StreamFooter1 

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

func GetRootAsStreamFooter1 

func GetRootAsStreamFooter1(buf []byte, offset flatbuffers.UOffsetT) *StreamFooter1

func (*StreamFooter1) Init 

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

func (*StreamFooter1) Series 

func (rcv *StreamFooter1) Series(obj *StreamIndexedSequenceInfo, j int) bool

func (*StreamFooter1) SeriesLength 

func (rcv *StreamFooter1) SeriesLength() int

func (*StreamFooter1) Table 

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

type StreamIndexedSequenceInfo 

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

func GetRootAsStreamIndexedSequenceInfo 

func GetRootAsStreamIndexedSequenceInfo(buf []byte, offset flatbuffers.UOffsetT) *StreamIndexedSequenceInfo

func (*StreamIndexedSequenceInfo) AbsolutePosition 

func (rcv *StreamIndexedSequenceInfo) AbsolutePosition() int64

func (*StreamIndexedSequenceInfo) HeadRecordEpoch 

func (rcv *StreamIndexedSequenceInfo) HeadRecordEpoch() uint64

func (*StreamIndexedSequenceInfo) Init 

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

func (*StreamIndexedSequenceInfo) MutateAbsolutePosition 

func (rcv *StreamIndexedSequenceInfo) MutateAbsolutePosition(n int64) bool

func (*StreamIndexedSequenceInfo) MutateHeadRecordEpoch 

func (rcv *StreamIndexedSequenceInfo) MutateHeadRecordEpoch(n uint64) bool

func (*StreamIndexedSequenceInfo) MutateTailRecordEpoch 

func (rcv *StreamIndexedSequenceInfo) MutateTailRecordEpoch(n uint64) bool

func (*StreamIndexedSequenceInfo) Table 

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

func (*StreamIndexedSequenceInfo) TailRecordEpoch 

func (rcv *StreamIndexedSequenceInfo) TailRecordEpoch() uint64

func (*StreamIndexedSequenceInfo) Uuid 

func (rcv *StreamIndexedSequenceInfo) Uuid() []byte

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.