feat: update prometheus remote write proto file for native histogram (#294)

* feat: update prometheus remote write proto file for native histogram

* chore: format
This commit is contained in:
Ning Sun
2025-12-12 11:45:34 +08:00
committed by GitHub
parent 0df99f09f1
commit 5b7d43d7bf
8 changed files with 8302 additions and 206 deletions
+583 -120
View File
@@ -97,6 +97,58 @@ func (MetricMetadata_MetricType) EnumDescriptor() ([]byte, []int) {
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{0, 0}
}
type Histogram_ResetHint int32
const (
Histogram_UNKNOWN Histogram_ResetHint = 0 // Need to test for a counter reset explicitly.
Histogram_YES Histogram_ResetHint = 1 // This is the 1st histogram after a counter reset.
Histogram_NO Histogram_ResetHint = 2 // There was no counter reset between this and the previous Histogram.
Histogram_GAUGE Histogram_ResetHint = 3 // This is a gauge histogram where counter resets don't happen.
)
// Enum value maps for Histogram_ResetHint.
var (
Histogram_ResetHint_name = map[int32]string{
0: "UNKNOWN",
1: "YES",
2: "NO",
3: "GAUGE",
}
Histogram_ResetHint_value = map[string]int32{
"UNKNOWN": 0,
"YES": 1,
"NO": 2,
"GAUGE": 3,
}
)
func (x Histogram_ResetHint) Enum() *Histogram_ResetHint {
p := new(Histogram_ResetHint)
*p = x
return p
}
func (x Histogram_ResetHint) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (Histogram_ResetHint) Descriptor() protoreflect.EnumDescriptor {
return file_prometheus_remote_types_proto_enumTypes[1].Descriptor()
}
func (Histogram_ResetHint) Type() protoreflect.EnumType {
return &file_prometheus_remote_types_proto_enumTypes[1]
}
func (x Histogram_ResetHint) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use Histogram_ResetHint.Descriptor instead.
func (Histogram_ResetHint) EnumDescriptor() ([]byte, []int) {
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{3, 0}
}
type LabelMatcher_Type int32
const (
@@ -133,11 +185,11 @@ func (x LabelMatcher_Type) String() string {
}
func (LabelMatcher_Type) Descriptor() protoreflect.EnumDescriptor {
return file_prometheus_remote_types_proto_enumTypes[1].Descriptor()
return file_prometheus_remote_types_proto_enumTypes[2].Descriptor()
}
func (LabelMatcher_Type) Type() protoreflect.EnumType {
return &file_prometheus_remote_types_proto_enumTypes[1]
return &file_prometheus_remote_types_proto_enumTypes[2]
}
func (x LabelMatcher_Type) Number() protoreflect.EnumNumber {
@@ -146,15 +198,17 @@ func (x LabelMatcher_Type) Number() protoreflect.EnumNumber {
// Deprecated: Use LabelMatcher_Type.Descriptor instead.
func (LabelMatcher_Type) EnumDescriptor() ([]byte, []int) {
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{6, 0}
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{8, 0}
}
// We require this to match chunkenc.Encoding.
type Chunk_Encoding int32
const (
Chunk_UNKNOWN Chunk_Encoding = 0
Chunk_XOR Chunk_Encoding = 1
Chunk_UNKNOWN Chunk_Encoding = 0
Chunk_XOR Chunk_Encoding = 1
Chunk_HISTOGRAM Chunk_Encoding = 2
Chunk_FLOAT_HISTOGRAM Chunk_Encoding = 3
)
// Enum value maps for Chunk_Encoding.
@@ -162,10 +216,14 @@ var (
Chunk_Encoding_name = map[int32]string{
0: "UNKNOWN",
1: "XOR",
2: "HISTOGRAM",
3: "FLOAT_HISTOGRAM",
}
Chunk_Encoding_value = map[string]int32{
"UNKNOWN": 0,
"XOR": 1,
"UNKNOWN": 0,
"XOR": 1,
"HISTOGRAM": 2,
"FLOAT_HISTOGRAM": 3,
}
)
@@ -180,11 +238,11 @@ func (x Chunk_Encoding) String() string {
}
func (Chunk_Encoding) Descriptor() protoreflect.EnumDescriptor {
return file_prometheus_remote_types_proto_enumTypes[2].Descriptor()
return file_prometheus_remote_types_proto_enumTypes[3].Descriptor()
}
func (Chunk_Encoding) Type() protoreflect.EnumType {
return &file_prometheus_remote_types_proto_enumTypes[2]
return &file_prometheus_remote_types_proto_enumTypes[3]
}
func (x Chunk_Encoding) Number() protoreflect.EnumNumber {
@@ -193,7 +251,7 @@ func (x Chunk_Encoding) Number() protoreflect.EnumNumber {
// Deprecated: Use Chunk_Encoding.Descriptor instead.
func (Chunk_Encoding) EnumDescriptor() ([]byte, []int) {
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{8, 0}
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{10, 0}
}
type MetricMetadata struct {
@@ -202,7 +260,7 @@ type MetricMetadata struct {
unknownFields protoimpl.UnknownFields
// Represents the metric type, these match the set from Prometheus.
// Refer to model/textparse/interface.go for details.
// Refer to github.com/prometheus/common/model/metadata.go for details.
Type MetricMetadata_MetricType `protobuf:"varint,1,opt,name=type,proto3,enum=prometheus.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"`
@@ -392,6 +450,310 @@ func (x *Exemplar) GetTimestamp() int64 {
return 0
}
// 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.
type Histogram struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// Types that are assignable to Count:
//
// *Histogram_CountInt
// *Histogram_CountFloat
Count isHistogram_Count `protobuf_oneof:"count"`
Sum float64 `protobuf:"fixed64,3,opt,name=sum,proto3" json:"sum,omitempty"` // Sum of observations in the histogram.
// 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"` // Breadth of the zero bucket.
// Types that are assignable 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,omitempty"`
// 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"` // Count delta of each bucket compared to previous one (or to zero for 1st bucket).
NegativeCounts []float64 `protobuf:"fixed64,10,rep,packed,name=negative_counts,json=negativeCounts,proto3" json:"negative_counts,omitempty"` // Absolute count of each bucket.
// Positive Buckets.
PositiveSpans []*BucketSpan `protobuf:"bytes,11,rep,name=positive_spans,json=positiveSpans,proto3" json:"positive_spans,omitempty"`
// 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"` // Count delta of each bucket compared to previous one (or to zero for 1st bucket).
PositiveCounts []float64 `protobuf:"fixed64,13,rep,packed,name=positive_counts,json=positiveCounts,proto3" json:"positive_counts,omitempty"` // Absolute count of each bucket.
ResetHint Histogram_ResetHint `protobuf:"varint,14,opt,name=reset_hint,json=resetHint,proto3,enum=prometheus.Histogram_ResetHint" json:"reset_hint,omitempty"`
// 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"`
// custom_values are not part of the specification, DO NOT use in remote write clients.
// Used only for converting from OpenTelemetry to Prometheus internally.
CustomValues []float64 `protobuf:"fixed64,16,rep,packed,name=custom_values,json=customValues,proto3" json:"custom_values,omitempty"`
}
func (x *Histogram) Reset() {
*x = Histogram{}
if protoimpl.UnsafeEnabled {
mi := &file_prometheus_remote_types_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *Histogram) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Histogram) ProtoMessage() {}
func (x *Histogram) ProtoReflect() protoreflect.Message {
mi := &file_prometheus_remote_types_proto_msgTypes[3]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Histogram.ProtoReflect.Descriptor instead.
func (*Histogram) Descriptor() ([]byte, []int) {
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{3}
}
func (m *Histogram) GetCount() isHistogram_Count {
if m != nil {
return m.Count
}
return nil
}
func (x *Histogram) GetCountInt() uint64 {
if x, ok := x.GetCount().(*Histogram_CountInt); ok {
return x.CountInt
}
return 0
}
func (x *Histogram) GetCountFloat() float64 {
if x, ok := x.GetCount().(*Histogram_CountFloat); ok {
return x.CountFloat
}
return 0
}
func (x *Histogram) GetSum() float64 {
if x != nil {
return x.Sum
}
return 0
}
func (x *Histogram) GetSchema() int32 {
if x != nil {
return x.Schema
}
return 0
}
func (x *Histogram) GetZeroThreshold() float64 {
if x != nil {
return x.ZeroThreshold
}
return 0
}
func (m *Histogram) GetZeroCount() isHistogram_ZeroCount {
if m != nil {
return m.ZeroCount
}
return nil
}
func (x *Histogram) GetZeroCountInt() uint64 {
if x, ok := x.GetZeroCount().(*Histogram_ZeroCountInt); ok {
return x.ZeroCountInt
}
return 0
}
func (x *Histogram) GetZeroCountFloat() float64 {
if x, ok := x.GetZeroCount().(*Histogram_ZeroCountFloat); ok {
return x.ZeroCountFloat
}
return 0
}
func (x *Histogram) GetNegativeSpans() []*BucketSpan {
if x != nil {
return x.NegativeSpans
}
return nil
}
func (x *Histogram) GetNegativeDeltas() []int64 {
if x != nil {
return x.NegativeDeltas
}
return nil
}
func (x *Histogram) GetNegativeCounts() []float64 {
if x != nil {
return x.NegativeCounts
}
return nil
}
func (x *Histogram) GetPositiveSpans() []*BucketSpan {
if x != nil {
return x.PositiveSpans
}
return nil
}
func (x *Histogram) GetPositiveDeltas() []int64 {
if x != nil {
return x.PositiveDeltas
}
return nil
}
func (x *Histogram) GetPositiveCounts() []float64 {
if x != nil {
return x.PositiveCounts
}
return nil
}
func (x *Histogram) GetResetHint() Histogram_ResetHint {
if x != nil {
return x.ResetHint
}
return Histogram_UNKNOWN
}
func (x *Histogram) GetTimestamp() int64 {
if x != nil {
return x.Timestamp
}
return 0
}
func (x *Histogram) GetCustomValues() []float64 {
if x != nil {
return x.CustomValues
}
return nil
}
type isHistogram_Count interface {
isHistogram_Count()
}
type Histogram_CountInt struct {
CountInt uint64 `protobuf:"varint,1,opt,name=count_int,json=countInt,proto3,oneof"`
}
type Histogram_CountFloat struct {
CountFloat float64 `protobuf:"fixed64,2,opt,name=count_float,json=countFloat,proto3,oneof"`
}
func (*Histogram_CountInt) isHistogram_Count() {}
func (*Histogram_CountFloat) isHistogram_Count() {}
type isHistogram_ZeroCount interface {
isHistogram_ZeroCount()
}
type Histogram_ZeroCountInt struct {
ZeroCountInt uint64 `protobuf:"varint,6,opt,name=zero_count_int,json=zeroCountInt,proto3,oneof"`
}
type Histogram_ZeroCountFloat struct {
ZeroCountFloat float64 `protobuf:"fixed64,7,opt,name=zero_count_float,json=zeroCountFloat,proto3,oneof"`
}
func (*Histogram_ZeroCountInt) isHistogram_ZeroCount() {}
func (*Histogram_ZeroCountFloat) isHistogram_ZeroCount() {}
// 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).
type BucketSpan struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Offset int32 `protobuf:"zigzag32,1,opt,name=offset,proto3" json:"offset,omitempty"` // Gap to previous span, or starting point for 1st span (which can be negative).
Length uint32 `protobuf:"varint,2,opt,name=length,proto3" json:"length,omitempty"` // Length of consecutive buckets.
}
func (x *BucketSpan) Reset() {
*x = BucketSpan{}
if protoimpl.UnsafeEnabled {
mi := &file_prometheus_remote_types_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *BucketSpan) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*BucketSpan) ProtoMessage() {}
func (x *BucketSpan) ProtoReflect() protoreflect.Message {
mi := &file_prometheus_remote_types_proto_msgTypes[4]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use BucketSpan.ProtoReflect.Descriptor instead.
func (*BucketSpan) Descriptor() ([]byte, []int) {
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{4}
}
func (x *BucketSpan) GetOffset() int32 {
if x != nil {
return x.Offset
}
return 0
}
func (x *BucketSpan) GetLength() uint32 {
if x != nil {
return x.Length
}
return 0
}
// TimeSeries represents samples and labels for a single time series.
type TimeSeries struct {
state protoimpl.MessageState
@@ -400,15 +762,16 @@ type TimeSeries struct {
// For a timeseries to be valid, and for the samples and exemplars
// to be ingested by the remote system properly, the labels field is required.
Labels []*Label `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"`
Samples []*Sample `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples,omitempty"`
Exemplars []*Exemplar `protobuf:"bytes,3,rep,name=exemplars,proto3" json:"exemplars,omitempty"`
Labels []*Label `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"`
Samples []*Sample `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples,omitempty"`
Exemplars []*Exemplar `protobuf:"bytes,3,rep,name=exemplars,proto3" json:"exemplars,omitempty"`
Histograms []*Histogram `protobuf:"bytes,4,rep,name=histograms,proto3" json:"histograms,omitempty"`
}
func (x *TimeSeries) Reset() {
*x = TimeSeries{}
if protoimpl.UnsafeEnabled {
mi := &file_prometheus_remote_types_proto_msgTypes[3]
mi := &file_prometheus_remote_types_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -421,7 +784,7 @@ func (x *TimeSeries) String() string {
func (*TimeSeries) ProtoMessage() {}
func (x *TimeSeries) ProtoReflect() protoreflect.Message {
mi := &file_prometheus_remote_types_proto_msgTypes[3]
mi := &file_prometheus_remote_types_proto_msgTypes[5]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -434,7 +797,7 @@ func (x *TimeSeries) ProtoReflect() protoreflect.Message {
// Deprecated: Use TimeSeries.ProtoReflect.Descriptor instead.
func (*TimeSeries) Descriptor() ([]byte, []int) {
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{3}
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{5}
}
func (x *TimeSeries) GetLabels() []*Label {
@@ -458,6 +821,13 @@ func (x *TimeSeries) GetExemplars() []*Exemplar {
return nil
}
func (x *TimeSeries) GetHistograms() []*Histogram {
if x != nil {
return x.Histograms
}
return nil
}
type Label struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
@@ -470,7 +840,7 @@ type Label struct {
func (x *Label) Reset() {
*x = Label{}
if protoimpl.UnsafeEnabled {
mi := &file_prometheus_remote_types_proto_msgTypes[4]
mi := &file_prometheus_remote_types_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -483,7 +853,7 @@ func (x *Label) String() string {
func (*Label) ProtoMessage() {}
func (x *Label) ProtoReflect() protoreflect.Message {
mi := &file_prometheus_remote_types_proto_msgTypes[4]
mi := &file_prometheus_remote_types_proto_msgTypes[6]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -496,7 +866,7 @@ func (x *Label) ProtoReflect() protoreflect.Message {
// Deprecated: Use Label.ProtoReflect.Descriptor instead.
func (*Label) Descriptor() ([]byte, []int) {
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{4}
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{6}
}
func (x *Label) GetName() string {
@@ -524,7 +894,7 @@ type Labels struct {
func (x *Labels) Reset() {
*x = Labels{}
if protoimpl.UnsafeEnabled {
mi := &file_prometheus_remote_types_proto_msgTypes[5]
mi := &file_prometheus_remote_types_proto_msgTypes[7]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -537,7 +907,7 @@ func (x *Labels) String() string {
func (*Labels) ProtoMessage() {}
func (x *Labels) ProtoReflect() protoreflect.Message {
mi := &file_prometheus_remote_types_proto_msgTypes[5]
mi := &file_prometheus_remote_types_proto_msgTypes[7]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -550,7 +920,7 @@ func (x *Labels) ProtoReflect() protoreflect.Message {
// Deprecated: Use Labels.ProtoReflect.Descriptor instead.
func (*Labels) Descriptor() ([]byte, []int) {
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{5}
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{7}
}
func (x *Labels) GetLabels() []*Label {
@@ -574,7 +944,7 @@ type LabelMatcher struct {
func (x *LabelMatcher) Reset() {
*x = LabelMatcher{}
if protoimpl.UnsafeEnabled {
mi := &file_prometheus_remote_types_proto_msgTypes[6]
mi := &file_prometheus_remote_types_proto_msgTypes[8]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -587,7 +957,7 @@ func (x *LabelMatcher) String() string {
func (*LabelMatcher) ProtoMessage() {}
func (x *LabelMatcher) ProtoReflect() protoreflect.Message {
mi := &file_prometheus_remote_types_proto_msgTypes[6]
mi := &file_prometheus_remote_types_proto_msgTypes[8]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -600,7 +970,7 @@ func (x *LabelMatcher) ProtoReflect() protoreflect.Message {
// Deprecated: Use LabelMatcher.ProtoReflect.Descriptor instead.
func (*LabelMatcher) Descriptor() ([]byte, []int) {
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{6}
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{8}
}
func (x *LabelMatcher) GetType() LabelMatcher_Type {
@@ -641,7 +1011,7 @@ type ReadHints struct {
func (x *ReadHints) Reset() {
*x = ReadHints{}
if protoimpl.UnsafeEnabled {
mi := &file_prometheus_remote_types_proto_msgTypes[7]
mi := &file_prometheus_remote_types_proto_msgTypes[9]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -654,7 +1024,7 @@ func (x *ReadHints) String() string {
func (*ReadHints) ProtoMessage() {}
func (x *ReadHints) ProtoReflect() protoreflect.Message {
mi := &file_prometheus_remote_types_proto_msgTypes[7]
mi := &file_prometheus_remote_types_proto_msgTypes[9]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -667,7 +1037,7 @@ func (x *ReadHints) ProtoReflect() protoreflect.Message {
// Deprecated: Use ReadHints.ProtoReflect.Descriptor instead.
func (*ReadHints) Descriptor() ([]byte, []int) {
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{7}
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{9}
}
func (x *ReadHints) GetStepMs() int64 {
@@ -735,7 +1105,7 @@ type Chunk struct {
func (x *Chunk) Reset() {
*x = Chunk{}
if protoimpl.UnsafeEnabled {
mi := &file_prometheus_remote_types_proto_msgTypes[8]
mi := &file_prometheus_remote_types_proto_msgTypes[10]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -748,7 +1118,7 @@ func (x *Chunk) String() string {
func (*Chunk) ProtoMessage() {}
func (x *Chunk) ProtoReflect() protoreflect.Message {
mi := &file_prometheus_remote_types_proto_msgTypes[8]
mi := &file_prometheus_remote_types_proto_msgTypes[10]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -761,7 +1131,7 @@ func (x *Chunk) ProtoReflect() protoreflect.Message {
// Deprecated: Use Chunk.ProtoReflect.Descriptor instead.
func (*Chunk) Descriptor() ([]byte, []int) {
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{8}
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{10}
}
func (x *Chunk) GetMinTimeMs() int64 {
@@ -807,7 +1177,7 @@ type ChunkedSeries struct {
func (x *ChunkedSeries) Reset() {
*x = ChunkedSeries{}
if protoimpl.UnsafeEnabled {
mi := &file_prometheus_remote_types_proto_msgTypes[9]
mi := &file_prometheus_remote_types_proto_msgTypes[11]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -820,7 +1190,7 @@ func (x *ChunkedSeries) String() string {
func (*ChunkedSeries) ProtoMessage() {}
func (x *ChunkedSeries) ProtoReflect() protoreflect.Message {
mi := &file_prometheus_remote_types_proto_msgTypes[9]
mi := &file_prometheus_remote_types_proto_msgTypes[11]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -833,7 +1203,7 @@ func (x *ChunkedSeries) ProtoReflect() protoreflect.Message {
// Deprecated: Use ChunkedSeries.ProtoReflect.Descriptor instead.
func (*ChunkedSeries) Descriptor() ([]byte, []int) {
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{9}
return file_prometheus_remote_types_proto_rawDescGZIP(), []int{11}
}
func (x *ChunkedSeries) GetLabels() []*Label {
@@ -884,55 +1254,111 @@ var file_prometheus_remote_types_proto_rawDesc = []byte{
0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x01, 0x52, 0x05,
0x76, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61,
0x6d, 0x70, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74,
0x61, 0x6d, 0x70, 0x22, 0x99, 0x01, 0x0a, 0x0a, 0x54, 0x69, 0x6d, 0x65, 0x53, 0x65, 0x72, 0x69,
0x65, 0x73, 0x12, 0x29, 0x0a, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x18, 0x01, 0x20, 0x03,
0x28, 0x0b, 0x32, 0x11, 0x2e, 0x70, 0x72, 0x6f, 0x6d, 0x65, 0x74, 0x68, 0x65, 0x75, 0x73, 0x2e,
0x4c, 0x61, 0x62, 0x65, 0x6c, 0x52, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x12, 0x2c, 0x0a,
0x07, 0x73, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x12,
0x2e, 0x70, 0x72, 0x6f, 0x6d, 0x65, 0x74, 0x68, 0x65, 0x75, 0x73, 0x2e, 0x53, 0x61, 0x6d, 0x70,
0x6c, 0x65, 0x52, 0x07, 0x73, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x73, 0x12, 0x32, 0x0a, 0x09, 0x65,
0x78, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x72, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x14,
0x2e, 0x70, 0x72, 0x6f, 0x6d, 0x65, 0x74, 0x68, 0x65, 0x75, 0x73, 0x2e, 0x45, 0x78, 0x65, 0x6d,
0x70, 0x6c, 0x61, 0x72, 0x52, 0x09, 0x65, 0x78, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x72, 0x73, 0x22,
0x31, 0x0a, 0x05, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65,
0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x14, 0x0a, 0x05,
0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c,
0x75, 0x65, 0x22, 0x33, 0x0a, 0x06, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x12, 0x29, 0x0a, 0x06,
0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x70,
0x72, 0x6f, 0x6d, 0x65, 0x74, 0x68, 0x65, 0x75, 0x73, 0x2e, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x52,
0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x22, 0x95, 0x01, 0x0a, 0x0c, 0x4c, 0x61, 0x62, 0x65,
0x6c, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x65, 0x72, 0x12, 0x31, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65,
0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1d, 0x2e, 0x70, 0x72, 0x6f, 0x6d, 0x65, 0x74, 0x68,
0x65, 0x75, 0x73, 0x2e, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x65, 0x72,
0x2e, 0x54, 0x79, 0x70, 0x65, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x6e,
0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12,
0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05,
0x76, 0x61, 0x6c, 0x75, 0x65, 0x22, 0x28, 0x0a, 0x04, 0x54, 0x79, 0x70, 0x65, 0x12, 0x06, 0x0a,
0x02, 0x45, 0x51, 0x10, 0x00, 0x12, 0x07, 0x0a, 0x03, 0x4e, 0x45, 0x51, 0x10, 0x01, 0x12, 0x06,
0x0a, 0x02, 0x52, 0x45, 0x10, 0x02, 0x12, 0x07, 0x0a, 0x03, 0x4e, 0x52, 0x45, 0x10, 0x03, 0x22,
0xb1, 0x01, 0x0a, 0x09, 0x52, 0x65, 0x61, 0x64, 0x48, 0x69, 0x6e, 0x74, 0x73, 0x12, 0x17, 0x0a,
0x07, 0x73, 0x74, 0x65, 0x70, 0x5f, 0x6d, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06,
0x73, 0x74, 0x65, 0x70, 0x4d, 0x73, 0x12, 0x12, 0x0a, 0x04, 0x66, 0x75, 0x6e, 0x63, 0x18, 0x02,
0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x66, 0x75, 0x6e, 0x63, 0x12, 0x19, 0x0a, 0x08, 0x73, 0x74,
0x61, 0x72, 0x74, 0x5f, 0x6d, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x07, 0x73, 0x74,
0x61, 0x72, 0x74, 0x4d, 0x73, 0x12, 0x15, 0x0a, 0x06, 0x65, 0x6e, 0x64, 0x5f, 0x6d, 0x73, 0x18,
0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x05, 0x65, 0x6e, 0x64, 0x4d, 0x73, 0x12, 0x1a, 0x0a, 0x08,
0x67, 0x72, 0x6f, 0x75, 0x70, 0x69, 0x6e, 0x67, 0x18, 0x05, 0x20, 0x03, 0x28, 0x09, 0x52, 0x08,
0x67, 0x72, 0x6f, 0x75, 0x70, 0x69, 0x6e, 0x67, 0x12, 0x0e, 0x0a, 0x02, 0x62, 0x79, 0x18, 0x06,
0x20, 0x01, 0x28, 0x08, 0x52, 0x02, 0x62, 0x79, 0x12, 0x19, 0x0a, 0x08, 0x72, 0x61, 0x6e, 0x67,
0x65, 0x5f, 0x6d, 0x73, 0x18, 0x07, 0x20, 0x01, 0x28, 0x03, 0x52, 0x07, 0x72, 0x61, 0x6e, 0x67,
0x65, 0x4d, 0x73, 0x22, 0xad, 0x01, 0x0a, 0x05, 0x43, 0x68, 0x75, 0x6e, 0x6b, 0x12, 0x1e, 0x0a,
0x0b, 0x6d, 0x69, 0x6e, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x5f, 0x6d, 0x73, 0x18, 0x01, 0x20, 0x01,
0x28, 0x03, 0x52, 0x09, 0x6d, 0x69, 0x6e, 0x54, 0x69, 0x6d, 0x65, 0x4d, 0x73, 0x12, 0x1e, 0x0a,
0x0b, 0x6d, 0x61, 0x78, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x5f, 0x6d, 0x73, 0x18, 0x02, 0x20, 0x01,
0x28, 0x03, 0x52, 0x09, 0x6d, 0x61, 0x78, 0x54, 0x69, 0x6d, 0x65, 0x4d, 0x73, 0x12, 0x2e, 0x0a,
0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1a, 0x2e, 0x70, 0x72,
0x6f, 0x6d, 0x65, 0x74, 0x68, 0x65, 0x75, 0x73, 0x2e, 0x43, 0x68, 0x75, 0x6e, 0x6b, 0x2e, 0x45,
0x6e, 0x63, 0x6f, 0x64, 0x69, 0x6e, 0x67, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x12, 0x0a,
0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74,
0x61, 0x22, 0x20, 0x0a, 0x08, 0x45, 0x6e, 0x63, 0x6f, 0x64, 0x69, 0x6e, 0x67, 0x12, 0x0b, 0x0a,
0x07, 0x55, 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10, 0x00, 0x12, 0x07, 0x0a, 0x03, 0x58, 0x4f,
0x52, 0x10, 0x01, 0x22, 0x65, 0x0a, 0x0d, 0x43, 0x68, 0x75, 0x6e, 0x6b, 0x65, 0x64, 0x53, 0x65,
0x61, 0x6d, 0x70, 0x22, 0xe4, 0x05, 0x0a, 0x09, 0x48, 0x69, 0x73, 0x74, 0x6f, 0x67, 0x72, 0x61,
0x6d, 0x12, 0x1d, 0x0a, 0x09, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x5f, 0x69, 0x6e, 0x74, 0x18, 0x01,
0x20, 0x01, 0x28, 0x04, 0x48, 0x00, 0x52, 0x08, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x49, 0x6e, 0x74,
0x12, 0x21, 0x0a, 0x0b, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x5f, 0x66, 0x6c, 0x6f, 0x61, 0x74, 0x18,
0x02, 0x20, 0x01, 0x28, 0x01, 0x48, 0x00, 0x52, 0x0a, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x46, 0x6c,
0x6f, 0x61, 0x74, 0x12, 0x10, 0x0a, 0x03, 0x73, 0x75, 0x6d, 0x18, 0x03, 0x20, 0x01, 0x28, 0x01,
0x52, 0x03, 0x73, 0x75, 0x6d, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18,
0x04, 0x20, 0x01, 0x28, 0x11, 0x52, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x25, 0x0a,
0x0e, 0x7a, 0x65, 0x72, 0x6f, 0x5f, 0x74, 0x68, 0x72, 0x65, 0x73, 0x68, 0x6f, 0x6c, 0x64, 0x18,
0x05, 0x20, 0x01, 0x28, 0x01, 0x52, 0x0d, 0x7a, 0x65, 0x72, 0x6f, 0x54, 0x68, 0x72, 0x65, 0x73,
0x68, 0x6f, 0x6c, 0x64, 0x12, 0x26, 0x0a, 0x0e, 0x7a, 0x65, 0x72, 0x6f, 0x5f, 0x63, 0x6f, 0x75,
0x6e, 0x74, 0x5f, 0x69, 0x6e, 0x74, 0x18, 0x06, 0x20, 0x01, 0x28, 0x04, 0x48, 0x01, 0x52, 0x0c,
0x7a, 0x65, 0x72, 0x6f, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x49, 0x6e, 0x74, 0x12, 0x2a, 0x0a, 0x10,
0x7a, 0x65, 0x72, 0x6f, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x5f, 0x66, 0x6c, 0x6f, 0x61, 0x74,
0x18, 0x07, 0x20, 0x01, 0x28, 0x01, 0x48, 0x01, 0x52, 0x0e, 0x7a, 0x65, 0x72, 0x6f, 0x43, 0x6f,
0x75, 0x6e, 0x74, 0x46, 0x6c, 0x6f, 0x61, 0x74, 0x12, 0x3d, 0x0a, 0x0e, 0x6e, 0x65, 0x67, 0x61,
0x74, 0x69, 0x76, 0x65, 0x5f, 0x73, 0x70, 0x61, 0x6e, 0x73, 0x18, 0x08, 0x20, 0x03, 0x28, 0x0b,
0x32, 0x16, 0x2e, 0x70, 0x72, 0x6f, 0x6d, 0x65, 0x74, 0x68, 0x65, 0x75, 0x73, 0x2e, 0x42, 0x75,
0x63, 0x6b, 0x65, 0x74, 0x53, 0x70, 0x61, 0x6e, 0x52, 0x0d, 0x6e, 0x65, 0x67, 0x61, 0x74, 0x69,
0x76, 0x65, 0x53, 0x70, 0x61, 0x6e, 0x73, 0x12, 0x27, 0x0a, 0x0f, 0x6e, 0x65, 0x67, 0x61, 0x74,
0x69, 0x76, 0x65, 0x5f, 0x64, 0x65, 0x6c, 0x74, 0x61, 0x73, 0x18, 0x09, 0x20, 0x03, 0x28, 0x12,
0x52, 0x0e, 0x6e, 0x65, 0x67, 0x61, 0x74, 0x69, 0x76, 0x65, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x73,
0x12, 0x27, 0x0a, 0x0f, 0x6e, 0x65, 0x67, 0x61, 0x74, 0x69, 0x76, 0x65, 0x5f, 0x63, 0x6f, 0x75,
0x6e, 0x74, 0x73, 0x18, 0x0a, 0x20, 0x03, 0x28, 0x01, 0x52, 0x0e, 0x6e, 0x65, 0x67, 0x61, 0x74,
0x69, 0x76, 0x65, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x73, 0x12, 0x3d, 0x0a, 0x0e, 0x70, 0x6f, 0x73,
0x69, 0x74, 0x69, 0x76, 0x65, 0x5f, 0x73, 0x70, 0x61, 0x6e, 0x73, 0x18, 0x0b, 0x20, 0x03, 0x28,
0x0b, 0x32, 0x16, 0x2e, 0x70, 0x72, 0x6f, 0x6d, 0x65, 0x74, 0x68, 0x65, 0x75, 0x73, 0x2e, 0x42,
0x75, 0x63, 0x6b, 0x65, 0x74, 0x53, 0x70, 0x61, 0x6e, 0x52, 0x0d, 0x70, 0x6f, 0x73, 0x69, 0x74,
0x69, 0x76, 0x65, 0x53, 0x70, 0x61, 0x6e, 0x73, 0x12, 0x27, 0x0a, 0x0f, 0x70, 0x6f, 0x73, 0x69,
0x74, 0x69, 0x76, 0x65, 0x5f, 0x64, 0x65, 0x6c, 0x74, 0x61, 0x73, 0x18, 0x0c, 0x20, 0x03, 0x28,
0x12, 0x52, 0x0e, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x69, 0x76, 0x65, 0x44, 0x65, 0x6c, 0x74, 0x61,
0x73, 0x12, 0x27, 0x0a, 0x0f, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x69, 0x76, 0x65, 0x5f, 0x63, 0x6f,
0x75, 0x6e, 0x74, 0x73, 0x18, 0x0d, 0x20, 0x03, 0x28, 0x01, 0x52, 0x0e, 0x70, 0x6f, 0x73, 0x69,
0x74, 0x69, 0x76, 0x65, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x73, 0x12, 0x3e, 0x0a, 0x0a, 0x72, 0x65,
0x73, 0x65, 0x74, 0x5f, 0x68, 0x69, 0x6e, 0x74, 0x18, 0x0e, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1f,
0x2e, 0x70, 0x72, 0x6f, 0x6d, 0x65, 0x74, 0x68, 0x65, 0x75, 0x73, 0x2e, 0x48, 0x69, 0x73, 0x74,
0x6f, 0x67, 0x72, 0x61, 0x6d, 0x2e, 0x52, 0x65, 0x73, 0x65, 0x74, 0x48, 0x69, 0x6e, 0x74, 0x52,
0x09, 0x72, 0x65, 0x73, 0x65, 0x74, 0x48, 0x69, 0x6e, 0x74, 0x12, 0x1c, 0x0a, 0x09, 0x74, 0x69,
0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x0f, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x74,
0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x12, 0x23, 0x0a, 0x0d, 0x63, 0x75, 0x73, 0x74,
0x6f, 0x6d, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x18, 0x10, 0x20, 0x03, 0x28, 0x01, 0x52,
0x0c, 0x63, 0x75, 0x73, 0x74, 0x6f, 0x6d, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x22, 0x34, 0x0a,
0x09, 0x52, 0x65, 0x73, 0x65, 0x74, 0x48, 0x69, 0x6e, 0x74, 0x12, 0x0b, 0x0a, 0x07, 0x55, 0x4e,
0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10, 0x00, 0x12, 0x07, 0x0a, 0x03, 0x59, 0x45, 0x53, 0x10, 0x01,
0x12, 0x06, 0x0a, 0x02, 0x4e, 0x4f, 0x10, 0x02, 0x12, 0x09, 0x0a, 0x05, 0x47, 0x41, 0x55, 0x47,
0x45, 0x10, 0x03, 0x42, 0x07, 0x0a, 0x05, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x42, 0x0c, 0x0a, 0x0a,
0x7a, 0x65, 0x72, 0x6f, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x22, 0x3c, 0x0a, 0x0a, 0x42, 0x75,
0x63, 0x6b, 0x65, 0x74, 0x53, 0x70, 0x61, 0x6e, 0x12, 0x16, 0x0a, 0x06, 0x6f, 0x66, 0x66, 0x73,
0x65, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x11, 0x52, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74,
0x12, 0x16, 0x0a, 0x06, 0x6c, 0x65, 0x6e, 0x67, 0x74, 0x68, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d,
0x52, 0x06, 0x6c, 0x65, 0x6e, 0x67, 0x74, 0x68, 0x22, 0xd0, 0x01, 0x0a, 0x0a, 0x54, 0x69, 0x6d,
0x65, 0x53, 0x65, 0x72, 0x69, 0x65, 0x73, 0x12, 0x29, 0x0a, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c,
0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x70, 0x72, 0x6f, 0x6d, 0x65, 0x74,
0x68, 0x65, 0x75, 0x73, 0x2e, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x52, 0x06, 0x6c, 0x61, 0x62, 0x65,
0x6c, 0x73, 0x12, 0x2c, 0x0a, 0x07, 0x73, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x73, 0x18, 0x02, 0x20,
0x03, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x70, 0x72, 0x6f, 0x6d, 0x65, 0x74, 0x68, 0x65, 0x75, 0x73,
0x2e, 0x53, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x52, 0x07, 0x73, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x73,
0x12, 0x32, 0x0a, 0x09, 0x65, 0x78, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x72, 0x73, 0x18, 0x03, 0x20,
0x03, 0x28, 0x0b, 0x32, 0x14, 0x2e, 0x70, 0x72, 0x6f, 0x6d, 0x65, 0x74, 0x68, 0x65, 0x75, 0x73,
0x2e, 0x45, 0x78, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x72, 0x52, 0x09, 0x65, 0x78, 0x65, 0x6d, 0x70,
0x6c, 0x61, 0x72, 0x73, 0x12, 0x35, 0x0a, 0x0a, 0x68, 0x69, 0x73, 0x74, 0x6f, 0x67, 0x72, 0x61,
0x6d, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x15, 0x2e, 0x70, 0x72, 0x6f, 0x6d, 0x65,
0x74, 0x68, 0x65, 0x75, 0x73, 0x2e, 0x48, 0x69, 0x73, 0x74, 0x6f, 0x67, 0x72, 0x61, 0x6d, 0x52,
0x0a, 0x68, 0x69, 0x73, 0x74, 0x6f, 0x67, 0x72, 0x61, 0x6d, 0x73, 0x22, 0x31, 0x0a, 0x05, 0x4c,
0x61, 0x62, 0x65, 0x6c, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01,
0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75,
0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x22, 0x33,
0x0a, 0x06, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x12, 0x29, 0x0a, 0x06, 0x6c, 0x61, 0x62, 0x65,
0x6c, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x70, 0x72, 0x6f, 0x6d, 0x65,
0x74, 0x68, 0x65, 0x75, 0x73, 0x2e, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x52, 0x06, 0x6c, 0x61, 0x62,
0x65, 0x6c, 0x73, 0x22, 0x95, 0x01, 0x0a, 0x0c, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x4d, 0x61, 0x74,
0x63, 0x68, 0x65, 0x72, 0x12, 0x31, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01,
0x28, 0x0e, 0x32, 0x1d, 0x2e, 0x70, 0x72, 0x6f, 0x6d, 0x65, 0x74, 0x68, 0x65, 0x75, 0x73, 0x2e,
0x4c, 0x61, 0x62, 0x65, 0x6c, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x65, 0x72, 0x2e, 0x54, 0x79, 0x70,
0x65, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18,
0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x76,
0x61, 0x6c, 0x75, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75,
0x65, 0x22, 0x28, 0x0a, 0x04, 0x54, 0x79, 0x70, 0x65, 0x12, 0x06, 0x0a, 0x02, 0x45, 0x51, 0x10,
0x00, 0x12, 0x07, 0x0a, 0x03, 0x4e, 0x45, 0x51, 0x10, 0x01, 0x12, 0x06, 0x0a, 0x02, 0x52, 0x45,
0x10, 0x02, 0x12, 0x07, 0x0a, 0x03, 0x4e, 0x52, 0x45, 0x10, 0x03, 0x22, 0xb1, 0x01, 0x0a, 0x09,
0x52, 0x65, 0x61, 0x64, 0x48, 0x69, 0x6e, 0x74, 0x73, 0x12, 0x17, 0x0a, 0x07, 0x73, 0x74, 0x65,
0x70, 0x5f, 0x6d, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x73, 0x74, 0x65, 0x70,
0x4d, 0x73, 0x12, 0x12, 0x0a, 0x04, 0x66, 0x75, 0x6e, 0x63, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09,
0x52, 0x04, 0x66, 0x75, 0x6e, 0x63, 0x12, 0x19, 0x0a, 0x08, 0x73, 0x74, 0x61, 0x72, 0x74, 0x5f,
0x6d, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x07, 0x73, 0x74, 0x61, 0x72, 0x74, 0x4d,
0x73, 0x12, 0x15, 0x0a, 0x06, 0x65, 0x6e, 0x64, 0x5f, 0x6d, 0x73, 0x18, 0x04, 0x20, 0x01, 0x28,
0x03, 0x52, 0x05, 0x65, 0x6e, 0x64, 0x4d, 0x73, 0x12, 0x1a, 0x0a, 0x08, 0x67, 0x72, 0x6f, 0x75,
0x70, 0x69, 0x6e, 0x67, 0x18, 0x05, 0x20, 0x03, 0x28, 0x09, 0x52, 0x08, 0x67, 0x72, 0x6f, 0x75,
0x70, 0x69, 0x6e, 0x67, 0x12, 0x0e, 0x0a, 0x02, 0x62, 0x79, 0x18, 0x06, 0x20, 0x01, 0x28, 0x08,
0x52, 0x02, 0x62, 0x79, 0x12, 0x19, 0x0a, 0x08, 0x72, 0x61, 0x6e, 0x67, 0x65, 0x5f, 0x6d, 0x73,
0x18, 0x07, 0x20, 0x01, 0x28, 0x03, 0x52, 0x07, 0x72, 0x61, 0x6e, 0x67, 0x65, 0x4d, 0x73, 0x22,
0xd1, 0x01, 0x0a, 0x05, 0x43, 0x68, 0x75, 0x6e, 0x6b, 0x12, 0x1e, 0x0a, 0x0b, 0x6d, 0x69, 0x6e,
0x5f, 0x74, 0x69, 0x6d, 0x65, 0x5f, 0x6d, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09,
0x6d, 0x69, 0x6e, 0x54, 0x69, 0x6d, 0x65, 0x4d, 0x73, 0x12, 0x1e, 0x0a, 0x0b, 0x6d, 0x61, 0x78,
0x5f, 0x74, 0x69, 0x6d, 0x65, 0x5f, 0x6d, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09,
0x6d, 0x61, 0x78, 0x54, 0x69, 0x6d, 0x65, 0x4d, 0x73, 0x12, 0x2e, 0x0a, 0x04, 0x74, 0x79, 0x70,
0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1a, 0x2e, 0x70, 0x72, 0x6f, 0x6d, 0x65, 0x74,
0x68, 0x65, 0x75, 0x73, 0x2e, 0x43, 0x68, 0x75, 0x6e, 0x6b, 0x2e, 0x45, 0x6e, 0x63, 0x6f, 0x64,
0x69, 0x6e, 0x67, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74,
0x61, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x22, 0x44, 0x0a,
0x08, 0x45, 0x6e, 0x63, 0x6f, 0x64, 0x69, 0x6e, 0x67, 0x12, 0x0b, 0x0a, 0x07, 0x55, 0x4e, 0x4b,
0x4e, 0x4f, 0x57, 0x4e, 0x10, 0x00, 0x12, 0x07, 0x0a, 0x03, 0x58, 0x4f, 0x52, 0x10, 0x01, 0x12,
0x0d, 0x0a, 0x09, 0x48, 0x49, 0x53, 0x54, 0x4f, 0x47, 0x52, 0x41, 0x4d, 0x10, 0x02, 0x12, 0x13,
0x0a, 0x0f, 0x46, 0x4c, 0x4f, 0x41, 0x54, 0x5f, 0x48, 0x49, 0x53, 0x54, 0x4f, 0x47, 0x52, 0x41,
0x4d, 0x10, 0x03, 0x22, 0x65, 0x0a, 0x0d, 0x43, 0x68, 0x75, 0x6e, 0x6b, 0x65, 0x64, 0x53, 0x65,
0x72, 0x69, 0x65, 0x73, 0x12, 0x29, 0x0a, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x18, 0x01,
0x20, 0x03, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x70, 0x72, 0x6f, 0x6d, 0x65, 0x74, 0x68, 0x65, 0x75,
0x73, 0x2e, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x52, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x12,
@@ -958,39 +1384,46 @@ func file_prometheus_remote_types_proto_rawDescGZIP() []byte {
return file_prometheus_remote_types_proto_rawDescData
}
var file_prometheus_remote_types_proto_enumTypes = make([]protoimpl.EnumInfo, 3)
var file_prometheus_remote_types_proto_msgTypes = make([]protoimpl.MessageInfo, 10)
var file_prometheus_remote_types_proto_enumTypes = make([]protoimpl.EnumInfo, 4)
var file_prometheus_remote_types_proto_msgTypes = make([]protoimpl.MessageInfo, 12)
var file_prometheus_remote_types_proto_goTypes = []interface{}{
(MetricMetadata_MetricType)(0), // 0: prometheus.MetricMetadata.MetricType
(LabelMatcher_Type)(0), // 1: prometheus.LabelMatcher.Type
(Chunk_Encoding)(0), // 2: prometheus.Chunk.Encoding
(*MetricMetadata)(nil), // 3: prometheus.MetricMetadata
(*Sample)(nil), // 4: prometheus.Sample
(*Exemplar)(nil), // 5: prometheus.Exemplar
(*TimeSeries)(nil), // 6: prometheus.TimeSeries
(*Label)(nil), // 7: prometheus.Label
(*Labels)(nil), // 8: prometheus.Labels
(*LabelMatcher)(nil), // 9: prometheus.LabelMatcher
(*ReadHints)(nil), // 10: prometheus.ReadHints
(*Chunk)(nil), // 11: prometheus.Chunk
(*ChunkedSeries)(nil), // 12: prometheus.ChunkedSeries
(Histogram_ResetHint)(0), // 1: prometheus.Histogram.ResetHint
(LabelMatcher_Type)(0), // 2: prometheus.LabelMatcher.Type
(Chunk_Encoding)(0), // 3: prometheus.Chunk.Encoding
(*MetricMetadata)(nil), // 4: prometheus.MetricMetadata
(*Sample)(nil), // 5: prometheus.Sample
(*Exemplar)(nil), // 6: prometheus.Exemplar
(*Histogram)(nil), // 7: prometheus.Histogram
(*BucketSpan)(nil), // 8: prometheus.BucketSpan
(*TimeSeries)(nil), // 9: prometheus.TimeSeries
(*Label)(nil), // 10: prometheus.Label
(*Labels)(nil), // 11: prometheus.Labels
(*LabelMatcher)(nil), // 12: prometheus.LabelMatcher
(*ReadHints)(nil), // 13: prometheus.ReadHints
(*Chunk)(nil), // 14: prometheus.Chunk
(*ChunkedSeries)(nil), // 15: prometheus.ChunkedSeries
}
var file_prometheus_remote_types_proto_depIdxs = []int32{
0, // 0: prometheus.MetricMetadata.type:type_name -> prometheus.MetricMetadata.MetricType
7, // 1: prometheus.Exemplar.labels:type_name -> prometheus.Label
7, // 2: prometheus.TimeSeries.labels:type_name -> prometheus.Label
4, // 3: prometheus.TimeSeries.samples:type_name -> prometheus.Sample
5, // 4: prometheus.TimeSeries.exemplars:type_name -> prometheus.Exemplar
7, // 5: prometheus.Labels.labels:type_name -> prometheus.Label
1, // 6: prometheus.LabelMatcher.type:type_name -> prometheus.LabelMatcher.Type
2, // 7: prometheus.Chunk.type:type_name -> prometheus.Chunk.Encoding
7, // 8: prometheus.ChunkedSeries.labels:type_name -> prometheus.Label
11, // 9: prometheus.ChunkedSeries.chunks:type_name -> prometheus.Chunk
10, // [10:10] is the sub-list for method output_type
10, // [10:10] is the sub-list for method input_type
10, // [10:10] is the sub-list for extension type_name
10, // [10:10] is the sub-list for extension extendee
0, // [0:10] is the sub-list for field type_name
10, // 1: prometheus.Exemplar.labels:type_name -> prometheus.Label
8, // 2: prometheus.Histogram.negative_spans:type_name -> prometheus.BucketSpan
8, // 3: prometheus.Histogram.positive_spans:type_name -> prometheus.BucketSpan
1, // 4: prometheus.Histogram.reset_hint:type_name -> prometheus.Histogram.ResetHint
10, // 5: prometheus.TimeSeries.labels:type_name -> prometheus.Label
5, // 6: prometheus.TimeSeries.samples:type_name -> prometheus.Sample
6, // 7: prometheus.TimeSeries.exemplars:type_name -> prometheus.Exemplar
7, // 8: prometheus.TimeSeries.histograms:type_name -> prometheus.Histogram
10, // 9: prometheus.Labels.labels:type_name -> prometheus.Label
2, // 10: prometheus.LabelMatcher.type:type_name -> prometheus.LabelMatcher.Type
3, // 11: prometheus.Chunk.type:type_name -> prometheus.Chunk.Encoding
10, // 12: prometheus.ChunkedSeries.labels:type_name -> prometheus.Label
14, // 13: prometheus.ChunkedSeries.chunks:type_name -> prometheus.Chunk
14, // [14:14] is the sub-list for method output_type
14, // [14:14] is the sub-list for method input_type
14, // [14:14] is the sub-list for extension type_name
14, // [14:14] is the sub-list for extension extendee
0, // [0:14] is the sub-list for field type_name
}
func init() { file_prometheus_remote_types_proto_init() }
@@ -1036,7 +1469,7 @@ func file_prometheus_remote_types_proto_init() {
}
}
file_prometheus_remote_types_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*TimeSeries); i {
switch v := v.(*Histogram); i {
case 0:
return &v.state
case 1:
@@ -1048,7 +1481,7 @@ func file_prometheus_remote_types_proto_init() {
}
}
file_prometheus_remote_types_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Label); i {
switch v := v.(*BucketSpan); i {
case 0:
return &v.state
case 1:
@@ -1060,7 +1493,7 @@ func file_prometheus_remote_types_proto_init() {
}
}
file_prometheus_remote_types_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Labels); i {
switch v := v.(*TimeSeries); i {
case 0:
return &v.state
case 1:
@@ -1072,7 +1505,7 @@ func file_prometheus_remote_types_proto_init() {
}
}
file_prometheus_remote_types_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*LabelMatcher); i {
switch v := v.(*Label); i {
case 0:
return &v.state
case 1:
@@ -1084,7 +1517,7 @@ func file_prometheus_remote_types_proto_init() {
}
}
file_prometheus_remote_types_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ReadHints); i {
switch v := v.(*Labels); i {
case 0:
return &v.state
case 1:
@@ -1096,7 +1529,7 @@ func file_prometheus_remote_types_proto_init() {
}
}
file_prometheus_remote_types_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Chunk); i {
switch v := v.(*LabelMatcher); i {
case 0:
return &v.state
case 1:
@@ -1108,6 +1541,30 @@ func file_prometheus_remote_types_proto_init() {
}
}
file_prometheus_remote_types_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ReadHints); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_prometheus_remote_types_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Chunk); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_prometheus_remote_types_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ChunkedSeries); i {
case 0:
return &v.state
@@ -1120,13 +1577,19 @@ func file_prometheus_remote_types_proto_init() {
}
}
}
file_prometheus_remote_types_proto_msgTypes[3].OneofWrappers = []interface{}{
(*Histogram_CountInt)(nil),
(*Histogram_CountFloat)(nil),
(*Histogram_ZeroCountInt)(nil),
(*Histogram_ZeroCountFloat)(nil),
}
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: file_prometheus_remote_types_proto_rawDesc,
NumEnums: 3,
NumMessages: 10,
NumEnums: 4,
NumMessages: 12,
NumExtensions: 0,
NumServices: 0,
},