prompb

package
v0.35.0 Latest Latest
Warning

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

 Go to latest Published: May 2, 2024 License: Apache-2.0 Imports: 11 Imported by: 5

README

NOTE(bwplotka): This excerpt of "github.com/prometheus/prometheus/prompb" reconstructed to avoid XXX fields for unsafe conversion to safe allocs.

Controlled by make proto

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRemote        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRemote          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRemote = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Chunk_Encoding_name = map[int32]string{
	0: "UNKNOWN",
	1: "XOR",
	2: "HISTOGRAM",
	3: "FLOAT_HISTOGRAM",
}
View Source 
var Chunk_Encoding_value = map[string]int32{
	"UNKNOWN":         0,
	"XOR":             1,
	"HISTOGRAM":       2,
	"FLOAT_HISTOGRAM": 3,
}
View Source 
var Histogram_ResetHint_name = map[int32]string{
	0: "UNKNOWN",
	1: "YES",
	2: "NO",
	3: "GAUGE",
}
View Source 
var Histogram_ResetHint_value = map[string]int32{
	"UNKNOWN": 0,
	"YES":     1,
	"NO":      2,
	"GAUGE":   3,
}
View Source 
var LabelMatcher_Type_name = map[int32]string{
	0: "EQ",
	1: "NEQ",
	2: "RE",
	3: "NRE",
}
View Source 
var LabelMatcher_Type_value = map[string]int32{
	"EQ":  0,
	"NEQ": 1,
	"RE":  2,
	"NRE": 3,
}
View Source 
var MetricMetadata_MetricType_name = map[int32]string{
	0: "UNKNOWN",
	1: "COUNTER",
	2: "GAUGE",
	3: "HISTOGRAM",
	4: "GAUGEHISTOGRAM",
	5: "SUMMARY",
	6: "INFO",
	7: "STATESET",
}
View Source 
var MetricMetadata_MetricType_value = map[string]int32{
	"UNKNOWN":        0,
	"COUNTER":        1,
	"GAUGE":          2,
	"HISTOGRAM":      3,
	"GAUGEHISTOGRAM": 4,
	"SUMMARY":        5,
	"INFO":           6,
	"STATESET":       7,
}
View Source 
var ReadRequest_ResponseType_name = map[int32]string{
	0: "SAMPLES",
	1: "STREAMED_XOR_CHUNKS",
}
View Source 
var ReadRequest_ResponseType_value = map[string]int32{
	"SAMPLES":             0,
	"STREAMED_XOR_CHUNKS": 1,
}

Functions

func FloatHistogramProtoToFloatHistogram added in v0.32.0 

func FloatHistogramProtoToFloatHistogram(hp Histogram) *histogram.FloatHistogram

FloatHistogramToHistogramProto converts a float histogram to a protobuf type. Copied from https://github.com/prometheus/prometheus/blob/0ab95536115adfe50af249d36d73674be694ca3f/storage/remote/codec.go#L647-L667

func FromProtoHistogram added in v0.34.0 

func FromProtoHistogram(h Histogram) *histogram.FloatHistogram

func HistogramProtoToFloatHistogram added in v0.32.0 

func HistogramProtoToFloatHistogram(hp Histogram) *histogram.FloatHistogram

HistogramProtoToFloatHistogram extracts a (normal integer) Histogram from the provided proto message to a Float Histogram. The caller has to make sure that the proto message represents an float histogram and not a integer histogram. Copied from https://github.com/prometheus/prometheus/blob/0ab95536115adfe50af249d36d73674be694ca3f/storage/remote/codec.go#L669-L688

func HistogramProtoToHistogram added in v0.32.0 

func HistogramProtoToHistogram(hp Histogram) *histogram.Histogram

HistogramProtoToHistogram extracts a (normal integer) Histogram from the provided proto message. The caller has to make sure that the proto message represents an interger histogram and not a float histogram. Copied from https://github.com/prometheus/prometheus/blob/0ab95536115adfe50af249d36d73674be694ca3f/storage/remote/codec.go#L626-L645

func SamplesFromPromqlSamples added in v0.32.0 

func SamplesFromPromqlSamples(samples ...promql.Sample) ([]Sample, []Histogram)

SamplesFromPromqlSamples converts a slice of promql.Sample to a slice of Sample.

func SamplesFromPromqlSeries added in v0.32.0 

func SamplesFromPromqlSeries(series promql.Series) ([]Sample, []Histogram)

SamplesFromPromqlSeries converts promql.Series to a slice of Sample and a slice of Histogram.

Types

type BucketSpan added in v0.31.0 

type BucketSpan struct {
	Offset int32  `protobuf:"zigzag32,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Length uint32 `protobuf:"varint,2,opt,name=length,proto3" json:"length,omitempty"`
}

A BucketSpan defines a number of consecutive buckets with their offset. Logically, it would be more straightforward to include the bucket counts in the Span. However, the protobuf representation is more compact in the way the data is structured here (with all the buckets in a single array separate from the Spans).

func (*BucketSpan) Descriptor added in v0.31.0 

func (*BucketSpan) Descriptor() ([]byte, []int)

func (*BucketSpan) GetLength added in v0.31.0 

func (m *BucketSpan) GetLength() uint32

func (*BucketSpan) GetOffset added in v0.31.0 

func (m *BucketSpan) GetOffset() int32

func (*BucketSpan) Marshal added in v0.31.0 

func (m *BucketSpan) Marshal() (dAtA []byte, err error)

func (*BucketSpan) MarshalTo added in v0.31.0 

func (m *BucketSpan) MarshalTo(dAtA []byte) (int, error)

func (*BucketSpan) MarshalToSizedBuffer added in v0.31.0 

func (m *BucketSpan) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BucketSpan) ProtoMessage added in v0.31.0 

func (*BucketSpan) ProtoMessage()

func (*BucketSpan) Reset added in v0.31.0 

func (m *BucketSpan) Reset()

func (*BucketSpan) Size added in v0.31.0 

func (m *BucketSpan) Size() (n int)

func (*BucketSpan) String added in v0.31.0 

func (m *BucketSpan) String() string

func (*BucketSpan) Unmarshal added in v0.31.0 

func (m *BucketSpan) Unmarshal(dAtA []byte) error

func (*BucketSpan) XXX_DiscardUnknown added in v0.31.0 

func (m *BucketSpan) XXX_DiscardUnknown()

func (*BucketSpan) XXX_Marshal added in v0.31.0 

func (m *BucketSpan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BucketSpan) XXX_Merge added in v0.31.0 

func (m *BucketSpan) XXX_Merge(src proto.Message)

func (*BucketSpan) XXX_Size added in v0.31.0 

func (m *BucketSpan) XXX_Size() int

func (*BucketSpan) XXX_Unmarshal added in v0.31.0 

func (m *BucketSpan) XXX_Unmarshal(b []byte) error

type Chunk 

type Chunk struct {
	MinTimeMs int64          `protobuf:"varint,1,opt,name=min_time_ms,json=minTimeMs,proto3" json:"min_time_ms,omitempty"`
	MaxTimeMs int64          `protobuf:"varint,2,opt,name=max_time_ms,json=maxTimeMs,proto3" json:"max_time_ms,omitempty"`
	Type      Chunk_Encoding `protobuf:"varint,3,opt,name=type,proto3,enum=prometheus_copy.Chunk_Encoding" json:"type,omitempty"`
	Data      []byte         `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
}

Chunk represents a TSDB chunk. Time range [min, max] is inclusive.

func (*Chunk) Descriptor 

func (*Chunk) Descriptor() ([]byte, []int)

func (*Chunk) GetData 

func (m *Chunk) GetData() []byte

func (*Chunk) GetMaxTimeMs 

func (m *Chunk) GetMaxTimeMs() int64

func (*Chunk) GetMinTimeMs 

func (m *Chunk) GetMinTimeMs() int64

func (*Chunk) GetType 

func (m *Chunk) GetType() Chunk_Encoding

func (*Chunk) Marshal 

func (m *Chunk) Marshal() (dAtA []byte, err error)

func (*Chunk) MarshalTo 

func (m *Chunk) MarshalTo(dAtA []byte) (int, error)

func (*Chunk) MarshalToSizedBuffer 

func (m *Chunk) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Chunk) ProtoMessage 

func (*Chunk) ProtoMessage()

func (*Chunk) Reset 

func (m *Chunk) Reset()

func (*Chunk) Size 

func (m *Chunk) Size() (n int)

func (*Chunk) String 

func (m *Chunk) String() string

func (*Chunk) Unmarshal 

func (m *Chunk) Unmarshal(dAtA []byte) error

func (*Chunk) XXX_DiscardUnknown 

func (m *Chunk) XXX_DiscardUnknown()

func (*Chunk) XXX_Marshal 

func (m *Chunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Chunk) XXX_Merge 

func (m *Chunk) XXX_Merge(src proto.Message)

func (*Chunk) XXX_Size 

func (m *Chunk) XXX_Size() int

func (*Chunk) XXX_Unmarshal 

func (m *Chunk) XXX_Unmarshal(b []byte) error

type Chunk_Encoding 

type Chunk_Encoding int32

We require this to match chunkenc.Encoding. 

const (
	Chunk_UNKNOWN         Chunk_Encoding = 0
	Chunk_XOR             Chunk_Encoding = 1
	Chunk_HISTOGRAM       Chunk_Encoding = 2
	Chunk_FLOAT_HISTOGRAM Chunk_Encoding = 3
)

func (Chunk_Encoding) EnumDescriptor 

func (Chunk_Encoding) EnumDescriptor() ([]byte, []int)

func (Chunk_Encoding) String 

func (x Chunk_Encoding) String() string

type ChunkedReadResponse 

type ChunkedReadResponse struct {
	ChunkedSeries []*ChunkedSeries `protobuf:"bytes,1,rep,name=chunked_series,json=chunkedSeries,proto3" json:"chunked_series,omitempty"`
	// query_index represents an index of the query from ReadRequest.queries these chunks relates to.
	QueryIndex int64 `protobuf:"varint,2,opt,name=query_index,json=queryIndex,proto3" json:"query_index,omitempty"`
}

ChunkedReadResponse is a response when response_type equals STREAMED_XOR_CHUNKS. We strictly stream full series after series, optionally split by time. This means that a single frame can contain partition of the single series, but once a new series is started to be streamed it means that no more chunks will be sent for previous one.

func (*ChunkedReadResponse) Descriptor 

func (*ChunkedReadResponse) Descriptor() ([]byte, []int)

func (*ChunkedReadResponse) GetChunkedSeries 

func (m *ChunkedReadResponse) GetChunkedSeries() []*ChunkedSeries

func (*ChunkedReadResponse) GetQueryIndex 

func (m *ChunkedReadResponse) GetQueryIndex() int64

func (*ChunkedReadResponse) Marshal 

func (m *ChunkedReadResponse) Marshal() (dAtA []byte, err error)

func (*ChunkedReadResponse) MarshalTo 

func (m *ChunkedReadResponse) MarshalTo(dAtA []byte) (int, error)

func (*ChunkedReadResponse) MarshalToSizedBuffer 

func (m *ChunkedReadResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChunkedReadResponse) ProtoMessage 

func (*ChunkedReadResponse) ProtoMessage()

func (*ChunkedReadResponse) Reset 

func (m *ChunkedReadResponse) Reset()

func (*ChunkedReadResponse) Size 

func (m *ChunkedReadResponse) Size() (n int)

func (*ChunkedReadResponse) String 

func (m *ChunkedReadResponse) String() string

func (*ChunkedReadResponse) Unmarshal 

func (m *ChunkedReadResponse) Unmarshal(dAtA []byte) error

func (*ChunkedReadResponse) XXX_DiscardUnknown 

func (m *ChunkedReadResponse) XXX_DiscardUnknown()

func (*ChunkedReadResponse) XXX_Marshal 

func (m *ChunkedReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChunkedReadResponse) XXX_Merge 

func (m *ChunkedReadResponse) XXX_Merge(src proto.Message)

func (*ChunkedReadResponse) XXX_Size 

func (m *ChunkedReadResponse) XXX_Size() int

func (*ChunkedReadResponse) XXX_Unmarshal 

func (m *ChunkedReadResponse) XXX_Unmarshal(b []byte) error

type ChunkedSeries 

type ChunkedSeries struct {
	// Labels should be sorted.
	Labels []github_com_thanos_io_thanos_pkg_store_labelpb.ZLabel `protobuf:"bytes,1,rep,name=labels,proto3,customtype=github.com/thanos-io/thanos/pkg/store/labelpb.ZLabel" json:"labels"`
	// Chunks will be in start time order and may overlap.
	Chunks []Chunk `protobuf:"bytes,2,rep,name=chunks,proto3" json:"chunks"`
}

ChunkedSeries represents single, encoded time series.

func (*ChunkedSeries) Descriptor 

func (*ChunkedSeries) Descriptor() ([]byte, []int)

func (*ChunkedSeries) GetChunks 

func (m *ChunkedSeries) GetChunks() []Chunk

func (*ChunkedSeries) Marshal 

func (m *ChunkedSeries) Marshal() (dAtA []byte, err error)

func (*ChunkedSeries) MarshalTo 

func (m *ChunkedSeries) MarshalTo(dAtA []byte) (int, error)

func (*ChunkedSeries) MarshalToSizedBuffer 

func (m *ChunkedSeries) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChunkedSeries) ProtoMessage 

func (*ChunkedSeries) ProtoMessage()

func (*ChunkedSeries) Reset 

func (m *ChunkedSeries) Reset()

func (*ChunkedSeries) Size 

func (m *ChunkedSeries) Size() (n int)

func (*ChunkedSeries) String 

func (m *ChunkedSeries) String() string

func (*ChunkedSeries) Unmarshal 

func (m *ChunkedSeries) Unmarshal(dAtA []byte) error

func (*ChunkedSeries) XXX_DiscardUnknown 

func (m *ChunkedSeries) XXX_DiscardUnknown()

func (*ChunkedSeries) XXX_Marshal 

func (m *ChunkedSeries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChunkedSeries) XXX_Merge 

func (m *ChunkedSeries) XXX_Merge(src proto.Message)

func (*ChunkedSeries) XXX_Size 

func (m *ChunkedSeries) XXX_Size() int

func (*ChunkedSeries) XXX_Unmarshal 

func (m *ChunkedSeries) XXX_Unmarshal(b []byte) error

type Exemplar added in v0.21.0 

type Exemplar struct {
	// Optional, can be empty.
	Labels []github_com_thanos_io_thanos_pkg_store_labelpb.ZLabel `protobuf:"bytes,1,rep,name=labels,proto3,customtype=github.com/thanos-io/thanos/pkg/store/labelpb.ZLabel" json:"labels"`
	Value  float64                                                `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
	// timestamp is in ms format, see pkg/timestamp/timestamp.go for
	// conversion from time.Time to Prometheus timestamp.
	Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

func (*Exemplar) Descriptor added in v0.21.0 

func (*Exemplar) Descriptor() ([]byte, []int)

func (*Exemplar) GetTimestamp added in v0.21.0 

func (m *Exemplar) GetTimestamp() int64

func (*Exemplar) GetValue added in v0.21.0 

func (m *Exemplar) GetValue() float64

func (*Exemplar) Marshal added in v0.21.0 

func (m *Exemplar) Marshal() (dAtA []byte, err error)

func (*Exemplar) MarshalTo added in v0.21.0 

func (m *Exemplar) MarshalTo(dAtA []byte) (int, error)

func (*Exemplar) MarshalToSizedBuffer added in v0.21.0 

func (m *Exemplar) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Exemplar) ProtoMessage added in v0.21.0 

func (*Exemplar) ProtoMessage()

func (*Exemplar) Reset added in v0.21.0 

func (m *Exemplar) Reset()

func (*Exemplar) Size added in v0.21.0 

func (m *Exemplar) Size() (n int)

func (*Exemplar) String added in v0.21.0 

func (m *Exemplar) String() string

func (*Exemplar) Unmarshal added in v0.21.0 

func (m *Exemplar) Unmarshal(dAtA []byte) error

func (*Exemplar) XXX_DiscardUnknown added in v0.21.0 

func (m *Exemplar) XXX_DiscardUnknown()

func (*Exemplar) XXX_Marshal added in v0.21.0 

func (m *Exemplar) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Exemplar) XXX_Merge added in v0.21.0 

func (m *Exemplar) XXX_Merge(src proto.Message)

func (*Exemplar) XXX_Size added in v0.21.0 

func (m *Exemplar) XXX_Size() int

func (*Exemplar) XXX_Unmarshal added in v0.21.0 

func (m *Exemplar) XXX_Unmarshal(b []byte) error

type Histogram added in v0.31.0 

type Histogram struct {
	// Types that are valid to be assigned to Count:
	//
	//	*Histogram_CountInt
	//	*Histogram_CountFloat
	Count isHistogram_Count `protobuf_oneof:"count"`
	Sum   float64           `protobuf:"fixed64,3,opt,name=sum,proto3" json:"sum,omitempty"`
	// The schema defines the bucket schema. Currently, valid numbers
	// are -4 <= n <= 8. They are all for base-2 bucket schemas, where 1
	// is a bucket boundary in each case, and then each power of two is
	// divided into 2^n logarithmic buckets. Or in other words, each
	// bucket boundary is the previous boundary times 2^(2^-n). In the
	// future, more bucket schemas may be added using numbers < -4 or >
	// 8.
	Schema        int32   `protobuf:"zigzag32,4,opt,name=schema,proto3" json:"schema,omitempty"`
	ZeroThreshold float64 `protobuf:"fixed64,5,opt,name=zero_threshold,json=zeroThreshold,proto3" json:"zero_threshold,omitempty"`
	// Types that are valid to be assigned to ZeroCount:
	//
	//	*Histogram_ZeroCountInt
	//	*Histogram_ZeroCountFloat
	ZeroCount isHistogram_ZeroCount `protobuf_oneof:"zero_count"`
	// Negative Buckets.
	NegativeSpans []BucketSpan `protobuf:"bytes,8,rep,name=negative_spans,json=negativeSpans,proto3" json:"negative_spans"`
	// Use either "negative_deltas" or "negative_counts", the former for
	// regular histograms with integer counts, the latter for float
	// histograms.
	NegativeDeltas []int64   `protobuf:"zigzag64,9,rep,packed,name=negative_deltas,json=negativeDeltas,proto3" json:"negative_deltas,omitempty"`
	NegativeCounts []float64 `protobuf:"fixed64,10,rep,packed,name=negative_counts,json=negativeCounts,proto3" json:"negative_counts,omitempty"`
	// Positive Buckets.
	PositiveSpans []BucketSpan `protobuf:"bytes,11,rep,name=positive_spans,json=positiveSpans,proto3" json:"positive_spans"`
	// Use either "positive_deltas" or "positive_counts", the former for
	// regular histograms with integer counts, the latter for float
	// histograms.
	PositiveDeltas []int64             `protobuf:"zigzag64,12,rep,packed,name=positive_deltas,json=positiveDeltas,proto3" json:"positive_deltas,omitempty"`
	PositiveCounts []float64           `protobuf:"fixed64,13,rep,packed,name=positive_counts,json=positiveCounts,proto3" json:"positive_counts,omitempty"`
	ResetHint      Histogram_ResetHint `` /* 131-byte string literal not displayed */
	// timestamp is in ms format, see model/timestamp/timestamp.go for
	// conversion from time.Time to Prometheus timestamp.
	Timestamp int64 `protobuf:"varint,15,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

A native histogram, also known as a sparse histogram. Original design doc: https://docs.google.com/document/d/1cLNv3aufPZb3fNfaJgdaRBZsInZKKIHo9E6HinJVbpM/edit The appendix of this design doc also explains the concept of float histograms. This Histogram message can represent both, the usual integer histogram as well as a float histogram.

func FloatHistogramToHistogramProto added in v0.32.0 

func FloatHistogramToHistogramProto(timestamp int64, fh *histogram.FloatHistogram) Histogram

Copied from https://github.com/prometheus/prometheus/blob/0ab95536115adfe50af249d36d73674be694ca3f/storage/remote/codec.go#L725-L739

func HistogramToHistogramProto added in v0.32.0 

func HistogramToHistogramProto(timestamp int64, h *histogram.Histogram) Histogram

Copied from https://github.com/prometheus/prometheus/blob/0ab95536115adfe50af249d36d73674be694ca3f/storage/remote/codec.go#L709-L723

func (*Histogram) Descriptor added in v0.31.0 

func (*Histogram) Descriptor() ([]byte, []int)

func (*Histogram) GetCount added in v0.31.0 

func (m *Histogram) GetCount() isHistogram_Count

func (*Histogram) GetCountFloat added in v0.31.0 

func (m *Histogram) GetCountFloat() float64

func (*Histogram) GetCountInt added in v0.31.0 

func (m *Histogram) GetCountInt() uint64

func (*Histogram) GetNegativeCounts added in v0.31.0 

func (m *Histogram) GetNegativeCounts() []float64

func (*Histogram) GetNegativeDeltas added in v0.31.0 

func (m *Histogram) GetNegativeDeltas() []int64

func (*Histogram) GetNegativeSpans added in v0.31.0 

func (m *Histogram) GetNegativeSpans() []BucketSpan

func (*Histogram) GetPositiveCounts added in v0.31.0 

func (m *Histogram) GetPositiveCounts() []float64

func (*Histogram) GetPositiveDeltas added in v0.31.0 

func (m *Histogram) GetPositiveDeltas() []int64

func (*Histogram) GetPositiveSpans added in v0.31.0 

func (m *Histogram) GetPositiveSpans() []BucketSpan

func (*Histogram) GetResetHint added in v0.31.0 

func (m *Histogram) GetResetHint() Histogram_ResetHint

func (*Histogram) GetSchema added in v0.31.0 

func (m *Histogram) GetSchema() int32

func (*Histogram) GetSum added in v0.31.0 

func (m *Histogram) GetSum() float64

func (*Histogram) GetTimestamp added in v0.31.0 

func (m *Histogram) GetTimestamp() int64

func (*Histogram) GetZeroCount added in v0.31.0 

func (m *Histogram) GetZeroCount() isHistogram_ZeroCount

func (*Histogram) GetZeroCountFloat added in v0.31.0 

func (m *Histogram) GetZeroCountFloat() float64

func (*Histogram) GetZeroCountInt added in v0.31.0 

func (m *Histogram) GetZeroCountInt() uint64

func (*Histogram) GetZeroThreshold added in v0.31.0 

func (m *Histogram) GetZeroThreshold() float64

func (Histogram) IsFloatHistogram added in v0.32.0 

func (h Histogram) IsFloatHistogram() bool

func (*Histogram) Marshal added in v0.31.0 

func (m *Histogram) Marshal() (dAtA []byte, err error)

func (*Histogram) MarshalTo added in v0.31.0 

func (m *Histogram) MarshalTo(dAtA []byte) (int, error)

func (*Histogram) MarshalToSizedBuffer added in v0.31.0 

func (m *Histogram) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Histogram) ProtoMessage added in v0.31.0 

func (*Histogram) ProtoMessage()

func (*Histogram) Reset added in v0.31.0 

func (m *Histogram) Reset()

func (*Histogram) Size added in v0.31.0 

func (m *Histogram) Size() (n int)

func (*Histogram) String added in v0.31.0 

func (m *Histogram) String() string

func (*Histogram) Unmarshal added in v0.31.0 

func (m *Histogram) Unmarshal(dAtA []byte) error

func (*Histogram) XXX_DiscardUnknown added in v0.31.0 

func (m *Histogram) XXX_DiscardUnknown()

func (*Histogram) XXX_Marshal added in v0.31.0 

func (m *Histogram) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Histogram) XXX_Merge added in v0.31.0 

func (m *Histogram) XXX_Merge(src proto.Message)

func (*Histogram) XXX_OneofWrappers added in v0.31.0 

func (*Histogram) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Histogram) XXX_Size added in v0.31.0 

func (m *Histogram) XXX_Size() int

func (*Histogram) XXX_Unmarshal added in v0.31.0 

func (m *Histogram) XXX_Unmarshal(b []byte) error

type Histogram_CountFloat added in v0.31.0 

type Histogram_CountFloat struct {
	CountFloat float64 `protobuf:"fixed64,2,opt,name=count_float,json=countFloat,proto3,oneof" json:"count_float,omitempty"`
}

func (*Histogram_CountFloat) MarshalTo added in v0.31.0 

func (m *Histogram_CountFloat) MarshalTo(dAtA []byte) (int, error)

func (*Histogram_CountFloat) MarshalToSizedBuffer added in v0.31.0 

func (m *Histogram_CountFloat) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Histogram_CountFloat) Size added in v0.31.0 

func (m *Histogram_CountFloat) Size() (n int)

type Histogram_CountInt added in v0.31.0 

type Histogram_CountInt struct {
	CountInt uint64 `protobuf:"varint,1,opt,name=count_int,json=countInt,proto3,oneof" json:"count_int,omitempty"`
}

func (*Histogram_CountInt) MarshalTo added in v0.31.0 

func (m *Histogram_CountInt) MarshalTo(dAtA []byte) (int, error)

func (*Histogram_CountInt) MarshalToSizedBuffer added in v0.31.0 

func (m *Histogram_CountInt) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Histogram_CountInt) Size added in v0.31.0 

func (m *Histogram_CountInt) Size() (n int)

type Histogram_ResetHint added in v0.31.0 

type Histogram_ResetHint int32
const (
	Histogram_UNKNOWN Histogram_ResetHint = 0
	Histogram_YES     Histogram_ResetHint = 1
	Histogram_NO      Histogram_ResetHint = 2
	Histogram_GAUGE   Histogram_ResetHint = 3
)

func (Histogram_ResetHint) EnumDescriptor added in v0.31.0 

func (Histogram_ResetHint) EnumDescriptor() ([]byte, []int)

func (Histogram_ResetHint) String added in v0.31.0 

func (x Histogram_ResetHint) String() string

type Histogram_ZeroCountFloat added in v0.31.0 

type Histogram_ZeroCountFloat struct {
	ZeroCountFloat float64 `protobuf:"fixed64,7,opt,name=zero_count_float,json=zeroCountFloat,proto3,oneof" json:"zero_count_float,omitempty"`
}

func (*Histogram_ZeroCountFloat) MarshalTo added in v0.31.0 

func (m *Histogram_ZeroCountFloat) MarshalTo(dAtA []byte) (int, error)

func (*Histogram_ZeroCountFloat) MarshalToSizedBuffer added in v0.31.0 

func (m *Histogram_ZeroCountFloat) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Histogram_ZeroCountFloat) Size added in v0.31.0 

func (m *Histogram_ZeroCountFloat) Size() (n int)

type Histogram_ZeroCountInt added in v0.31.0 

type Histogram_ZeroCountInt struct {
	ZeroCountInt uint64 `protobuf:"varint,6,opt,name=zero_count_int,json=zeroCountInt,proto3,oneof" json:"zero_count_int,omitempty"`
}

func (*Histogram_ZeroCountInt) MarshalTo added in v0.31.0 

func (m *Histogram_ZeroCountInt) MarshalTo(dAtA []byte) (int, error)

func (*Histogram_ZeroCountInt) MarshalToSizedBuffer added in v0.31.0 

func (m *Histogram_ZeroCountInt) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Histogram_ZeroCountInt) Size added in v0.31.0 

func (m *Histogram_ZeroCountInt) Size() (n int)

type LabelMatcher 

type LabelMatcher struct {
	Type  LabelMatcher_Type `protobuf:"varint,1,opt,name=type,proto3,enum=prometheus_copy.LabelMatcher_Type" json:"type,omitempty"`
	Name  string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Value string            `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

Matcher specifies a rule, which can match or set of labels or not.

func (*LabelMatcher) Descriptor 

func (*LabelMatcher) Descriptor() ([]byte, []int)

func (*LabelMatcher) GetName 

func (m *LabelMatcher) GetName() string

func (*LabelMatcher) GetType 

func (m *LabelMatcher) GetType() LabelMatcher_Type

func (*LabelMatcher) GetValue 

func (m *LabelMatcher) GetValue() string

func (*LabelMatcher) Marshal 

func (m *LabelMatcher) Marshal() (dAtA []byte, err error)

func (*LabelMatcher) MarshalTo 

func (m *LabelMatcher) MarshalTo(dAtA []byte) (int, error)

func (*LabelMatcher) MarshalToSizedBuffer 

func (m *LabelMatcher) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LabelMatcher) ProtoMessage 

func (*LabelMatcher) ProtoMessage()

func (*LabelMatcher) Reset 

func (m *LabelMatcher) Reset()

func (*LabelMatcher) Size 

func (m *LabelMatcher) Size() (n int)

func (*LabelMatcher) String 

func (m *LabelMatcher) String() string

func (*LabelMatcher) Unmarshal 

func (m *LabelMatcher) Unmarshal(dAtA []byte) error

func (*LabelMatcher) XXX_DiscardUnknown 

func (m *LabelMatcher) XXX_DiscardUnknown()

func (*LabelMatcher) XXX_Marshal 

func (m *LabelMatcher) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LabelMatcher) XXX_Merge 

func (m *LabelMatcher) XXX_Merge(src proto.Message)

func (*LabelMatcher) XXX_Size 

func (m *LabelMatcher) XXX_Size() int

func (*LabelMatcher) XXX_Unmarshal 

func (m *LabelMatcher) XXX_Unmarshal(b []byte) error

type LabelMatcher_Type 

type LabelMatcher_Type int32
const (
	LabelMatcher_EQ  LabelMatcher_Type = 0
	LabelMatcher_NEQ LabelMatcher_Type = 1
	LabelMatcher_RE  LabelMatcher_Type = 2
	LabelMatcher_NRE LabelMatcher_Type = 3
)

func (LabelMatcher_Type) EnumDescriptor 

func (LabelMatcher_Type) EnumDescriptor() ([]byte, []int)

func (LabelMatcher_Type) String 

func (x LabelMatcher_Type) String() string

type MetricMetadata added in v0.21.0 

type MetricMetadata struct {
	// Represents the metric type, these match the set from Prometheus.
	// Refer to pkg/textparse/interface.go for details.
	Type             MetricMetadata_MetricType `protobuf:"varint,1,opt,name=type,proto3,enum=prometheus_copy.MetricMetadata_MetricType" json:"type,omitempty"`
	MetricFamilyName string                    `protobuf:"bytes,2,opt,name=metric_family_name,json=metricFamilyName,proto3" json:"metric_family_name,omitempty"`
	Help             string                    `protobuf:"bytes,4,opt,name=help,proto3" json:"help,omitempty"`
	Unit             string                    `protobuf:"bytes,5,opt,name=unit,proto3" json:"unit,omitempty"`
}

func (*MetricMetadata) Descriptor added in v0.21.0 

func (*MetricMetadata) Descriptor() ([]byte, []int)

func (*MetricMetadata) GetHelp added in v0.21.0 

func (m *MetricMetadata) GetHelp() string

func (*MetricMetadata) GetMetricFamilyName added in v0.21.0 

func (m *MetricMetadata) GetMetricFamilyName() string

func (*MetricMetadata) GetType added in v0.21.0 

func (m *MetricMetadata) GetType() MetricMetadata_MetricType

func (*MetricMetadata) GetUnit added in v0.21.0 

func (m *MetricMetadata) GetUnit() string

func (*MetricMetadata) Marshal added in v0.21.0 

func (m *MetricMetadata) Marshal() (dAtA []byte, err error)

func (*MetricMetadata) MarshalTo added in v0.21.0 

func (m *MetricMetadata) MarshalTo(dAtA []byte) (int, error)

func (*MetricMetadata) MarshalToSizedBuffer added in v0.21.0 

func (m *MetricMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MetricMetadata) ProtoMessage added in v0.21.0 

func (*MetricMetadata) ProtoMessage()

func (*MetricMetadata) Reset added in v0.21.0 

func (m *MetricMetadata) Reset()

func (*MetricMetadata) Size added in v0.21.0 

func (m *MetricMetadata) Size() (n int)

func (*MetricMetadata) String added in v0.21.0 

func (m *MetricMetadata) String() string

func (*MetricMetadata) Unmarshal added in v0.21.0 

func (m *MetricMetadata) Unmarshal(dAtA []byte) error

func (*MetricMetadata) XXX_DiscardUnknown added in v0.21.0 

func (m *MetricMetadata) XXX_DiscardUnknown()

func (*MetricMetadata) XXX_Marshal added in v0.21.0 

func (m *MetricMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricMetadata) XXX_Merge added in v0.21.0 

func (m *MetricMetadata) XXX_Merge(src proto.Message)

func (*MetricMetadata) XXX_Size added in v0.21.0 

func (m *MetricMetadata) XXX_Size() int

func (*MetricMetadata) XXX_Unmarshal added in v0.21.0 

func (m *MetricMetadata) XXX_Unmarshal(b []byte) error

type MetricMetadata_MetricType added in v0.21.0 

type MetricMetadata_MetricType int32
const (
	MetricMetadata_UNKNOWN        MetricMetadata_MetricType = 0
	MetricMetadata_COUNTER        MetricMetadata_MetricType = 1
	MetricMetadata_GAUGE          MetricMetadata_MetricType = 2
	MetricMetadata_HISTOGRAM      MetricMetadata_MetricType = 3
	MetricMetadata_GAUGEHISTOGRAM MetricMetadata_MetricType = 4
	MetricMetadata_SUMMARY        MetricMetadata_MetricType = 5
	MetricMetadata_INFO           MetricMetadata_MetricType = 6
	MetricMetadata_STATESET       MetricMetadata_MetricType = 7
)

func (MetricMetadata_MetricType) EnumDescriptor added in v0.21.0 

func (MetricMetadata_MetricType) EnumDescriptor() ([]byte, []int)

func (MetricMetadata_MetricType) String added in v0.21.0 

func (x MetricMetadata_MetricType) String() string

type Query 

type Query struct {
	StartTimestampMs int64           `protobuf:"varint,1,opt,name=start_timestamp_ms,json=startTimestampMs,proto3" json:"start_timestamp_ms,omitempty"`
	EndTimestampMs   int64           `protobuf:"varint,2,opt,name=end_timestamp_ms,json=endTimestampMs,proto3" json:"end_timestamp_ms,omitempty"`
	Matchers         []*LabelMatcher `protobuf:"bytes,3,rep,name=matchers,proto3" json:"matchers,omitempty"`
	Hints            *ReadHints      `protobuf:"bytes,4,opt,name=hints,proto3" json:"hints,omitempty"`
}

func (*Query) Descriptor 

func (*Query) Descriptor() ([]byte, []int)

func (*Query) GetEndTimestampMs 

func (m *Query) GetEndTimestampMs() int64

func (*Query) GetHints 

func (m *Query) GetHints() *ReadHints

func (*Query) GetMatchers 

func (m *Query) GetMatchers() []*LabelMatcher

func (*Query) GetStartTimestampMs 

func (m *Query) GetStartTimestampMs() int64

func (*Query) Marshal 

func (m *Query) Marshal() (dAtA []byte, err error)

func (*Query) MarshalTo 

func (m *Query) MarshalTo(dAtA []byte) (int, error)

func (*Query) MarshalToSizedBuffer 

func (m *Query) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) Reset 

func (m *Query) Reset()

func (*Query) Size 

func (m *Query) Size() (n int)

func (*Query) String 

func (m *Query) String() string

func (*Query) Unmarshal 

func (m *Query) Unmarshal(dAtA []byte) error

func (*Query) XXX_DiscardUnknown 

func (m *Query) XXX_DiscardUnknown()

func (*Query) XXX_Marshal 

func (m *Query) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Query) XXX_Merge 

func (m *Query) XXX_Merge(src proto.Message)

func (*Query) XXX_Size 

func (m *Query) XXX_Size() int

func (*Query) XXX_Unmarshal 

func (m *Query) XXX_Unmarshal(b []byte) error

type QueryResult 

type QueryResult struct {
	// Samples within a time series must be ordered by time.
	Timeseries []*TimeSeries `protobuf:"bytes,1,rep,name=timeseries,proto3" json:"timeseries,omitempty"`
}

func (*QueryResult) Descriptor 

func (*QueryResult) Descriptor() ([]byte, []int)

func (*QueryResult) GetTimeseries 

func (m *QueryResult) GetTimeseries() []*TimeSeries

func (*QueryResult) Marshal 

func (m *QueryResult) Marshal() (dAtA []byte, err error)

func (*QueryResult) MarshalTo 

func (m *QueryResult) MarshalTo(dAtA []byte) (int, error)

func (*QueryResult) MarshalToSizedBuffer 

func (m *QueryResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryResult) ProtoMessage 

func (*QueryResult) ProtoMessage()

func (*QueryResult) Reset 

func (m *QueryResult) Reset()

func (*QueryResult) Size 

func (m *QueryResult) Size() (n int)

func (*QueryResult) String 

func (m *QueryResult) String() string

func (*QueryResult) Unmarshal 

func (m *QueryResult) Unmarshal(dAtA []byte) error

func (*QueryResult) XXX_DiscardUnknown 

func (m *QueryResult) XXX_DiscardUnknown()

func (*QueryResult) XXX_Marshal 

func (m *QueryResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryResult) XXX_Merge 

func (m *QueryResult) XXX_Merge(src proto.Message)

func (*QueryResult) XXX_Size 

func (m *QueryResult) XXX_Size() int

func (*QueryResult) XXX_Unmarshal 

func (m *QueryResult) XXX_Unmarshal(b []byte) error

type ReadHints 

type ReadHints struct {
	StepMs   int64    `protobuf:"varint,1,opt,name=step_ms,json=stepMs,proto3" json:"step_ms,omitempty"`
	Func     string   `protobuf:"bytes,2,opt,name=func,proto3" json:"func,omitempty"`
	StartMs  int64    `protobuf:"varint,3,opt,name=start_ms,json=startMs,proto3" json:"start_ms,omitempty"`
	EndMs    int64    `protobuf:"varint,4,opt,name=end_ms,json=endMs,proto3" json:"end_ms,omitempty"`
	Grouping []string `protobuf:"bytes,5,rep,name=grouping,proto3" json:"grouping,omitempty"`
	By       bool     `protobuf:"varint,6,opt,name=by,proto3" json:"by,omitempty"`
	RangeMs  int64    `protobuf:"varint,7,opt,name=range_ms,json=rangeMs,proto3" json:"range_ms,omitempty"`
}

func (*ReadHints) Descriptor 

func (*ReadHints) Descriptor() ([]byte, []int)

func (*ReadHints) GetBy 

func (m *ReadHints) GetBy() bool

func (*ReadHints) GetEndMs 

func (m *ReadHints) GetEndMs() int64

func (*ReadHints) GetFunc 

func (m *ReadHints) GetFunc() string

func (*ReadHints) GetGrouping 

func (m *ReadHints) GetGrouping() []string

func (*ReadHints) GetRangeMs 

func (m *ReadHints) GetRangeMs() int64

func (*ReadHints) GetStartMs 

func (m *ReadHints) GetStartMs() int64

func (*ReadHints) GetStepMs 

func (m *ReadHints) GetStepMs() int64

func (*ReadHints) Marshal 

func (m *ReadHints) Marshal() (dAtA []byte, err error)

func (*ReadHints) MarshalTo 

func (m *ReadHints) MarshalTo(dAtA []byte) (int, error)

func (*ReadHints) MarshalToSizedBuffer 

func (m *ReadHints) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadHints) ProtoMessage 

func (*ReadHints) ProtoMessage()

func (*ReadHints) Reset 

func (m *ReadHints) Reset()

func (*ReadHints) Size 

func (m *ReadHints) Size() (n int)

func (*ReadHints) String 

func (m *ReadHints) String() string

func (*ReadHints) Unmarshal 

func (m *ReadHints) Unmarshal(dAtA []byte) error

func (*ReadHints) XXX_DiscardUnknown 

func (m *ReadHints) XXX_DiscardUnknown()

func (*ReadHints) XXX_Marshal 

func (m *ReadHints) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadHints) XXX_Merge 

func (m *ReadHints) XXX_Merge(src proto.Message)

func (*ReadHints) XXX_Size 

func (m *ReadHints) XXX_Size() int

func (*ReadHints) XXX_Unmarshal 

func (m *ReadHints) XXX_Unmarshal(b []byte) error

type ReadRequest 

type ReadRequest struct {
	Queries []*Query `protobuf:"bytes,1,rep,name=queries,proto3" json:"queries,omitempty"`
	// accepted_response_types allows negotiating the content type of the response.
	//
	// Response types are taken from the list in the FIFO order. If no response type in `accepted_response_types` is
	// implemented by server, error is returned.
	// For request that do not contain `accepted_response_types` field the SAMPLES response type will be used.
	AcceptedResponseTypes []ReadRequest_ResponseType `` /* 180-byte string literal not displayed */
}

ReadRequest represents a remote read request.

func (*ReadRequest) Descriptor 

func (*ReadRequest) Descriptor() ([]byte, []int)

func (*ReadRequest) GetAcceptedResponseTypes 

func (m *ReadRequest) GetAcceptedResponseTypes() []ReadRequest_ResponseType

func (*ReadRequest) GetQueries 

func (m *ReadRequest) GetQueries() []*Query

func (*ReadRequest) Marshal 

func (m *ReadRequest) Marshal() (dAtA []byte, err error)

func (*ReadRequest) MarshalTo 

func (m *ReadRequest) MarshalTo(dAtA []byte) (int, error)

func (*ReadRequest) MarshalToSizedBuffer 

func (m *ReadRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) Reset 

func (m *ReadRequest) Reset()

func (*ReadRequest) Size 

func (m *ReadRequest) Size() (n int)

func (*ReadRequest) String 

func (m *ReadRequest) String() string

func (*ReadRequest) Unmarshal 

func (m *ReadRequest) Unmarshal(dAtA []byte) error

func (*ReadRequest) XXX_DiscardUnknown 

func (m *ReadRequest) XXX_DiscardUnknown()

func (*ReadRequest) XXX_Marshal 

func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadRequest) XXX_Merge 

func (m *ReadRequest) XXX_Merge(src proto.Message)

func (*ReadRequest) XXX_Size 

func (m *ReadRequest) XXX_Size() int

func (*ReadRequest) XXX_Unmarshal 

func (m *ReadRequest) XXX_Unmarshal(b []byte) error

type ReadRequest_ResponseType 

type ReadRequest_ResponseType int32
const (
	// Server will return a single ReadResponse message with matched series that includes list of raw samples.
	// It's recommended to use streamed response types instead.
	//
	// Response headers:
	// Content-Type: "application/x-protobuf"
	// Content-Encoding: "snappy"
	ReadRequest_SAMPLES ReadRequest_ResponseType = 0
	// Server will stream a delimited ChunkedReadResponse message that contains XOR encoded chunks for a single series.
	// Each message is following varint size and fixed size bigendian uint32 for CRC32 Castagnoli checksum.
	//
	// Response headers:
	// Content-Type: "application/x-streamed-protobuf; proto=prometheus.ChunkedReadResponse"
	// Content-Encoding: ""
	ReadRequest_STREAMED_XOR_CHUNKS ReadRequest_ResponseType = 1
)

func (ReadRequest_ResponseType) EnumDescriptor 

func (ReadRequest_ResponseType) EnumDescriptor() ([]byte, []int)

func (ReadRequest_ResponseType) String 

func (x ReadRequest_ResponseType) String() string

type ReadResponse 

type ReadResponse struct {
	// In same order as the request's queries.
	Results []*QueryResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
}

ReadResponse is a response when response_type equals SAMPLES.

func (*ReadResponse) Descriptor 

func (*ReadResponse) Descriptor() ([]byte, []int)

func (*ReadResponse) GetResults 

func (m *ReadResponse) GetResults() []*QueryResult

func (*ReadResponse) Marshal 

func (m *ReadResponse) Marshal() (dAtA []byte, err error)

func (*ReadResponse) MarshalTo 

func (m *ReadResponse) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse) MarshalToSizedBuffer 

func (m *ReadResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse) ProtoMessage 

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) Reset 

func (m *ReadResponse) Reset()

func (*ReadResponse) Size 

func (m *ReadResponse) Size() (n int)

func (*ReadResponse) String 

func (m *ReadResponse) String() string

func (*ReadResponse) Unmarshal 

func (m *ReadResponse) Unmarshal(dAtA []byte) error

func (*ReadResponse) XXX_DiscardUnknown 

func (m *ReadResponse) XXX_DiscardUnknown()

func (*ReadResponse) XXX_Marshal 

func (m *ReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadResponse) XXX_Merge 

func (m *ReadResponse) XXX_Merge(src proto.Message)

func (*ReadResponse) XXX_Size 

func (m *ReadResponse) XXX_Size() int

func (*ReadResponse) XXX_Unmarshal 

func (m *ReadResponse) XXX_Unmarshal(b []byte) error

type Sample 

type Sample struct {
	Value     float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp int64   `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

func SamplesFromSamplePairs added in v0.25.0 

func SamplesFromSamplePairs(samples []model.SamplePair) []Sample

SamplesFromSamplePairs converts a slice of model.SamplePair to a slice of Sample.

func (*Sample) Descriptor 

func (*Sample) Descriptor() ([]byte, []int)

func (*Sample) GetTimestamp 

func (m *Sample) GetTimestamp() int64

func (*Sample) GetValue 

func (m *Sample) GetValue() float64

func (*Sample) Marshal 

func (m *Sample) Marshal() (dAtA []byte, err error)

func (*Sample) MarshalTo 

func (m *Sample) MarshalTo(dAtA []byte) (int, error)

func (*Sample) MarshalToSizedBuffer 

func (m *Sample) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Sample) ProtoMessage 

func (*Sample) ProtoMessage()

func (*Sample) Reset 

func (m *Sample) Reset()

func (*Sample) Size 

func (m *Sample) Size() (n int)

func (*Sample) String 

func (m *Sample) String() string

func (*Sample) Unmarshal 

func (m *Sample) Unmarshal(dAtA []byte) error

func (*Sample) XXX_DiscardUnknown 

func (m *Sample) XXX_DiscardUnknown()

func (*Sample) XXX_Marshal 

func (m *Sample) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Sample) XXX_Merge 

func (m *Sample) XXX_Merge(src proto.Message)

func (*Sample) XXX_Size 

func (m *Sample) XXX_Size() int

func (*Sample) XXX_Unmarshal 

func (m *Sample) XXX_Unmarshal(b []byte) error

type TimeSeries 

type TimeSeries struct {
	// Labels have to be sorted by label names and without duplicated label names.
	// TODO(bwplotka): Don't use zero copy ZLabels, see https://github.com/thanos-io/thanos/pull/3279 for details.
	Labels     []github_com_thanos_io_thanos_pkg_store_labelpb.ZLabel `protobuf:"bytes,1,rep,name=labels,proto3,customtype=github.com/thanos-io/thanos/pkg/store/labelpb.ZLabel" json:"labels"`
	Samples    []Sample                                               `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples"`
	Exemplars  []Exemplar                                             `protobuf:"bytes,3,rep,name=exemplars,proto3" json:"exemplars"`
	Histograms []Histogram                                            `protobuf:"bytes,4,rep,name=histograms,proto3" json:"histograms"`
}

TimeSeries represents samples and labels for a single time series.

func (*TimeSeries) Descriptor 

func (*TimeSeries) Descriptor() ([]byte, []int)

func (*TimeSeries) GetExemplars added in v0.21.0 

func (m *TimeSeries) GetExemplars() []Exemplar

func (*TimeSeries) GetHistograms added in v0.31.0 

func (m *TimeSeries) GetHistograms() []Histogram

func (*TimeSeries) GetSamples 

func (m *TimeSeries) GetSamples() []Sample

func (*TimeSeries) Marshal 

func (m *TimeSeries) Marshal() (dAtA []byte, err error)

func (*TimeSeries) MarshalTo 

func (m *TimeSeries) MarshalTo(dAtA []byte) (int, error)

func (*TimeSeries) MarshalToSizedBuffer 

func (m *TimeSeries) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TimeSeries) ProtoMessage 

func (*TimeSeries) ProtoMessage()

func (*TimeSeries) Reset 

func (m *TimeSeries) Reset()

func (*TimeSeries) Size 

func (m *TimeSeries) Size() (n int)

func (*TimeSeries) String 

func (m *TimeSeries) String() string

func (*TimeSeries) Unmarshal 

func (m *TimeSeries) Unmarshal(dAtA []byte) error

func (*TimeSeries) XXX_DiscardUnknown 

func (m *TimeSeries) XXX_DiscardUnknown()

func (*TimeSeries) XXX_Marshal 

func (m *TimeSeries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TimeSeries) XXX_Merge 

func (m *TimeSeries) XXX_Merge(src proto.Message)

func (*TimeSeries) XXX_Size 

func (m *TimeSeries) XXX_Size() int

func (*TimeSeries) XXX_Unmarshal 

func (m *TimeSeries) XXX_Unmarshal(b []byte) error

type WriteRequest 

type WriteRequest struct {
	Timeseries []TimeSeries     `protobuf:"bytes,1,rep,name=timeseries,proto3" json:"timeseries"`
	Metadata   []MetricMetadata `protobuf:"bytes,3,rep,name=metadata,proto3" json:"metadata"`
}

func (*WriteRequest) Descriptor 

func (*WriteRequest) Descriptor() ([]byte, []int)

func (*WriteRequest) GetMetadata added in v0.21.0 

func (m *WriteRequest) GetMetadata() []MetricMetadata

func (*WriteRequest) GetTimeseries 

func (m *WriteRequest) GetTimeseries() []TimeSeries

func (*WriteRequest) Marshal 

func (m *WriteRequest) Marshal() (dAtA []byte, err error)

func (*WriteRequest) MarshalTo 

func (m *WriteRequest) MarshalTo(dAtA []byte) (int, error)

func (*WriteRequest) MarshalToSizedBuffer 

func (m *WriteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) Size 

func (m *WriteRequest) Size() (n int)

func (*WriteRequest) String 

func (m *WriteRequest) String() string

func (*WriteRequest) Unmarshal 

func (m *WriteRequest) Unmarshal(dAtA []byte) error

func (*WriteRequest) XXX_DiscardUnknown 

func (m *WriteRequest) XXX_DiscardUnknown()

func (*WriteRequest) XXX_Marshal 

func (m *WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteRequest) XXX_Merge 

func (m *WriteRequest) XXX_Merge(src proto.Message)

func (*WriteRequest) XXX_Size 

func (m *WriteRequest) XXX_Size() int

func (*WriteRequest) XXX_Unmarshal 

func (m *WriteRequest) XXX_Unmarshal(b []byte) error

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.