Versions in this module Expand all Collapse all v0 v0.2.0 Nov 23, 2023 Changes in this version + var Chunk_Encoding_name = map[int32]string + var Chunk_Encoding_value = map[string]int32 + var File_remote_proto protoreflect.FileDescriptor + var File_types_proto protoreflect.FileDescriptor + var Histogram_ResetHint_name = map[int32]string + var Histogram_ResetHint_value = map[string]int32 + var LabelMatcher_Type_name = map[int32]string + var LabelMatcher_Type_value = map[string]int32 + var MetricMetadata_MetricType_name = map[int32]string + var MetricMetadata_MetricType_value = map[string]int32 + var ReadRequest_ResponseType_name = map[int32]string + var ReadRequest_ResponseType_value = map[string]int32 + type BucketSpan struct + Length uint32 + Offset int32 + func (*BucketSpan) Descriptor() ([]byte, []int) + func (*BucketSpan) ProtoMessage() + func (m *BucketSpan) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *BucketSpan) MarshalToVT(dAtA []byte) (int, error) + func (m *BucketSpan) MarshalVT() (dAtA []byte, err error) + func (m *BucketSpan) SizeVT() (n int) + func (x *BucketSpan) GetLength() uint32 + func (x *BucketSpan) GetOffset() int32 + func (x *BucketSpan) ProtoReflect() protoreflect.Message + func (x *BucketSpan) Reset() + func (x *BucketSpan) String() string + type Chunk struct + Data []byte + MaxTimeMs int64 + MinTimeMs int64 + Type Chunk_Encoding + func (*Chunk) Descriptor() ([]byte, []int) + func (*Chunk) ProtoMessage() + func (m *Chunk) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Chunk) MarshalToVT(dAtA []byte) (int, error) + func (m *Chunk) MarshalVT() (dAtA []byte, err error) + func (m *Chunk) SizeVT() (n int) + func (x *Chunk) GetData() []byte + func (x *Chunk) GetMaxTimeMs() int64 + func (x *Chunk) GetMinTimeMs() int64 + func (x *Chunk) GetType() Chunk_Encoding + func (x *Chunk) ProtoReflect() protoreflect.Message + func (x *Chunk) Reset() + func (x *Chunk) String() string + type Chunk_Encoding int32 + const Chunk_FLOAT_HISTOGRAM + const Chunk_HISTOGRAM + const Chunk_UNKNOWN + const Chunk_XOR + func (Chunk_Encoding) Descriptor() protoreflect.EnumDescriptor + func (Chunk_Encoding) EnumDescriptor() ([]byte, []int) + func (Chunk_Encoding) Type() protoreflect.EnumType + func (x Chunk_Encoding) Enum() *Chunk_Encoding + func (x Chunk_Encoding) Number() protoreflect.EnumNumber + func (x Chunk_Encoding) String() string + type ChunkedReadResponse struct + ChunkedSeries []*ChunkedSeries + QueryIndex int64 + func (*ChunkedReadResponse) Descriptor() ([]byte, []int) + func (*ChunkedReadResponse) ProtoMessage() + func (m *ChunkedReadResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *ChunkedReadResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *ChunkedReadResponse) MarshalVT() (dAtA []byte, err error) + func (m *ChunkedReadResponse) SizeVT() (n int) + func (x *ChunkedReadResponse) GetChunkedSeries() []*ChunkedSeries + func (x *ChunkedReadResponse) GetQueryIndex() int64 + func (x *ChunkedReadResponse) ProtoReflect() protoreflect.Message + func (x *ChunkedReadResponse) Reset() + func (x *ChunkedReadResponse) String() string + type ChunkedSeries struct + Chunks []*Chunk + Labels []*Label + func (*ChunkedSeries) Descriptor() ([]byte, []int) + func (*ChunkedSeries) ProtoMessage() + func (m *ChunkedSeries) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *ChunkedSeries) MarshalToVT(dAtA []byte) (int, error) + func (m *ChunkedSeries) MarshalVT() (dAtA []byte, err error) + func (m *ChunkedSeries) SizeVT() (n int) + func (x *ChunkedSeries) GetChunks() []*Chunk + func (x *ChunkedSeries) GetLabels() []*Label + func (x *ChunkedSeries) ProtoReflect() protoreflect.Message + func (x *ChunkedSeries) Reset() + func (x *ChunkedSeries) String() string + type Exemplar struct + Labels []*Label + Timestamp int64 + Value float64 + func (*Exemplar) Descriptor() ([]byte, []int) + func (*Exemplar) ProtoMessage() + func (m *Exemplar) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Exemplar) MarshalToVT(dAtA []byte) (int, error) + func (m *Exemplar) MarshalVT() (dAtA []byte, err error) + func (m *Exemplar) SizeVT() (n int) + func (x *Exemplar) GetLabels() []*Label + func (x *Exemplar) GetTimestamp() int64 + func (x *Exemplar) GetValue() float64 + func (x *Exemplar) ProtoReflect() protoreflect.Message + func (x *Exemplar) Reset() + func (x *Exemplar) String() string + type Histogram struct + Count isHistogram_Count + NegativeCounts []float64 + NegativeDeltas []int64 + NegativeSpans []*BucketSpan + PositiveCounts []float64 + PositiveDeltas []int64 + PositiveSpans []*BucketSpan + ResetHint Histogram_ResetHint + Schema int32 + Sum float64 + Timestamp int64 + ZeroCount isHistogram_ZeroCount + ZeroThreshold float64 + func (*Histogram) Descriptor() ([]byte, []int) + func (*Histogram) ProtoMessage() + func (m *Histogram) GetCount() isHistogram_Count + func (m *Histogram) GetZeroCount() isHistogram_ZeroCount + func (m *Histogram) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Histogram) MarshalToVT(dAtA []byte) (int, error) + func (m *Histogram) MarshalVT() (dAtA []byte, err error) + func (m *Histogram) SizeVT() (n int) + func (x *Histogram) GetCountFloat() float64 + func (x *Histogram) GetCountInt() uint64 + func (x *Histogram) GetNegativeCounts() []float64 + func (x *Histogram) GetNegativeDeltas() []int64 + func (x *Histogram) GetNegativeSpans() []*BucketSpan + func (x *Histogram) GetPositiveCounts() []float64 + func (x *Histogram) GetPositiveDeltas() []int64 + func (x *Histogram) GetPositiveSpans() []*BucketSpan + func (x *Histogram) GetResetHint() Histogram_ResetHint + func (x *Histogram) GetSchema() int32 + func (x *Histogram) GetSum() float64 + func (x *Histogram) GetTimestamp() int64 + func (x *Histogram) GetZeroCountFloat() float64 + func (x *Histogram) GetZeroCountInt() uint64 + func (x *Histogram) GetZeroThreshold() float64 + func (x *Histogram) ProtoReflect() protoreflect.Message + func (x *Histogram) Reset() + func (x *Histogram) String() string + type Histogram_CountFloat struct + CountFloat float64 + func (m *Histogram_CountFloat) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Histogram_CountFloat) MarshalToVT(dAtA []byte) (int, error) + func (m *Histogram_CountFloat) SizeVT() (n int) + type Histogram_CountInt struct + CountInt uint64 + func (m *Histogram_CountInt) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Histogram_CountInt) MarshalToVT(dAtA []byte) (int, error) + func (m *Histogram_CountInt) SizeVT() (n int) + type Histogram_ResetHint int32 + const Histogram_GAUGE + const Histogram_NO + const Histogram_UNKNOWN + const Histogram_YES + func (Histogram_ResetHint) Descriptor() protoreflect.EnumDescriptor + func (Histogram_ResetHint) EnumDescriptor() ([]byte, []int) + func (Histogram_ResetHint) Type() protoreflect.EnumType + func (x Histogram_ResetHint) Enum() *Histogram_ResetHint + func (x Histogram_ResetHint) Number() protoreflect.EnumNumber + func (x Histogram_ResetHint) String() string + type Histogram_ZeroCountFloat struct + ZeroCountFloat float64 + func (m *Histogram_ZeroCountFloat) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Histogram_ZeroCountFloat) MarshalToVT(dAtA []byte) (int, error) + func (m *Histogram_ZeroCountFloat) SizeVT() (n int) + type Histogram_ZeroCountInt struct + ZeroCountInt uint64 + func (m *Histogram_ZeroCountInt) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Histogram_ZeroCountInt) MarshalToVT(dAtA []byte) (int, error) + func (m *Histogram_ZeroCountInt) SizeVT() (n int) + type Label struct + Name string + Value string + func (*Label) Descriptor() ([]byte, []int) + func (*Label) ProtoMessage() + func (m *Label) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Label) MarshalToVT(dAtA []byte) (int, error) + func (m *Label) MarshalVT() (dAtA []byte, err error) + func (m *Label) SizeVT() (n int) + func (x *Label) GetName() string + func (x *Label) GetValue() string + func (x *Label) ProtoReflect() protoreflect.Message + func (x *Label) Reset() + func (x *Label) String() string + type LabelMatcher struct + Name string + Type LabelMatcher_Type + Value string + func (*LabelMatcher) Descriptor() ([]byte, []int) + func (*LabelMatcher) ProtoMessage() + func (m *LabelMatcher) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *LabelMatcher) MarshalToVT(dAtA []byte) (int, error) + func (m *LabelMatcher) MarshalVT() (dAtA []byte, err error) + func (m *LabelMatcher) SizeVT() (n int) + func (x *LabelMatcher) GetName() string + func (x *LabelMatcher) GetType() LabelMatcher_Type + func (x *LabelMatcher) GetValue() string + func (x *LabelMatcher) ProtoReflect() protoreflect.Message + func (x *LabelMatcher) Reset() + func (x *LabelMatcher) String() string + type LabelMatcher_Type int32 + const LabelMatcher_EQ + const LabelMatcher_NEQ + const LabelMatcher_NRE + const LabelMatcher_RE + func (LabelMatcher_Type) Descriptor() protoreflect.EnumDescriptor + func (LabelMatcher_Type) EnumDescriptor() ([]byte, []int) + func (LabelMatcher_Type) Type() protoreflect.EnumType + func (x LabelMatcher_Type) Enum() *LabelMatcher_Type + func (x LabelMatcher_Type) Number() protoreflect.EnumNumber + func (x LabelMatcher_Type) String() string + type Labels struct + Labels []*Label + func (*Labels) Descriptor() ([]byte, []int) + func (*Labels) ProtoMessage() + func (m *Labels) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Labels) MarshalToVT(dAtA []byte) (int, error) + func (m *Labels) MarshalVT() (dAtA []byte, err error) + func (m *Labels) SizeVT() (n int) + func (x *Labels) GetLabels() []*Label + func (x *Labels) ProtoReflect() protoreflect.Message + func (x *Labels) Reset() + func (x *Labels) String() string + type MetricMetadata struct + Help string + MetricFamilyName string + Type MetricMetadata_MetricType + Unit string + func (*MetricMetadata) Descriptor() ([]byte, []int) + func (*MetricMetadata) ProtoMessage() + func (m *MetricMetadata) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *MetricMetadata) MarshalToVT(dAtA []byte) (int, error) + func (m *MetricMetadata) MarshalVT() (dAtA []byte, err error) + func (m *MetricMetadata) SizeVT() (n int) + func (x *MetricMetadata) GetHelp() string + func (x *MetricMetadata) GetMetricFamilyName() string + func (x *MetricMetadata) GetType() MetricMetadata_MetricType + func (x *MetricMetadata) GetUnit() string + func (x *MetricMetadata) ProtoReflect() protoreflect.Message + func (x *MetricMetadata) Reset() + func (x *MetricMetadata) String() string + type MetricMetadata_MetricType int32 + const MetricMetadata_COUNTER + const MetricMetadata_GAUGE + const MetricMetadata_GAUGEHISTOGRAM + const MetricMetadata_HISTOGRAM + const MetricMetadata_INFO + const MetricMetadata_STATESET + const MetricMetadata_SUMMARY + const MetricMetadata_UNKNOWN + func (MetricMetadata_MetricType) Descriptor() protoreflect.EnumDescriptor + func (MetricMetadata_MetricType) EnumDescriptor() ([]byte, []int) + func (MetricMetadata_MetricType) Type() protoreflect.EnumType + func (x MetricMetadata_MetricType) Enum() *MetricMetadata_MetricType + func (x MetricMetadata_MetricType) Number() protoreflect.EnumNumber + func (x MetricMetadata_MetricType) String() string + type Query struct + EndTimestampMs int64 + Hints *ReadHints + Matchers []*LabelMatcher + StartTimestampMs int64 + func (*Query) Descriptor() ([]byte, []int) + func (*Query) ProtoMessage() + func (m *Query) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Query) MarshalToVT(dAtA []byte) (int, error) + func (m *Query) MarshalVT() (dAtA []byte, err error) + func (m *Query) SizeVT() (n int) + func (x *Query) GetEndTimestampMs() int64 + func (x *Query) GetHints() *ReadHints + func (x *Query) GetMatchers() []*LabelMatcher + func (x *Query) GetStartTimestampMs() int64 + func (x *Query) ProtoReflect() protoreflect.Message + func (x *Query) Reset() + func (x *Query) String() string + type QueryResult struct + Timeseries []*TimeSeries + func (*QueryResult) Descriptor() ([]byte, []int) + func (*QueryResult) ProtoMessage() + func (m *QueryResult) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *QueryResult) MarshalToVT(dAtA []byte) (int, error) + func (m *QueryResult) MarshalVT() (dAtA []byte, err error) + func (m *QueryResult) SizeVT() (n int) + func (x *QueryResult) GetTimeseries() []*TimeSeries + func (x *QueryResult) ProtoReflect() protoreflect.Message + func (x *QueryResult) Reset() + func (x *QueryResult) String() string + type ReadHints struct + By bool + EndMs int64 + Func string + Grouping []string + RangeMs int64 + StartMs int64 + StepMs int64 + func (*ReadHints) Descriptor() ([]byte, []int) + func (*ReadHints) ProtoMessage() + func (m *ReadHints) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *ReadHints) MarshalToVT(dAtA []byte) (int, error) + func (m *ReadHints) MarshalVT() (dAtA []byte, err error) + func (m *ReadHints) SizeVT() (n int) + func (x *ReadHints) GetBy() bool + func (x *ReadHints) GetEndMs() int64 + func (x *ReadHints) GetFunc() string + func (x *ReadHints) GetGrouping() []string + func (x *ReadHints) GetRangeMs() int64 + func (x *ReadHints) GetStartMs() int64 + func (x *ReadHints) GetStepMs() int64 + func (x *ReadHints) ProtoReflect() protoreflect.Message + func (x *ReadHints) Reset() + func (x *ReadHints) String() string + type ReadRequest struct + AcceptedResponseTypes []ReadRequest_ResponseType + Queries []*Query + func (*ReadRequest) Descriptor() ([]byte, []int) + func (*ReadRequest) ProtoMessage() + func (m *ReadRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *ReadRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *ReadRequest) MarshalVT() (dAtA []byte, err error) + func (m *ReadRequest) SizeVT() (n int) + func (x *ReadRequest) GetAcceptedResponseTypes() []ReadRequest_ResponseType + func (x *ReadRequest) GetQueries() []*Query + func (x *ReadRequest) ProtoReflect() protoreflect.Message + func (x *ReadRequest) Reset() + func (x *ReadRequest) String() string + type ReadRequest_ResponseType int32 + const ReadRequest_SAMPLES + const ReadRequest_STREAMED_XOR_CHUNKS + func (ReadRequest_ResponseType) Descriptor() protoreflect.EnumDescriptor + func (ReadRequest_ResponseType) EnumDescriptor() ([]byte, []int) + func (ReadRequest_ResponseType) Type() protoreflect.EnumType + func (x ReadRequest_ResponseType) Enum() *ReadRequest_ResponseType + func (x ReadRequest_ResponseType) Number() protoreflect.EnumNumber + func (x ReadRequest_ResponseType) String() string + type ReadResponse struct + Results []*QueryResult + func (*ReadResponse) Descriptor() ([]byte, []int) + func (*ReadResponse) ProtoMessage() + func (m *ReadResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *ReadResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *ReadResponse) MarshalVT() (dAtA []byte, err error) + func (m *ReadResponse) SizeVT() (n int) + func (x *ReadResponse) GetResults() []*QueryResult + func (x *ReadResponse) ProtoReflect() protoreflect.Message + func (x *ReadResponse) Reset() + func (x *ReadResponse) String() string + type Sample struct + Timestamp int64 + Value float64 + func (*Sample) Descriptor() ([]byte, []int) + func (*Sample) ProtoMessage() + func (m *Sample) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Sample) MarshalToVT(dAtA []byte) (int, error) + func (m *Sample) MarshalVT() (dAtA []byte, err error) + func (m *Sample) SizeVT() (n int) + func (x *Sample) GetTimestamp() int64 + func (x *Sample) GetValue() float64 + func (x *Sample) ProtoReflect() protoreflect.Message + func (x *Sample) Reset() + func (x *Sample) String() string + type TimeSeries struct + Exemplars []*Exemplar + Histograms []*Histogram + Labels []*Label + Samples []*Sample + func (*TimeSeries) Descriptor() ([]byte, []int) + func (*TimeSeries) ProtoMessage() + func (m *TimeSeries) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *TimeSeries) MarshalToVT(dAtA []byte) (int, error) + func (m *TimeSeries) MarshalVT() (dAtA []byte, err error) + func (m *TimeSeries) SizeVT() (n int) + func (x *TimeSeries) GetExemplars() []*Exemplar + func (x *TimeSeries) GetHistograms() []*Histogram + func (x *TimeSeries) GetLabels() []*Label + func (x *TimeSeries) GetSamples() []*Sample + func (x *TimeSeries) ProtoReflect() protoreflect.Message + func (x *TimeSeries) Reset() + func (x *TimeSeries) String() string + type WriteRequest struct + Metadata []*MetricMetadata + Timeseries []*TimeSeries + func (*WriteRequest) Descriptor() ([]byte, []int) + func (*WriteRequest) ProtoMessage() + func (m *WriteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *WriteRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *WriteRequest) MarshalVT() (dAtA []byte, err error) + func (m *WriteRequest) SizeVT() (n int) + func (x *WriteRequest) GetMetadata() []*MetricMetadata + func (x *WriteRequest) GetTimeseries() []*TimeSeries + func (x *WriteRequest) ProtoReflect() protoreflect.Message + func (x *WriteRequest) Reset() + func (x *WriteRequest) String() string v0.1.0 Oct 7, 2023