tempofb

package
v1.5.0 Latest Latest
Warning

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

 Go to latest Published: Aug 17, 2022 License: AGPL-3.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ContainsTag 

func ContainsTag(s FBTagContainer, kv *KeyValues, k []byte, v []byte) bool

func KeyValuesAddKey 

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

func KeyValuesAddValue 

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

func KeyValuesEnd 

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

func KeyValuesStart 

func KeyValuesStart(builder *flatbuffers.Builder)

func KeyValuesStartValueVector 

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

func SearchBlockHeaderAddMaxDurationNanos 

func SearchBlockHeaderAddMaxDurationNanos(builder *flatbuffers.Builder, maxDurationNanos uint64)

func SearchBlockHeaderAddMinDurationNanos 

func SearchBlockHeaderAddMinDurationNanos(builder *flatbuffers.Builder, minDurationNanos uint64)

func SearchBlockHeaderAddTags 

func SearchBlockHeaderAddTags(builder *flatbuffers.Builder, tags flatbuffers.UOffsetT)

func SearchBlockHeaderEnd 

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

func SearchBlockHeaderStart 

func SearchBlockHeaderStart(builder *flatbuffers.Builder)

func SearchBlockHeaderStartTagsVector 

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

func SearchEntryAddEndTimeUnixNano 

func SearchEntryAddEndTimeUnixNano(builder *flatbuffers.Builder, endTimeUnixNano uint64)

func SearchEntryAddId 

func SearchEntryAddId(builder *flatbuffers.Builder, id flatbuffers.UOffsetT)

func SearchEntryAddStartTimeUnixNano 

func SearchEntryAddStartTimeUnixNano(builder *flatbuffers.Builder, startTimeUnixNano uint64)

func SearchEntryAddTags 

func SearchEntryAddTags(builder *flatbuffers.Builder, tags flatbuffers.UOffsetT)

func SearchEntryEnd 

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

func SearchEntryStart 

func SearchEntryStart(builder *flatbuffers.Builder)

func SearchEntryStartTagsVector 

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

func SearchPageAddEntries 

func SearchPageAddEntries(builder *flatbuffers.Builder, entries flatbuffers.UOffsetT)

func SearchPageAddTags 

func SearchPageAddTags(builder *flatbuffers.Builder, tags flatbuffers.UOffsetT)

func SearchPageEnd 

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

func SearchPageStart 

func SearchPageStart(builder *flatbuffers.Builder)

func SearchPageStartEntriesVector 

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

func SearchPageStartTagsVector 

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

func WriteSearchDataMap added in v1.3.0 

func WriteSearchDataMap(b *flatbuffers.Builder, d SearchDataMap, cache map[uint64]flatbuffers.UOffsetT) flatbuffers.UOffsetT

Types

type Block 

type Block interface {
	TagContainer
	MinDurationNanos() uint64
	MaxDurationNanos() uint64
}

type FBTagContainer 

type FBTagContainer interface {
	Tags(obj *KeyValues, j int) bool
	TagsLength() int
}

type KeyValues 

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

func FindTag added in v1.3.0 

func FindTag(s FBTagContainer, kv *KeyValues, k []byte) *KeyValues

func GetRootAsKeyValues 

func GetRootAsKeyValues(buf []byte, offset flatbuffers.UOffsetT) *KeyValues

func GetSizePrefixedRootAsKeyValues 

func GetSizePrefixedRootAsKeyValues(buf []byte, offset flatbuffers.UOffsetT) *KeyValues

func (*KeyValues) Init 

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

func (*KeyValues) Key 

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

func (*KeyValues) Table 

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

func (*KeyValues) Value 

func (rcv *KeyValues) Value(j int) []byte

func (*KeyValues) ValueLength 

func (rcv *KeyValues) ValueLength() int

type Page 

type Page interface {
	TagContainer
}

type SearchBlockHeader 

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

func GetRootAsSearchBlockHeader 

func GetRootAsSearchBlockHeader(buf []byte, offset flatbuffers.UOffsetT) *SearchBlockHeader

func GetSizePrefixedRootAsSearchBlockHeader 

func GetSizePrefixedRootAsSearchBlockHeader(buf []byte, offset flatbuffers.UOffsetT) *SearchBlockHeader

func (*SearchBlockHeader) Contains 

func (s *SearchBlockHeader) Contains(k []byte, v []byte, buffer *KeyValues) bool

func (*SearchBlockHeader) Init 

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

func (*SearchBlockHeader) MaxDurationNanos 

func (rcv *SearchBlockHeader) MaxDurationNanos() uint64

func (*SearchBlockHeader) MinDurationNanos 

func (rcv *SearchBlockHeader) MinDurationNanos() uint64

func (*SearchBlockHeader) MutateMaxDurationNanos 

func (rcv *SearchBlockHeader) MutateMaxDurationNanos(n uint64) bool

func (*SearchBlockHeader) MutateMinDurationNanos 

func (rcv *SearchBlockHeader) MutateMinDurationNanos(n uint64) bool

func (*SearchBlockHeader) Table 

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

func (*SearchBlockHeader) Tags 

func (rcv *SearchBlockHeader) Tags(obj *KeyValues, j int) bool

func (*SearchBlockHeader) TagsLength 

func (rcv *SearchBlockHeader) TagsLength() int

type SearchBlockHeaderMutable 

type SearchBlockHeaderMutable struct {
	Tags   SearchDataMap
	MinDur uint64
	MaxDur uint64
}

func NewSearchBlockHeaderMutable 

func NewSearchBlockHeaderMutable() *SearchBlockHeaderMutable

func (*SearchBlockHeaderMutable) AddEntry 

func (s *SearchBlockHeaderMutable) AddEntry(e *SearchEntry)

func (*SearchBlockHeaderMutable) AddTag 

func (s *SearchBlockHeaderMutable) AddTag(k string, v string)

AddTag adds the unique tag name and value to the search data. No effect if the pair is already present.

func (*SearchBlockHeaderMutable) Contains 

func (s *SearchBlockHeaderMutable) Contains(k []byte, v []byte, _ *KeyValues) bool

func (*SearchBlockHeaderMutable) MaxDurationNanos 

func (s *SearchBlockHeaderMutable) MaxDurationNanos() uint64

func (*SearchBlockHeaderMutable) MinDurationNanos 

func (s *SearchBlockHeaderMutable) MinDurationNanos() uint64

func (*SearchBlockHeaderMutable) ToBytes 

func (s *SearchBlockHeaderMutable) ToBytes() []byte

type SearchDataMap 

type SearchDataMap map[string]map[string]struct{}

func NewSearchDataMap 

func NewSearchDataMap() SearchDataMap

func NewSearchDataMapWithData 

func NewSearchDataMapWithData(m map[string][]string) SearchDataMap

func (SearchDataMap) Add 

func (s SearchDataMap) Add(k, v string)

func (SearchDataMap) Contains 

func (s SearchDataMap) Contains(k, v string) bool

Contains is an exact match on key, but substring on value

func (SearchDataMap) Range 

func (s SearchDataMap) Range(f func(k, v string))

func (SearchDataMap) RangeKeyValues added in v1.3.0 

func (s SearchDataMap) RangeKeyValues(k string, f TagCallback)

func (SearchDataMap) RangeKeys added in v1.3.0 

func (s SearchDataMap) RangeKeys(f TagCallback)

type SearchEntry 

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

func GetRootAsSearchEntry 

func GetRootAsSearchEntry(buf []byte, offset flatbuffers.UOffsetT) *SearchEntry

func GetSizePrefixedRootAsSearchEntry 

func GetSizePrefixedRootAsSearchEntry(buf []byte, offset flatbuffers.UOffsetT) *SearchEntry

func NewSearchEntryFromBytes added in v1.3.0 

func NewSearchEntryFromBytes(b []byte) *SearchEntry

func (*SearchEntry) Contains 

func (s *SearchEntry) Contains(k []byte, v []byte, buffer *KeyValues) bool

Contains returns true if the key and value are found in the search data. Buffer KeyValue object can be passed to reduce allocations. Key and value must be already converted to byte slices which match the nature of the flatbuffer data which reduces allocations even further.

func (*SearchEntry) EndTimeUnixNano 

func (rcv *SearchEntry) EndTimeUnixNano() uint64

func (*SearchEntry) Get 

func (s *SearchEntry) Get(k string) string

Get searches the entry and returns the first value found for the given key.

func (*SearchEntry) Id 

func (rcv *SearchEntry) Id() []byte

func (*SearchEntry) Init 

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

func (*SearchEntry) MutateEndTimeUnixNano 

func (rcv *SearchEntry) MutateEndTimeUnixNano(n uint64) bool

func (*SearchEntry) MutateStartTimeUnixNano 

func (rcv *SearchEntry) MutateStartTimeUnixNano(n uint64) bool

func (*SearchEntry) Reset added in v1.3.0 

func (s *SearchEntry) Reset(b []byte)

func (*SearchEntry) StartTimeUnixNano 

func (rcv *SearchEntry) StartTimeUnixNano() uint64

func (*SearchEntry) Table 

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

func (*SearchEntry) Tags 

func (rcv *SearchEntry) Tags(obj *KeyValues, j int) bool

func (*SearchEntry) TagsLength 

func (rcv *SearchEntry) TagsLength() int

type SearchEntryMutable 

type SearchEntryMutable struct {
	TraceID           []byte
	Tags              SearchDataMap
	StartTimeUnixNano uint64
	EndTimeUnixNano   uint64
}

SearchEntryMutable is a mutable form of the flatbuffer-compiled SearchEntry struct to make building and transporting easier.

func (*SearchEntryMutable) AddTag 

func (s *SearchEntryMutable) AddTag(k string, v string)

AddTag adds the unique tag name and value to the search data. No effect if the pair is already present.

func (*SearchEntryMutable) SetEndTimeUnixNano 

func (s *SearchEntryMutable) SetEndTimeUnixNano(t uint64)

SetEndTimeUnixNano records the latest of all timestamps passed to this function.

func (*SearchEntryMutable) SetStartTimeUnixNano 

func (s *SearchEntryMutable) SetStartTimeUnixNano(t uint64)

SetStartTimeUnixNano records the earliest of all timestamps passed to this function.

func (*SearchEntryMutable) ToBytes 

func (s *SearchEntryMutable) ToBytes() []byte

func (*SearchEntryMutable) WriteToBuilder 

func (s *SearchEntryMutable) WriteToBuilder(b *flatbuffers.Builder, kvCache map[uint64]flatbuffers.UOffsetT) flatbuffers.UOffsetT

type SearchPage 

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

func GetRootAsSearchPage 

func GetRootAsSearchPage(buf []byte, offset flatbuffers.UOffsetT) *SearchPage

func GetSizePrefixedRootAsSearchPage 

func GetSizePrefixedRootAsSearchPage(buf []byte, offset flatbuffers.UOffsetT) *SearchPage

func (*SearchPage) Contains 

func (s *SearchPage) Contains(k []byte, v []byte, buffer *KeyValues) bool

func (*SearchPage) Entries 

func (rcv *SearchPage) Entries(obj *SearchEntry, j int) bool

func (*SearchPage) EntriesLength 

func (rcv *SearchPage) EntriesLength() int

func (*SearchPage) Init 

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

func (*SearchPage) Table 

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

func (*SearchPage) Tags 

func (rcv *SearchPage) Tags(obj *KeyValues, j int) bool

func (*SearchPage) TagsLength 

func (rcv *SearchPage) TagsLength() int

type SearchPageBuilder 

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

func NewSearchPageBuilder 

func NewSearchPageBuilder() *SearchPageBuilder

func (*SearchPageBuilder) AddData 

func (b *SearchPageBuilder) AddData(data *SearchEntryMutable) int

func (*SearchPageBuilder) Finish 

func (b *SearchPageBuilder) Finish() []byte

func (*SearchPageBuilder) Reset 

func (b *SearchPageBuilder) Reset()

type TagCallback added in v1.5.0 

type TagCallback func(t string)

type TagContainer 

type TagContainer interface {
	Contains(k []byte, v []byte, buffer *KeyValues) bool
}

TagContainer is anything with KeyValues (tags). This is implemented by both SearchPage and SearchEntry.

type Trace 

type Trace interface {
	TagContainer
	StartTimeUnixNano() uint64
	EndTimeUnixNano() uint64
}

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.