fetch

package
v1.14.0 Latest Latest
Warning

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

 Go to latest Published: May 19, 2023 License: BSD-3-Clause Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var EnumNamesKind = map[Kind]string{
	KindUNKNOWN:         "UNKNOWN",
	KindNUMERIC:         "NUMERIC",
	KindHIST:            "HIST",
	KindHIST_CUMULATIVE: "HIST_CUMULATIVE",
	KindTEXT:            "TEXT",
}
View Source 
var EnumNamesSeries = map[Series]string{
	SeriesNONE:          "NONE",
	SeriesNumericSeries: "NumericSeries",
	SeriesHistSeries:    "HistSeries",
	SeriesTextSeries:    "TextSeries",
}
View Source 
var EnumValuesKind = map[string]Kind{
	"UNKNOWN":         KindUNKNOWN,
	"NUMERIC":         KindNUMERIC,
	"HIST":            KindHIST,
	"HIST_CUMULATIVE": KindHIST_CUMULATIVE,
	"TEXT":            KindTEXT,
}
View Source 
var EnumValuesSeries = map[string]Series{
	"NONE":          SeriesNONE,
	"NumericSeries": SeriesNumericSeries,
	"HistSeries":    SeriesHistSeries,
	"TextSeries":    SeriesTextSeries,
}

Functions

func ColumnMetaDataAddLabel 

func ColumnMetaDataAddLabel(builder *flatbuffers.Builder, label flatbuffers.UOffsetT)

func ColumnMetaDataAddMeta 

func ColumnMetaDataAddMeta(builder *flatbuffers.Builder, meta flatbuffers.UOffsetT)

func ColumnMetaDataEnd 

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

func ColumnMetaDataPack 

func ColumnMetaDataPack(builder *flatbuffers.Builder, t *ColumnMetaDataT) flatbuffers.UOffsetT

func ColumnMetaDataStart 

func ColumnMetaDataStart(builder *flatbuffers.Builder)

func ColumnMetaDataStartMetaVector 

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

func DF4AddColumns 

func DF4AddColumns(builder *flatbuffers.Builder, columns flatbuffers.UOffsetT)

func DF4AddHead 

func DF4AddHead(builder *flatbuffers.Builder, head flatbuffers.UOffsetT)

func DF4AddMeta 

func DF4AddMeta(builder *flatbuffers.Builder, meta flatbuffers.UOffsetT)

func DF4AddVersion 

func DF4AddVersion(builder *flatbuffers.Builder, version uint32)

func DF4End 

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

func DF4Pack 

func DF4Pack(builder *flatbuffers.Builder, t *DF4T) flatbuffers.UOffsetT

func DF4Start 

func DF4Start(builder *flatbuffers.Builder)

func DF4StartColumnsVector 

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

func DF4StartMetaVector 

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

func FetchAddCount 

func FetchAddCount(builder *flatbuffers.Builder, count uint32)

func FetchAddPeriodMs 

func FetchAddPeriodMs(builder *flatbuffers.Builder, periodMs uint32)

func FetchAddReduce 

func FetchAddReduce(builder *flatbuffers.Builder, reduce flatbuffers.UOffsetT)

func FetchAddStartMs 

func FetchAddStartMs(builder *flatbuffers.Builder, startMs uint64)

func FetchAddStreams 

func FetchAddStreams(builder *flatbuffers.Builder, streams flatbuffers.UOffsetT)

func FetchEnd 

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

func FetchPack 

func FetchPack(builder *flatbuffers.Builder, t *FetchT) flatbuffers.UOffsetT

func FetchStart 

func FetchStart(builder *flatbuffers.Builder)

func FetchStartReduceVector 

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

func FetchStartStreamsVector 

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

func GlobalMetaDataAddCount 

func GlobalMetaDataAddCount(builder *flatbuffers.Builder, count uint32)

func GlobalMetaDataAddError 

func GlobalMetaDataAddError(builder *flatbuffers.Builder, error flatbuffers.UOffsetT)

func GlobalMetaDataAddMeta 

func GlobalMetaDataAddMeta(builder *flatbuffers.Builder, meta flatbuffers.UOffsetT)

func GlobalMetaDataAddPeriodMs 

func GlobalMetaDataAddPeriodMs(builder *flatbuffers.Builder, periodMs uint32)

func GlobalMetaDataAddStartMs 

func GlobalMetaDataAddStartMs(builder *flatbuffers.Builder, startMs uint64)

func GlobalMetaDataAddWarning 

func GlobalMetaDataAddWarning(builder *flatbuffers.Builder, warning flatbuffers.UOffsetT)

func GlobalMetaDataEnd 

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

func GlobalMetaDataPack 

func GlobalMetaDataPack(builder *flatbuffers.Builder, t *GlobalMetaDataT) flatbuffers.UOffsetT

func GlobalMetaDataStart 

func GlobalMetaDataStart(builder *flatbuffers.Builder)

func GlobalMetaDataStartErrorVector 

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

func GlobalMetaDataStartMetaVector 

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

func GlobalMetaDataStartWarningVector 

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

func HistSeriesAddValues 

func HistSeriesAddValues(builder *flatbuffers.Builder, values flatbuffers.UOffsetT)

func HistSeriesEnd 

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

func HistSeriesPack 

func HistSeriesPack(builder *flatbuffers.Builder, t *HistSeriesT) flatbuffers.UOffsetT

func HistSeriesStart 

func HistSeriesStart(builder *flatbuffers.Builder)

func HistSeriesStartValuesVector 

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

func HistogramAddBuckets 

func HistogramAddBuckets(builder *flatbuffers.Builder, buckets flatbuffers.UOffsetT)

func HistogramBucketAddCount 

func HistogramBucketAddCount(builder *flatbuffers.Builder, count uint64)

func HistogramBucketAddExp 

func HistogramBucketAddExp(builder *flatbuffers.Builder, exp int8)

func HistogramBucketAddVal 

func HistogramBucketAddVal(builder *flatbuffers.Builder, val int8)

func HistogramBucketEnd 

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

func HistogramBucketPack 

func HistogramBucketPack(builder *flatbuffers.Builder, t *HistogramBucketT) flatbuffers.UOffsetT

func HistogramBucketStart 

func HistogramBucketStart(builder *flatbuffers.Builder)

func HistogramEnd 

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

func HistogramPack 

func HistogramPack(builder *flatbuffers.Builder, t *HistogramT) flatbuffers.UOffsetT

func HistogramStart 

func HistogramStart(builder *flatbuffers.Builder)

func HistogramStartBucketsVector 

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

func KVPairAddKey 

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

func KVPairAddValue 

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

func KVPairEnd 

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

func KVPairPack 

func KVPairPack(builder *flatbuffers.Builder, t *KVPairT) flatbuffers.UOffsetT

func KVPairStart 

func KVPairStart(builder *flatbuffers.Builder)

func MetricHistogramResultAddHistogram 

func MetricHistogramResultAddHistogram(builder *flatbuffers.Builder, histogram flatbuffers.UOffsetT)

func MetricHistogramResultAddPeriod 

func MetricHistogramResultAddPeriod(builder *flatbuffers.Builder, period int32)

func MetricHistogramResultAddTimestamp 

func MetricHistogramResultAddTimestamp(builder *flatbuffers.Builder, timestamp uint64)

func MetricHistogramResultEnd 

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

func MetricHistogramResultListAddResults 

func MetricHistogramResultListAddResults(builder *flatbuffers.Builder, results flatbuffers.UOffsetT)

func MetricHistogramResultListEnd 

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

func MetricHistogramResultListPack 

func MetricHistogramResultListPack(builder *flatbuffers.Builder, t *MetricHistogramResultListT) flatbuffers.UOffsetT

func MetricHistogramResultListStart 

func MetricHistogramResultListStart(builder *flatbuffers.Builder)

func MetricHistogramResultListStartResultsVector 

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

func MetricHistogramResultPack 

func MetricHistogramResultPack(builder *flatbuffers.Builder, t *MetricHistogramResultT) flatbuffers.UOffsetT

func MetricHistogramResultStart 

func MetricHistogramResultStart(builder *flatbuffers.Builder)

func NumericSeriesAddValues 

func NumericSeriesAddValues(builder *flatbuffers.Builder, values flatbuffers.UOffsetT)

func NumericSeriesEnd 

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

func NumericSeriesPack 

func NumericSeriesPack(builder *flatbuffers.Builder, t *NumericSeriesT) flatbuffers.UOffsetT

func NumericSeriesStart 

func NumericSeriesStart(builder *flatbuffers.Builder)

func NumericSeriesStartValuesVector 

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

func ReduceRequestAddLabel 

func ReduceRequestAddLabel(builder *flatbuffers.Builder, label flatbuffers.UOffsetT)

func ReduceRequestAddMethod 

func ReduceRequestAddMethod(builder *flatbuffers.Builder, method flatbuffers.UOffsetT)

func ReduceRequestAddMethodParams 

func ReduceRequestAddMethodParams(builder *flatbuffers.Builder, methodParams flatbuffers.UOffsetT)

func ReduceRequestEnd 

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

func ReduceRequestPack 

func ReduceRequestPack(builder *flatbuffers.Builder, t *ReduceRequestT) flatbuffers.UOffsetT

func ReduceRequestStart 

func ReduceRequestStart(builder *flatbuffers.Builder)

func ReduceRequestStartMethodParamsVector 

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

func SeriesContainerAddData 

func SeriesContainerAddData(builder *flatbuffers.Builder, data flatbuffers.UOffsetT)

func SeriesContainerAddDataType 

func SeriesContainerAddDataType(builder *flatbuffers.Builder, dataType Series)

func SeriesContainerAddKind 

func SeriesContainerAddKind(builder *flatbuffers.Builder, kind Kind)

func SeriesContainerEnd 

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

func SeriesContainerPack 

func SeriesContainerPack(builder *flatbuffers.Builder, t *SeriesContainerT) flatbuffers.UOffsetT

func SeriesContainerStart 

func SeriesContainerStart(builder *flatbuffers.Builder)

func SeriesPack 

func SeriesPack(builder *flatbuffers.Builder, t *SeriesT) flatbuffers.UOffsetT

func StreamRequestAddCheckUuid 

func StreamRequestAddCheckUuid(builder *flatbuffers.Builder, checkUuid flatbuffers.UOffsetT)

func StreamRequestAddKind 

func StreamRequestAddKind(builder *flatbuffers.Builder, kind Kind)

func StreamRequestAddLabel 

func StreamRequestAddLabel(builder *flatbuffers.Builder, label flatbuffers.UOffsetT)

func StreamRequestAddName 

func StreamRequestAddName(builder *flatbuffers.Builder, name flatbuffers.UOffsetT)

func StreamRequestAddTransform 

func StreamRequestAddTransform(builder *flatbuffers.Builder, transform flatbuffers.UOffsetT)

func StreamRequestAddTransformParams 

func StreamRequestAddTransformParams(builder *flatbuffers.Builder, transformParams flatbuffers.UOffsetT)

func StreamRequestEnd 

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

func StreamRequestPack 

func StreamRequestPack(builder *flatbuffers.Builder, t *StreamRequestT) flatbuffers.UOffsetT

func StreamRequestStart 

func StreamRequestStart(builder *flatbuffers.Builder)

func StreamRequestStartCheckUuidVector 

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

func StreamRequestStartTransformParamsVector 

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

func TextEntryAddInternalOffsetMs 

func TextEntryAddInternalOffsetMs(builder *flatbuffers.Builder, internalOffsetMs uint64)

func TextEntryAddValue 

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

func TextEntryEnd 

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

func TextEntryPack 

func TextEntryPack(builder *flatbuffers.Builder, t *TextEntryT) flatbuffers.UOffsetT

func TextEntryStart 

func TextEntryStart(builder *flatbuffers.Builder)

func TextMultiValueAddEntries 

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

func TextMultiValueEnd 

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

func TextMultiValuePack 

func TextMultiValuePack(builder *flatbuffers.Builder, t *TextMultiValueT) flatbuffers.UOffsetT

func TextMultiValueStart 

func TextMultiValueStart(builder *flatbuffers.Builder)

func TextMultiValueStartEntriesVector 

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

func TextSeriesAddValues 

func TextSeriesAddValues(builder *flatbuffers.Builder, values flatbuffers.UOffsetT)

func TextSeriesEnd 

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

func TextSeriesPack 

func TextSeriesPack(builder *flatbuffers.Builder, t *TextSeriesT) flatbuffers.UOffsetT

func TextSeriesStart 

func TextSeriesStart(builder *flatbuffers.Builder)

func TextSeriesStartValuesVector 

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

Types

type ColumnMetaData 

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

func GetRootAsColumnMetaData 

func GetRootAsColumnMetaData(buf []byte, offset flatbuffers.UOffsetT) *ColumnMetaData

func (*ColumnMetaData) Init 

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

func (*ColumnMetaData) Label 

func (rcv *ColumnMetaData) Label() []byte

func (*ColumnMetaData) Meta 

func (rcv *ColumnMetaData) Meta(obj *KVPair, j int) bool

func (*ColumnMetaData) MetaLength 

func (rcv *ColumnMetaData) MetaLength() int

func (*ColumnMetaData) Table 

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

func (*ColumnMetaData) UnPack 

func (rcv *ColumnMetaData) UnPack() *ColumnMetaDataT

type ColumnMetaDataT 

type ColumnMetaDataT struct {
	Label string
	Meta  []*KVPairT
}

type DF4 

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

func GetRootAsDF4 

func GetRootAsDF4(buf []byte, offset flatbuffers.UOffsetT) *DF4

func (*DF4) Columns 

func (rcv *DF4) Columns(obj *SeriesContainer, j int) bool

func (*DF4) ColumnsLength 

func (rcv *DF4) ColumnsLength() int

func (*DF4) Head 

func (rcv *DF4) Head(obj *GlobalMetaData) *GlobalMetaData

func (*DF4) Init 

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

func (*DF4) Meta 

func (rcv *DF4) Meta(obj *ColumnMetaData, j int) bool

func (*DF4) MetaLength 

func (rcv *DF4) MetaLength() int

func (*DF4) MutateVersion 

func (rcv *DF4) MutateVersion(n uint32) bool

func (*DF4) Table 

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

func (*DF4) UnPack 

func (rcv *DF4) UnPack() *DF4T

func (*DF4) Version 

func (rcv *DF4) Version() uint32

type DF4T 

type DF4T struct {
	Version uint32
	Head    *GlobalMetaDataT
	Meta    []*ColumnMetaDataT
	Columns []*SeriesContainerT
}

type Fetch 

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

func GetRootAsFetch 

func GetRootAsFetch(buf []byte, offset flatbuffers.UOffsetT) *Fetch

func (*Fetch) Count 

func (rcv *Fetch) Count() uint32

func (*Fetch) Init 

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

func (*Fetch) MutateCount 

func (rcv *Fetch) MutateCount(n uint32) bool

func (*Fetch) MutatePeriodMs 

func (rcv *Fetch) MutatePeriodMs(n uint32) bool

func (*Fetch) MutateStartMs 

func (rcv *Fetch) MutateStartMs(n uint64) bool

func (*Fetch) PeriodMs 

func (rcv *Fetch) PeriodMs() uint32

func (*Fetch) Reduce 

func (rcv *Fetch) Reduce(obj *ReduceRequest, j int) bool

func (*Fetch) ReduceLength 

func (rcv *Fetch) ReduceLength() int

func (*Fetch) StartMs 

func (rcv *Fetch) StartMs() uint64

func (*Fetch) Streams 

func (rcv *Fetch) Streams(obj *StreamRequest, j int) bool

func (*Fetch) StreamsLength 

func (rcv *Fetch) StreamsLength() int

func (*Fetch) Table 

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

func (*Fetch) UnPack 

func (rcv *Fetch) UnPack() *FetchT

type FetchT 

type FetchT struct {
	StartMs  uint64
	PeriodMs uint32
	Count    uint32
	Streams  []*StreamRequestT
	Reduce   []*ReduceRequestT
}

type GlobalMetaData 

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

func GetRootAsGlobalMetaData 

func GetRootAsGlobalMetaData(buf []byte, offset flatbuffers.UOffsetT) *GlobalMetaData

func (*GlobalMetaData) Count 

func (rcv *GlobalMetaData) Count() uint32

func (*GlobalMetaData) Error 

func (rcv *GlobalMetaData) Error(j int) []byte

func (*GlobalMetaData) ErrorLength 

func (rcv *GlobalMetaData) ErrorLength() int

func (*GlobalMetaData) Init 

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

func (*GlobalMetaData) Meta 

func (rcv *GlobalMetaData) Meta(obj *KVPair, j int) bool

func (*GlobalMetaData) MetaLength 

func (rcv *GlobalMetaData) MetaLength() int

func (*GlobalMetaData) MutateCount 

func (rcv *GlobalMetaData) MutateCount(n uint32) bool

func (*GlobalMetaData) MutatePeriodMs 

func (rcv *GlobalMetaData) MutatePeriodMs(n uint32) bool

func (*GlobalMetaData) MutateStartMs 

func (rcv *GlobalMetaData) MutateStartMs(n uint64) bool

func (*GlobalMetaData) PeriodMs 

func (rcv *GlobalMetaData) PeriodMs() uint32

func (*GlobalMetaData) StartMs 

func (rcv *GlobalMetaData) StartMs() uint64

func (*GlobalMetaData) Table 

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

func (*GlobalMetaData) UnPack 

func (rcv *GlobalMetaData) UnPack() *GlobalMetaDataT

func (*GlobalMetaData) Warning 

func (rcv *GlobalMetaData) Warning(j int) []byte

func (*GlobalMetaData) WarningLength 

func (rcv *GlobalMetaData) WarningLength() int

type GlobalMetaDataT 

type GlobalMetaDataT struct {
	StartMs  uint64
	PeriodMs uint32
	Count    uint32
	Error    []string
	Warning  []string
	Meta     []*KVPairT
}

type HistSeries 

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

func GetRootAsHistSeries 

func GetRootAsHistSeries(buf []byte, offset flatbuffers.UOffsetT) *HistSeries

func (*HistSeries) Init 

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

func (*HistSeries) Table 

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

func (*HistSeries) UnPack 

func (rcv *HistSeries) UnPack() *HistSeriesT

func (*HistSeries) Values 

func (rcv *HistSeries) Values(obj *Histogram, j int) bool

func (*HistSeries) ValuesLength 

func (rcv *HistSeries) ValuesLength() int

type HistSeriesT 

type HistSeriesT struct {
	Values []*HistogramT
}

type Histogram 

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

func GetRootAsHistogram 

func GetRootAsHistogram(buf []byte, offset flatbuffers.UOffsetT) *Histogram

func (*Histogram) Buckets 

func (rcv *Histogram) Buckets(obj *HistogramBucket, j int) bool

func (*Histogram) BucketsLength 

func (rcv *Histogram) BucketsLength() int

func (*Histogram) Init 

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

func (*Histogram) Table 

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

func (*Histogram) UnPack 

func (rcv *Histogram) UnPack() *HistogramT

type HistogramBucket 

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

func GetRootAsHistogramBucket 

func GetRootAsHistogramBucket(buf []byte, offset flatbuffers.UOffsetT) *HistogramBucket

func (*HistogramBucket) Count 

func (rcv *HistogramBucket) Count() uint64

func (*HistogramBucket) Exp 

func (rcv *HistogramBucket) Exp() int8

func (*HistogramBucket) Init 

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

func (*HistogramBucket) MutateCount 

func (rcv *HistogramBucket) MutateCount(n uint64) bool

func (*HistogramBucket) MutateExp 

func (rcv *HistogramBucket) MutateExp(n int8) bool

func (*HistogramBucket) MutateVal 

func (rcv *HistogramBucket) MutateVal(n int8) bool

func (*HistogramBucket) Table 

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

func (*HistogramBucket) UnPack 

func (rcv *HistogramBucket) UnPack() *HistogramBucketT

func (*HistogramBucket) Val 

func (rcv *HistogramBucket) Val() int8

type HistogramBucketT 

type HistogramBucketT struct {
	Val   int8
	Exp   int8
	Count uint64
}

type HistogramT 

type HistogramT struct {
	Buckets []*HistogramBucketT
}

type KVPair 

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

func GetRootAsKVPair 

func GetRootAsKVPair(buf []byte, offset flatbuffers.UOffsetT) *KVPair

func (*KVPair) Init 

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

func (*KVPair) Key 

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

func (*KVPair) Table 

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

func (*KVPair) UnPack 

func (rcv *KVPair) UnPack() *KVPairT

func (*KVPair) Value 

func (rcv *KVPair) Value() []byte

type KVPairT 

type KVPairT struct {
	Key   string
	Value string
}

type Kind 

type Kind int8
const (
	KindUNKNOWN         Kind = 0
	KindNUMERIC         Kind = 1
	KindHIST            Kind = 2
	KindHIST_CUMULATIVE Kind = 3
	KindTEXT            Kind = 4
)

func (Kind) String 

func (v Kind) String() string

type MetricHistogramResult 

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

func GetRootAsMetricHistogramResult 

func GetRootAsMetricHistogramResult(buf []byte, offset flatbuffers.UOffsetT) *MetricHistogramResult

func (*MetricHistogramResult) Histogram 

func (rcv *MetricHistogramResult) Histogram(obj *Histogram) *Histogram

func (*MetricHistogramResult) Init 

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

func (*MetricHistogramResult) MutatePeriod 

func (rcv *MetricHistogramResult) MutatePeriod(n int32) bool

func (*MetricHistogramResult) MutateTimestamp 

func (rcv *MetricHistogramResult) MutateTimestamp(n uint64) bool

func (*MetricHistogramResult) Period 

func (rcv *MetricHistogramResult) Period() int32

func (*MetricHistogramResult) Table 

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

func (*MetricHistogramResult) Timestamp 

func (rcv *MetricHistogramResult) Timestamp() uint64

func (*MetricHistogramResult) UnPack 

func (rcv *MetricHistogramResult) UnPack() *MetricHistogramResultT

type MetricHistogramResultList 

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

func GetRootAsMetricHistogramResultList 

func GetRootAsMetricHistogramResultList(buf []byte, offset flatbuffers.UOffsetT) *MetricHistogramResultList

func (*MetricHistogramResultList) Init 

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

func (*MetricHistogramResultList) Results 

func (rcv *MetricHistogramResultList) Results(obj *MetricHistogramResult, j int) bool

func (*MetricHistogramResultList) ResultsLength 

func (rcv *MetricHistogramResultList) ResultsLength() int

func (*MetricHistogramResultList) Table 

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

func (*MetricHistogramResultList) UnPack 

func (rcv *MetricHistogramResultList) UnPack() *MetricHistogramResultListT

type MetricHistogramResultListT 

type MetricHistogramResultListT struct {
	Results []*MetricHistogramResultT
}

type MetricHistogramResultT 

type MetricHistogramResultT struct {
	Timestamp uint64
	Period    int32
	Histogram *HistogramT
}

type NumericSeries 

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

func GetRootAsNumericSeries 

func GetRootAsNumericSeries(buf []byte, offset flatbuffers.UOffsetT) *NumericSeries

func (*NumericSeries) Init 

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

func (*NumericSeries) MutateValues 

func (rcv *NumericSeries) MutateValues(j int, n float64) bool

func (*NumericSeries) Table 

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

func (*NumericSeries) UnPack 

func (rcv *NumericSeries) UnPack() *NumericSeriesT

func (*NumericSeries) Values 

func (rcv *NumericSeries) Values(j int) float64

func (*NumericSeries) ValuesLength 

func (rcv *NumericSeries) ValuesLength() int

type NumericSeriesT 

type NumericSeriesT struct {
	Values []float64
}

type ReduceRequest 

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

func GetRootAsReduceRequest 

func GetRootAsReduceRequest(buf []byte, offset flatbuffers.UOffsetT) *ReduceRequest

func (*ReduceRequest) Init 

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

func (*ReduceRequest) Label 

func (rcv *ReduceRequest) Label() []byte

func (*ReduceRequest) Method 

func (rcv *ReduceRequest) Method() []byte

func (*ReduceRequest) MethodParams 

func (rcv *ReduceRequest) MethodParams(j int) []byte

func (*ReduceRequest) MethodParamsLength 

func (rcv *ReduceRequest) MethodParamsLength() int

func (*ReduceRequest) Table 

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

func (*ReduceRequest) UnPack 

func (rcv *ReduceRequest) UnPack() *ReduceRequestT

type ReduceRequestT 

type ReduceRequestT struct {
	Label        string
	Method       string
	MethodParams []string
}

type Series 

type Series byte
const (
	SeriesNONE          Series = 0
	SeriesNumericSeries Series = 1
	SeriesHistSeries    Series = 2
	SeriesTextSeries    Series = 3
)

func (Series) String 

func (v Series) String() string

type SeriesContainer 

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

func GetRootAsSeriesContainer 

func GetRootAsSeriesContainer(buf []byte, offset flatbuffers.UOffsetT) *SeriesContainer

func (*SeriesContainer) Data 

func (rcv *SeriesContainer) Data(obj *flatbuffers.Table) bool

func (*SeriesContainer) DataType 

func (rcv *SeriesContainer) DataType() Series

func (*SeriesContainer) Init 

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

func (*SeriesContainer) Kind 

func (rcv *SeriesContainer) Kind() Kind

func (*SeriesContainer) MutateDataType 

func (rcv *SeriesContainer) MutateDataType(n Series) bool

func (*SeriesContainer) MutateKind 

func (rcv *SeriesContainer) MutateKind(n Kind) bool

func (*SeriesContainer) Table 

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

func (*SeriesContainer) UnPack 

func (rcv *SeriesContainer) UnPack() *SeriesContainerT

type SeriesContainerT 

type SeriesContainerT struct {
	Kind Kind
	Data *SeriesT
}

type SeriesT 

type SeriesT struct {
	Type  Series
	Value interface{}
}

func SeriesUnPack 

func SeriesUnPack(t Series, table flatbuffers.Table) *SeriesT

type StreamRequest 

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

func GetRootAsStreamRequest 

func GetRootAsStreamRequest(buf []byte, offset flatbuffers.UOffsetT) *StreamRequest

func (*StreamRequest) CheckUuid 

func (rcv *StreamRequest) CheckUuid(j int) byte

func (*StreamRequest) CheckUuidBytes 

func (rcv *StreamRequest) CheckUuidBytes() []byte

func (*StreamRequest) CheckUuidLength 

func (rcv *StreamRequest) CheckUuidLength() int

func (*StreamRequest) Init 

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

func (*StreamRequest) Kind 

func (rcv *StreamRequest) Kind() Kind

func (*StreamRequest) Label 

func (rcv *StreamRequest) Label() []byte

func (*StreamRequest) MutateCheckUuid 

func (rcv *StreamRequest) MutateCheckUuid(j int, n byte) bool

func (*StreamRequest) MutateKind 

func (rcv *StreamRequest) MutateKind(n Kind) bool

func (*StreamRequest) Name 

func (rcv *StreamRequest) Name() []byte

func (*StreamRequest) Table 

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

func (*StreamRequest) Transform 

func (rcv *StreamRequest) Transform() []byte

func (*StreamRequest) TransformParams 

func (rcv *StreamRequest) TransformParams(j int) []byte

func (*StreamRequest) TransformParamsLength 

func (rcv *StreamRequest) TransformParamsLength() int

func (*StreamRequest) UnPack 

func (rcv *StreamRequest) UnPack() *StreamRequestT

type StreamRequestT 

type StreamRequestT struct {
	CheckUuid       []byte
	Name            string
	Kind            Kind
	Transform       string
	TransformParams []string
	Label           string
}

type TextEntry 

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

func GetRootAsTextEntry 

func GetRootAsTextEntry(buf []byte, offset flatbuffers.UOffsetT) *TextEntry

func (*TextEntry) Init 

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

func (*TextEntry) InternalOffsetMs 

func (rcv *TextEntry) InternalOffsetMs() uint64

func (*TextEntry) MutateInternalOffsetMs 

func (rcv *TextEntry) MutateInternalOffsetMs(n uint64) bool

func (*TextEntry) Table 

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

func (*TextEntry) UnPack 

func (rcv *TextEntry) UnPack() *TextEntryT

func (*TextEntry) Value 

func (rcv *TextEntry) Value() []byte

type TextEntryT 

type TextEntryT struct {
	InternalOffsetMs uint64
	Value            string
}

type TextMultiValue 

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

func GetRootAsTextMultiValue 

func GetRootAsTextMultiValue(buf []byte, offset flatbuffers.UOffsetT) *TextMultiValue

func (*TextMultiValue) Entries 

func (rcv *TextMultiValue) Entries(obj *TextEntry, j int) bool

func (*TextMultiValue) EntriesLength 

func (rcv *TextMultiValue) EntriesLength() int

func (*TextMultiValue) Init 

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

func (*TextMultiValue) Table 

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

func (*TextMultiValue) UnPack 

func (rcv *TextMultiValue) UnPack() *TextMultiValueT

type TextMultiValueT 

type TextMultiValueT struct {
	Entries []*TextEntryT
}

type TextSeries 

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

func GetRootAsTextSeries 

func GetRootAsTextSeries(buf []byte, offset flatbuffers.UOffsetT) *TextSeries

func (*TextSeries) Init 

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

func (*TextSeries) Table 

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

func (*TextSeries) UnPack 

func (rcv *TextSeries) UnPack() *TextSeriesT

func (*TextSeries) Values 

func (rcv *TextSeries) Values(obj *TextMultiValue, j int) bool

func (*TextSeries) ValuesLength 

func (rcv *TextSeries) ValuesLength() int

type TextSeriesT 

type TextSeriesT struct {
	Values []*TextMultiValueT
}

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.