mimirpb

package
v0.0.0-...-748a726 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2024 License: AGPL-3.0 Imports: 27 Imported by: 15

Documentation

Index

Constants

View Source 
const (
	// MinimumHistogramSchema is the minimum schema for a histogram.
	// Currently, it is -4, hardcoded and not exported from either
	// Prometheus or client_golang, so we define it here.
	MinimumHistogramSchema = -4

	// MaximumHistogramSchema is the minimum schema for a histogram.
	// Currently, it is 8, hardcoded and not exported from either
	// Prometheus or client_golang, so we define it here.
	MaximumHistogramSchema = 8
)
View Source 
const QueryResponseMimeType = QueryResponseMimeTypeType + "/" + QueryResponseMimeTypeSubType
View Source 
const QueryResponseMimeTypeSubType = "vnd.mimir.queryresponse+protobuf"
View Source 
const QueryResponseMimeTypeType = "application"

Variables

View Source 
var (
	ErrInvalidLengthMimir = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMimir   = fmt.Errorf("proto: integer overflow")
)
View Source 
var ErrorCause_name = map[int32]string{
	0:  "UNKNOWN_CAUSE",
	1:  "REPLICAS_DID_NOT_MATCH",
	2:  "TOO_MANY_CLUSTERS",
	3:  "BAD_DATA",
	4:  "INGESTION_RATE_LIMITED",
	5:  "REQUEST_RATE_LIMITED",
	6:  "INSTANCE_LIMIT",
	7:  "SERVICE_UNAVAILABLE",
	8:  "TSDB_UNAVAILABLE",
	9:  "TOO_BUSY",
	10: "CIRCUIT_BREAKER_OPEN",
	11: "METHOD_NOT_ALLOWED",
}
View Source 
var ErrorCause_value = map[string]int32{
	"UNKNOWN_CAUSE":          0,
	"REPLICAS_DID_NOT_MATCH": 1,
	"TOO_MANY_CLUSTERS":      2,
	"BAD_DATA":               3,
	"INGESTION_RATE_LIMITED": 4,
	"REQUEST_RATE_LIMITED":   5,
	"INSTANCE_LIMIT":         6,
	"SERVICE_UNAVAILABLE":    7,
	"TSDB_UNAVAILABLE":       8,
	"TOO_BUSY":               9,
	"CIRCUIT_BREAKER_OPEN":   10,
	"METHOD_NOT_ALLOWED":     11,
}
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 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 QueryResponse_ErrorType_name = map[int32]string{
	0: "NONE",
	1: "TIMEOUT",
	2: "CANCELED",
	3: "EXECUTION",
	4: "BAD_DATA",
	5: "INTERNAL",
	6: "UNAVAILABLE",
	7: "NOT_FOUND",
	8: "NOT_ACCEPTABLE",
}
View Source 
var QueryResponse_ErrorType_value = map[string]int32{
	"NONE":           0,
	"TIMEOUT":        1,
	"CANCELED":       2,
	"EXECUTION":      3,
	"BAD_DATA":       4,
	"INTERNAL":       5,
	"UNAVAILABLE":    6,
	"NOT_FOUND":      7,
	"NOT_ACCEPTABLE": 8,
}
View Source 
var QueryResponse_Status_name = map[int32]string{
	0: "ERROR",
	1: "SUCCESS",
}
View Source 
var QueryResponse_Status_value = map[string]int32{
	"ERROR":   0,
	"SUCCESS": 1,
}
View Source 
var TimeseriesUnmarshalCachingEnabled = true
View Source 
var WriteRequest_SourceEnum_name = map[int32]string{
	0: "API",
	1: "RULE",
}
View Source 
var WriteRequest_SourceEnum_value = map[string]int32{
	"API":  0,
	"RULE": 1,
}

Functions

func ClearExemplars 

func ClearExemplars(ts *TimeSeries)

ClearExemplars safely removes exemplars from TimeSeries.

func CompareLabelAdapters 

func CompareLabelAdapters(a, b []LabelAdapter) int

CompareLabelAdapters returns 0 if a==b, <0 if a < b, and >0 if a > b.

func CopyLabels 

func CopyLabels(input []labels.Label) labels.Labels

Copy data in Labels, such that any future Overwrite of input won't modify the returned value. We make a single block of bytes to hold all strings, to save memory compared to Go rounding up the allocations.

func FromExemplarProtosToExemplars 

func FromExemplarProtosToExemplars(es []Exemplar) []exemplar.Exemplar

func FromFloatHistogramProtoToFloatHistogram 

func FromFloatHistogramProtoToFloatHistogram(hp *Histogram) *histogram.FloatHistogram

func FromFloatHistogramToPromHistogram 

func FromFloatHistogramToPromHistogram(h *histogram.FloatHistogram) *model.SampleHistogram

FromFloatHistogramToPromHistogram converts histogram.FloatHistogram to model.SampleHistogram.

func FromHistogramProtoToFloatHistogram 

func FromHistogramProtoToFloatHistogram(hp *Histogram) *histogram.FloatHistogram

func FromHistogramProtoToHistogram 

func FromHistogramProtoToHistogram(hp *Histogram) *histogram.Histogram

func FromHistogramProtoToPromHistogram 

func FromHistogramProtoToPromHistogram(hp *Histogram) *model.SampleHistogram

func FromHistogramToPromHistogram 

func FromHistogramToPromHistogram(h *histogram.Histogram) *model.SampleHistogram

func FromLabelAdaptersOverwriteLabels 

func FromLabelAdaptersOverwriteLabels(_ *labels.ScratchBuilder, ls []LabelAdapter, dest *labels.Labels)

This is like FromLabelAdaptersToLabels but easier for stringlabels to implement.

func FromLabelAdaptersToBuilder 

func FromLabelAdaptersToBuilder(ls []LabelAdapter, builder *labels.Builder)

FromLabelAdaptersToBuilder converts []LabelAdapter to labels.Builder.

func FromLabelAdaptersToLabels 

func FromLabelAdaptersToLabels(ls []LabelAdapter) labels.Labels

FromLabelAdaptersToLabels casts []LabelAdapter to labels.Labels. It uses unsafe, but as LabelAdapter == labels.Label this should be safe. This allows us to use labels.Labels directly in protos.

Note: while resulting labels.Labels is supposedly sorted, this function doesn't enforce that. If input is not sorted, output will be wrong.

func FromLabelAdaptersToLabelsWithCopy 

func FromLabelAdaptersToLabelsWithCopy(input []LabelAdapter) labels.Labels

FromLabelAdaptersToLabelsWithCopy converts []LabelAdapter to labels.Labels. Do NOT use unsafe to convert between data types because this function may get in input labels whose data structure is reused.

func FromLabelAdaptersToMetric 

func FromLabelAdaptersToMetric(ls []LabelAdapter) model.Metric

FromLabelAdaptersToMetric converts []LabelAdapter to a model.Metric. Don't do this on any performance sensitive paths.

func FromLabelAdaptersToString 

func FromLabelAdaptersToString(ls []LabelAdapter) string

FromLabelAdaptersToString formats label adapters as a metric name with labels, while preserving label order, and keeping duplicates. If there are multiple "__name__" labels, only first one is used as metric name, other ones will be included as regular labels.

func FromMimirSampleToPromHistogram 

func FromMimirSampleToPromHistogram(src *SampleHistogram) *model.SampleHistogram

func HashAdd32 

func HashAdd32(h uint32, s string) uint32

HashAdd32 adds a string to an fnv32 hash value, returning the updated hash. Note this is the same algorithm as Go stdlib `sum32.Write()`

func HashAdd32a 

func HashAdd32a(h uint32, s string) uint32

HashAdd32a adds a string to an fnv32a hash value, returning the updated hash. Note this is the same algorithm as Go stdlib `sum32.Write()`

func HashAddByte32 

func HashAddByte32(h uint32, b byte) uint32

HashAddByte32 adds a byte to an fnv32 hash value, returning the updated hash.

func HashAddByte32a 

func HashAddByte32a(h uint32, b byte) uint32

HashAddByte32a adds a byte to an fnv32a hash value, returning the updated hash.

func HashNew32 

func HashNew32() uint32

HashNew32 initializes a new fnv32 hash value.

func HashNew32a 

func HashNew32a() uint32

HashNew32a initializies a new fnv32a hash value.

func IsClientError 

func IsClientError(err error) bool

IsClientError returns true if err is a gRPC or HTTPgRPC error whose cause is a well known client error.

func MetricMetadataMetricTypeToMetricType 

func MetricMetadataMetricTypeToMetricType(mt MetricMetadata_MetricType) model.MetricType

MetricMetadataMetricTypeToMetricType converts a metric type from our internal client to a Prometheus one.

func ReusePreallocTimeseries 

func ReusePreallocTimeseries(ts *PreallocTimeseries)

ReusePreallocTimeseries puts the timeseries and the yoloSlice back into their respective pools for re-use.

func ReuseSlice 

func ReuseSlice(ts []PreallocTimeseries)

ReuseSlice puts the slice back into a sync.Pool for reuse.

func ReuseTimeseries 

func ReuseTimeseries(ts *TimeSeries)

ReuseTimeseries puts the timeseries back into a sync.Pool for reuse.

func SampleJsoniterDecode 

func SampleJsoniterDecode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

func SampleJsoniterEncode 

func SampleJsoniterEncode(ptr unsafe.Pointer, stream *jsoniter.Stream)

func ShardByAllLabelAdapters 

func ShardByAllLabelAdapters(userID string, ls []LabelAdapter) uint32

ShardByAllLabelAdapters is like ShardByAllLabel, but uses LabelAdapter type.

func ShardByAllLabels 

func ShardByAllLabels(userID string, ls labels.Labels) uint32

ShardByAllLabels returns the token for given user and series.

ShardByAllLabels generates different values for different order of same labels.

func ShardByMetricName 

func ShardByMetricName(userID string, metricName string) uint32

ShardByMetricName returns the token for the given metric. The provided metricName is guaranteed to not be retained.

func ShardByUser 

func ShardByUser(userID string) uint32

Types

type BucketSpan 

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).

BucketSpan is based on Prometheus' histogram.Span type defined in https://github.com/prometheus/prometheus/blob/main/model/histogram/histogram.go. The fields below must be the same types and in the same order Prometheus' histogram.Span type so we can cast between them safely.

func (*BucketSpan) Descriptor 

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

func (*BucketSpan) Equal 

func (this *BucketSpan) Equal(that interface{}) bool

func (*BucketSpan) GetLength 

func (m *BucketSpan) GetLength() uint32

func (*BucketSpan) GetOffset 

func (m *BucketSpan) GetOffset() int32

func (*BucketSpan) GoString 

func (this *BucketSpan) GoString() string

func (*BucketSpan) Marshal 

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

func (*BucketSpan) MarshalTo 

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

func (*BucketSpan) MarshalToSizedBuffer 

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

func (*BucketSpan) ProtoMessage 

func (*BucketSpan) ProtoMessage()

func (*BucketSpan) Reset 

func (m *BucketSpan) Reset()

func (*BucketSpan) Size 

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

func (*BucketSpan) String 

func (this *BucketSpan) String() string

func (*BucketSpan) Unmarshal 

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

func (*BucketSpan) XXX_DiscardUnknown 

func (m *BucketSpan) XXX_DiscardUnknown()

func (*BucketSpan) XXX_Marshal 

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

func (*BucketSpan) XXX_Merge 

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

func (*BucketSpan) XXX_Size 

func (m *BucketSpan) XXX_Size() int

func (*BucketSpan) XXX_Unmarshal 

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

type ErrorCause 

type ErrorCause int32
const (
	UNKNOWN_CAUSE          ErrorCause = 0
	REPLICAS_DID_NOT_MATCH ErrorCause = 1
	TOO_MANY_CLUSTERS      ErrorCause = 2
	BAD_DATA               ErrorCause = 3
	INGESTION_RATE_LIMITED ErrorCause = 4
	REQUEST_RATE_LIMITED   ErrorCause = 5
	INSTANCE_LIMIT         ErrorCause = 6
	SERVICE_UNAVAILABLE    ErrorCause = 7
	TSDB_UNAVAILABLE       ErrorCause = 8
	TOO_BUSY               ErrorCause = 9
	CIRCUIT_BREAKER_OPEN   ErrorCause = 10
	METHOD_NOT_ALLOWED     ErrorCause = 11
)

func (ErrorCause) EnumDescriptor 

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

func (ErrorCause) String 

func (x ErrorCause) String() string

type ErrorDetails 

type ErrorDetails struct {
	Cause ErrorCause `protobuf:"varint,1,opt,name=Cause,proto3,enum=cortexpb.ErrorCause" json:"Cause,omitempty"`
}

func (*ErrorDetails) Descriptor 

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

func (*ErrorDetails) Equal 

func (this *ErrorDetails) Equal(that interface{}) bool

func (*ErrorDetails) GetCause 

func (m *ErrorDetails) GetCause() ErrorCause

func (*ErrorDetails) GoString 

func (this *ErrorDetails) GoString() string

func (*ErrorDetails) Marshal 

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

func (*ErrorDetails) MarshalTo 

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

func (*ErrorDetails) MarshalToSizedBuffer 

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

func (*ErrorDetails) ProtoMessage 

func (*ErrorDetails) ProtoMessage()

func (*ErrorDetails) Reset 

func (m *ErrorDetails) Reset()

func (*ErrorDetails) Size 

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

func (*ErrorDetails) String 

func (this *ErrorDetails) String() string

func (*ErrorDetails) Unmarshal 

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

func (*ErrorDetails) XXX_DiscardUnknown 

func (m *ErrorDetails) XXX_DiscardUnknown()

func (*ErrorDetails) XXX_Marshal 

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

func (*ErrorDetails) XXX_Merge 

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

func (*ErrorDetails) XXX_Size 

func (m *ErrorDetails) XXX_Size() int

func (*ErrorDetails) XXX_Unmarshal 

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

type Exemplar 

type Exemplar struct {
	// Exemplar labels, different than series labels
	Labels      []LabelAdapter `protobuf:"bytes,1,rep,name=labels,proto3,customtype=LabelAdapter" json:"labels"`
	Value       float64        `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
	TimestampMs int64          `protobuf:"varint,3,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"`
}

func FromExemplarsToExemplarProtos 

func FromExemplarsToExemplarProtos(es []exemplar.Exemplar) []Exemplar

func (*Exemplar) Descriptor 

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

func (*Exemplar) Equal 

func (this *Exemplar) Equal(that interface{}) bool

func (*Exemplar) GetTimestampMs 

func (m *Exemplar) GetTimestampMs() int64

func (*Exemplar) GetValue 

func (m *Exemplar) GetValue() float64

func (*Exemplar) GoString 

func (this *Exemplar) GoString() string

func (*Exemplar) Marshal 

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

func (*Exemplar) MarshalTo 

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

func (*Exemplar) MarshalToSizedBuffer 

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

func (*Exemplar) ProtoMessage 

func (*Exemplar) ProtoMessage()

func (*Exemplar) Reset 

func (m *Exemplar) Reset()

func (*Exemplar) Size 

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

func (*Exemplar) String 

func (this *Exemplar) String() string

func (*Exemplar) Unmarshal 

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

func (*Exemplar) XXX_DiscardUnknown 

func (m *Exemplar) XXX_DiscardUnknown()

func (*Exemplar) XXX_Marshal 

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

func (*Exemplar) XXX_Merge 

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

func (*Exemplar) XXX_Size 

func (m *Exemplar) XXX_Size() int

func (*Exemplar) XXX_Unmarshal 

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

type FloatHistogram 

type FloatHistogram struct {
	CounterResetHint github_com_prometheus_prometheus_model_histogram.CounterResetHint `` /* 188-byte string literal not displayed */
	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"`
	ZeroCount        float64                                                           `protobuf:"fixed64,7,opt,name=zero_count,json=zeroCount,proto3" json:"zero_count,omitempty"`
	Count            float64                                                           `protobuf:"fixed64,2,opt,name=count,proto3" json:"count,omitempty"`
	Sum              float64                                                           `protobuf:"fixed64,3,opt,name=sum,proto3" json:"sum,omitempty"`
	PositiveSpans    []BucketSpan                                                      `protobuf:"bytes,11,rep,name=positive_spans,json=positiveSpans,proto3" json:"positive_spans"`
	NegativeSpans    []BucketSpan                                                      `protobuf:"bytes,8,rep,name=negative_spans,json=negativeSpans,proto3" json:"negative_spans"`
	PositiveBuckets  []float64                                                         `protobuf:"fixed64,13,rep,packed,name=positive_buckets,json=positiveBuckets,proto3" json:"positive_buckets,omitempty"`
	NegativeBuckets  []float64                                                         `protobuf:"fixed64,10,rep,packed,name=negative_buckets,json=negativeBuckets,proto3" json:"negative_buckets,omitempty"`
}

FloatHistogram is based on https://github.com/prometheus/prometheus/blob/main/model/histogram/float_histogram.go. The fields below must be the same types and in the same order as Prometheus' histogram.FloatHistogram type so we can cast between them safely.

func FloatHistogramFromPrometheusModel 

func FloatHistogramFromPrometheusModel(h *histogram.FloatHistogram) *FloatHistogram

func (*FloatHistogram) Descriptor 

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

func (*FloatHistogram) Equal 

func (this *FloatHistogram) Equal(that interface{}) bool

func (*FloatHistogram) GetCount 

func (m *FloatHistogram) GetCount() float64

func (*FloatHistogram) GetCounterResetHint 

func (m *FloatHistogram) GetCounterResetHint() github_com_prometheus_prometheus_model_histogram.CounterResetHint

func (*FloatHistogram) GetNegativeBuckets 

func (m *FloatHistogram) GetNegativeBuckets() []float64

func (*FloatHistogram) GetNegativeSpans 

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

func (*FloatHistogram) GetPositiveBuckets 

func (m *FloatHistogram) GetPositiveBuckets() []float64

func (*FloatHistogram) GetPositiveSpans 

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

func (*FloatHistogram) GetSchema 

func (m *FloatHistogram) GetSchema() int32

func (*FloatHistogram) GetSum 

func (m *FloatHistogram) GetSum() float64

func (*FloatHistogram) GetZeroCount 

func (m *FloatHistogram) GetZeroCount() float64

func (*FloatHistogram) GetZeroThreshold 

func (m *FloatHistogram) GetZeroThreshold() float64

func (*FloatHistogram) GoString 

func (this *FloatHistogram) GoString() string

func (*FloatHistogram) Marshal 

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

func (*FloatHistogram) MarshalTo 

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

func (*FloatHistogram) MarshalToSizedBuffer 

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

func (*FloatHistogram) ProtoMessage 

func (*FloatHistogram) ProtoMessage()

func (*FloatHistogram) Reset 

func (m *FloatHistogram) Reset()

func (*FloatHistogram) Size 

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

func (*FloatHistogram) String 

func (this *FloatHistogram) String() string

func (*FloatHistogram) ToPrometheusModel 

func (h *FloatHistogram) ToPrometheusModel() *histogram.FloatHistogram

func (*FloatHistogram) Unmarshal 

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

func (*FloatHistogram) XXX_DiscardUnknown 

func (m *FloatHistogram) XXX_DiscardUnknown()

func (*FloatHistogram) XXX_Marshal 

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

func (*FloatHistogram) XXX_Merge 

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

func (*FloatHistogram) XXX_Size 

func (m *FloatHistogram) XXX_Size() int

func (*FloatHistogram) XXX_Unmarshal 

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

type FloatHistogramPair 

type FloatHistogramPair struct {
	// Fields order MUST match promql.HPoint so that we can cast types between them.
	TimestampMs int64           `protobuf:"varint,2,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"`
	Histogram   *FloatHistogram `protobuf:"bytes,1,opt,name=histogram,proto3" json:"histogram,omitempty"`
}

func FromHPointsToHistograms 

func FromHPointsToHistograms(points []promql.HPoint) []FloatHistogramPair

FromHPointsToHistograms converts []promql.HPoint to []FloatHistogramPair. It uses unsafe.

func (*FloatHistogramPair) Descriptor 

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

func (*FloatHistogramPair) Equal 

func (this *FloatHistogramPair) Equal(that interface{}) bool

func (*FloatHistogramPair) GetHistogram 

func (m *FloatHistogramPair) GetHistogram() *FloatHistogram

func (*FloatHistogramPair) GetTimestampMs 

func (m *FloatHistogramPair) GetTimestampMs() int64

func (*FloatHistogramPair) GoString 

func (this *FloatHistogramPair) GoString() string

func (*FloatHistogramPair) Marshal 

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

func (*FloatHistogramPair) MarshalTo 

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

func (*FloatHistogramPair) MarshalToSizedBuffer 

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

func (*FloatHistogramPair) ProtoMessage 

func (*FloatHistogramPair) ProtoMessage()

func (*FloatHistogramPair) Reset 

func (m *FloatHistogramPair) Reset()

func (*FloatHistogramPair) Size 

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

func (*FloatHistogramPair) String 

func (this *FloatHistogramPair) String() string

func (*FloatHistogramPair) Unmarshal 

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

func (*FloatHistogramPair) XXX_DiscardUnknown 

func (m *FloatHistogramPair) XXX_DiscardUnknown()

func (*FloatHistogramPair) XXX_Marshal 

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

func (*FloatHistogramPair) XXX_Merge 

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

func (*FloatHistogramPair) XXX_Size 

func (m *FloatHistogramPair) XXX_Size() int

func (*FloatHistogramPair) XXX_Unmarshal 

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

type Histogram 

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 `protobuf:"varint,14,opt,name=reset_hint,json=resetHint,proto3,enum=cortexpb.Histogram_ResetHint" json:"reset_hint,omitempty"`
	// timestamp is in ms format
	Timestamp int64 `protobuf:"varint,15,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

This is based on https://github.com/prometheus/prometheus/blob/main/prompb/types.proto

func FromFloatHistogramToHistogramProto 

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

FromFloatHistogramToHistogramProto does not make a deepcopy, slices are referenced

func FromHistogramToHistogramProto 

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

FromHistogramToHistogramProto does not make a deepcopy, slices are referenced

func (*Histogram) Descriptor 

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

func (*Histogram) Equal 

func (this *Histogram) Equal(that interface{}) bool

func (*Histogram) GetCount 

func (m *Histogram) GetCount() isHistogram_Count

func (*Histogram) GetCountFloat 

func (m *Histogram) GetCountFloat() float64

func (*Histogram) GetCountInt 

func (m *Histogram) GetCountInt() uint64

func (*Histogram) GetNegativeCounts 

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

func (*Histogram) GetNegativeDeltas 

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

func (*Histogram) GetNegativeSpans 

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

func (*Histogram) GetPositiveCounts 

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

func (*Histogram) GetPositiveDeltas 

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

func (*Histogram) GetPositiveSpans 

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

func (*Histogram) GetResetHint 

func (m *Histogram) GetResetHint() Histogram_ResetHint

func (*Histogram) GetSchema 

func (m *Histogram) GetSchema() int32

func (*Histogram) GetSum 

func (m *Histogram) GetSum() float64

func (*Histogram) GetTimestamp 

func (m *Histogram) GetTimestamp() int64

func (*Histogram) GetZeroCount 

func (m *Histogram) GetZeroCount() isHistogram_ZeroCount

func (*Histogram) GetZeroCountFloat 

func (m *Histogram) GetZeroCountFloat() float64

func (*Histogram) GetZeroCountInt 

func (m *Histogram) GetZeroCountInt() uint64

func (*Histogram) GetZeroThreshold 

func (m *Histogram) GetZeroThreshold() float64

func (*Histogram) GoString 

func (this *Histogram) GoString() string

func (Histogram) IsFloatHistogram 

func (h Histogram) IsFloatHistogram() bool

func (Histogram) IsGauge 

func (h Histogram) IsGauge() bool

func (*Histogram) Marshal 

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

func (*Histogram) MarshalTo 

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

func (*Histogram) MarshalToSizedBuffer 

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

func (*Histogram) ProtoMessage 

func (*Histogram) ProtoMessage()

func (*Histogram) ReduceResolution 

func (h *Histogram) ReduceResolution() (int, error)

ReduceResolution will reduce the resolution of the histogram by one level. Returns the resulting bucket count and an error if the histogram is not possible to reduce further.

func (*Histogram) Reset 

func (m *Histogram) Reset()

func (*Histogram) Size 

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

func (*Histogram) String 

func (this *Histogram) String() string

func (*Histogram) Unmarshal 

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

func (*Histogram) XXX_DiscardUnknown 

func (m *Histogram) XXX_DiscardUnknown()

func (*Histogram) XXX_Marshal 

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

func (*Histogram) XXX_Merge 

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

func (*Histogram) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Histogram) XXX_Size 

func (m *Histogram) XXX_Size() int

func (*Histogram) XXX_Unmarshal 

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

type HistogramBucket 

type HistogramBucket struct {
	Boundaries int32   `protobuf:"varint,1,opt,name=boundaries,proto3" json:"boundaries,omitempty"`
	Lower      float64 `protobuf:"fixed64,2,opt,name=lower,proto3" json:"lower,omitempty"`
	Upper      float64 `protobuf:"fixed64,3,opt,name=upper,proto3" json:"upper,omitempty"`
	Count      float64 `protobuf:"fixed64,4,opt,name=count,proto3" json:"count,omitempty"`
}

Must keep the same order and type of fields for casting, see SampleHistogram

func (*HistogramBucket) Descriptor 

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

func (*HistogramBucket) Equal 

func (this *HistogramBucket) Equal(that interface{}) bool

func (*HistogramBucket) GetBoundaries 

func (m *HistogramBucket) GetBoundaries() int32

func (*HistogramBucket) GetCount 

func (m *HistogramBucket) GetCount() float64

func (*HistogramBucket) GetLower 

func (m *HistogramBucket) GetLower() float64

func (*HistogramBucket) GetUpper 

func (m *HistogramBucket) GetUpper() float64

func (*HistogramBucket) GoString 

func (this *HistogramBucket) GoString() string

func (*HistogramBucket) Marshal 

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

func (*HistogramBucket) MarshalTo 

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

func (*HistogramBucket) MarshalToSizedBuffer 

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

func (*HistogramBucket) ProtoMessage 

func (*HistogramBucket) ProtoMessage()

func (*HistogramBucket) Reset 

func (m *HistogramBucket) Reset()

func (*HistogramBucket) Size 

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

func (*HistogramBucket) String 

func (this *HistogramBucket) String() string

func (*HistogramBucket) Unmarshal 

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

func (*HistogramBucket) XXX_DiscardUnknown 

func (m *HistogramBucket) XXX_DiscardUnknown()

func (*HistogramBucket) XXX_Marshal 

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

func (*HistogramBucket) XXX_Merge 

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

func (*HistogramBucket) XXX_Size 

func (m *HistogramBucket) XXX_Size() int

func (*HistogramBucket) XXX_Unmarshal 

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

type Histogram_CountFloat 

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

func (*Histogram_CountFloat) Equal 

func (this *Histogram_CountFloat) Equal(that interface{}) bool

func (*Histogram_CountFloat) GoString 

func (this *Histogram_CountFloat) GoString() string

func (*Histogram_CountFloat) MarshalTo 

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

func (*Histogram_CountFloat) MarshalToSizedBuffer 

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

func (*Histogram_CountFloat) Size 

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

func (*Histogram_CountFloat) String 

func (this *Histogram_CountFloat) String() string

type Histogram_CountInt 

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

func (*Histogram_CountInt) Equal 

func (this *Histogram_CountInt) Equal(that interface{}) bool

func (*Histogram_CountInt) GoString 

func (this *Histogram_CountInt) GoString() string

func (*Histogram_CountInt) MarshalTo 

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

func (*Histogram_CountInt) MarshalToSizedBuffer 

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

func (*Histogram_CountInt) Size 

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

func (*Histogram_CountInt) String 

func (this *Histogram_CountInt) String() string

type Histogram_ResetHint 

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 

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

func (Histogram_ResetHint) String 

func (x Histogram_ResetHint) String() string

type Histogram_ZeroCountFloat 

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

func (*Histogram_ZeroCountFloat) Equal 

func (this *Histogram_ZeroCountFloat) Equal(that interface{}) bool

func (*Histogram_ZeroCountFloat) GoString 

func (this *Histogram_ZeroCountFloat) GoString() string

func (*Histogram_ZeroCountFloat) MarshalTo 

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

func (*Histogram_ZeroCountFloat) MarshalToSizedBuffer 

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

func (*Histogram_ZeroCountFloat) Size 

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

func (*Histogram_ZeroCountFloat) String 

func (this *Histogram_ZeroCountFloat) String() string

type Histogram_ZeroCountInt 

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

func (*Histogram_ZeroCountInt) Equal 

func (this *Histogram_ZeroCountInt) Equal(that interface{}) bool

func (*Histogram_ZeroCountInt) GoString 

func (this *Histogram_ZeroCountInt) GoString() string

func (*Histogram_ZeroCountInt) MarshalTo 

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

func (*Histogram_ZeroCountInt) MarshalToSizedBuffer 

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

func (*Histogram_ZeroCountInt) Size 

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

func (*Histogram_ZeroCountInt) String 

func (this *Histogram_ZeroCountInt) String() string

type LabelAdapter 

type LabelAdapter labels.Label

LabelAdapter is a labels.Label that can be marshalled to/from protos.

func FromBuilderToLabelAdapters 

func FromBuilderToLabelAdapters(builder *labels.Builder, _ []LabelAdapter) []LabelAdapter

FromBuilderToLabelAdapters converts labels.Builder to []LabelAdapter.

func FromLabelsToLabelAdapters 

func FromLabelsToLabelAdapters(ls labels.Labels) []LabelAdapter

FromLabelsToLabelAdapters casts labels.Labels to []LabelAdapter. It uses unsafe, but as LabelAdapter == labels.Label this should be safe. This allows us to use labels.Labels directly in protos.

func FromMetricsToLabelAdapters 

func FromMetricsToLabelAdapters(metric model.Metric) []LabelAdapter

FromMetricsToLabelAdapters converts model.Metric to []LabelAdapter. Don't do this on any performance sensitive paths. The result is sorted.

func (*LabelAdapter) Compare 

func (bs *LabelAdapter) Compare(other LabelAdapter) int

Compare implements proto.Comparer.

func (*LabelAdapter) Equal 

func (bs *LabelAdapter) Equal(other LabelAdapter) bool

Equal implements proto.Equaler.

func (*LabelAdapter) Marshal 

func (bs *LabelAdapter) Marshal() ([]byte, error)

Marshal implements proto.Marshaller.

func (*LabelAdapter) MarshalTo 

func (bs *LabelAdapter) MarshalTo(dAtA []byte) (int, error)

func (*LabelAdapter) MarshalToSizedBuffer 

func (bs *LabelAdapter) MarshalToSizedBuffer(buf []byte) (n int, err error)

MarshalTo implements proto.Marshaller.

func (*LabelAdapter) Size 

func (bs *LabelAdapter) Size() (n int)

Size implements proto.Sizer.

func (*LabelAdapter) Unmarshal 

func (bs *LabelAdapter) Unmarshal(dAtA []byte) error

Unmarshal a LabelAdapter, implements proto.Unmarshaller. NB this is a copy of the autogenerated code to unmarshal a LabelPair, with the byte copying replaced with a yoloString.

type LabelPair 

type LabelPair struct {
	Name  []byte `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*LabelPair) Descriptor 

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

func (*LabelPair) Equal 

func (this *LabelPair) Equal(that interface{}) bool

func (*LabelPair) GetName 

func (m *LabelPair) GetName() []byte

func (*LabelPair) GetValue 

func (m *LabelPair) GetValue() []byte

func (*LabelPair) GoString 

func (this *LabelPair) GoString() string

func (*LabelPair) Marshal 

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

func (*LabelPair) MarshalTo 

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

func (*LabelPair) MarshalToSizedBuffer 

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

func (*LabelPair) ProtoMessage 

func (*LabelPair) ProtoMessage()

func (*LabelPair) Reset 

func (m *LabelPair) Reset()

func (*LabelPair) Size 

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

func (*LabelPair) String 

func (this *LabelPair) String() string

func (*LabelPair) Unmarshal 

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

func (*LabelPair) XXX_DiscardUnknown 

func (m *LabelPair) XXX_DiscardUnknown()

func (*LabelPair) XXX_Marshal 

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

func (*LabelPair) XXX_Merge 

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

func (*LabelPair) XXX_Size 

func (m *LabelPair) XXX_Size() int

func (*LabelPair) XXX_Unmarshal 

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

type MatrixData 

type MatrixData struct {
	Series []MatrixSeries `protobuf:"bytes,1,rep,name=series,proto3" json:"series"`
}

func (*MatrixData) Descriptor 

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

func (*MatrixData) Equal 

func (this *MatrixData) Equal(that interface{}) bool

func (*MatrixData) GetSeries 

func (m *MatrixData) GetSeries() []MatrixSeries

func (*MatrixData) GoString 

func (this *MatrixData) GoString() string

func (*MatrixData) Marshal 

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

func (*MatrixData) MarshalTo 

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

func (*MatrixData) MarshalToSizedBuffer 

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

func (*MatrixData) ProtoMessage 

func (*MatrixData) ProtoMessage()

func (*MatrixData) Reset 

func (m *MatrixData) Reset()

func (*MatrixData) Size 

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

func (*MatrixData) String 

func (this *MatrixData) String() string

func (*MatrixData) Unmarshal 

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

func (*MatrixData) XXX_DiscardUnknown 

func (m *MatrixData) XXX_DiscardUnknown()

func (*MatrixData) XXX_Marshal 

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

func (*MatrixData) XXX_Merge 

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

func (*MatrixData) XXX_Size 

func (m *MatrixData) XXX_Size() int

func (*MatrixData) XXX_Unmarshal 

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

type MatrixSeries 

type MatrixSeries struct {
	// Why not use a map<...> here? We want to preserve the order of the labels.
	Metric     []string             `protobuf:"bytes,1,rep,name=metric,proto3" json:"metric,omitempty"`
	Samples    []Sample             `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples"`
	Histograms []FloatHistogramPair `protobuf:"bytes,3,rep,name=histograms,proto3" json:"histograms"`
}

func (*MatrixSeries) Descriptor 

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

func (*MatrixSeries) Equal 

func (this *MatrixSeries) Equal(that interface{}) bool

func (*MatrixSeries) GetHistograms 

func (m *MatrixSeries) GetHistograms() []FloatHistogramPair

func (*MatrixSeries) GetMetric 

func (m *MatrixSeries) GetMetric() []string

func (*MatrixSeries) GetSamples 

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

func (*MatrixSeries) GoString 

func (this *MatrixSeries) GoString() string

func (*MatrixSeries) Marshal 

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

func (*MatrixSeries) MarshalTo 

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

func (*MatrixSeries) MarshalToSizedBuffer 

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

func (*MatrixSeries) ProtoMessage 

func (*MatrixSeries) ProtoMessage()

func (*MatrixSeries) Reset 

func (m *MatrixSeries) Reset()

func (*MatrixSeries) Size 

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

func (*MatrixSeries) String 

func (this *MatrixSeries) String() string

func (*MatrixSeries) Unmarshal 

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

func (*MatrixSeries) XXX_DiscardUnknown 

func (m *MatrixSeries) XXX_DiscardUnknown()

func (*MatrixSeries) XXX_Marshal 

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

func (*MatrixSeries) XXX_Merge 

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

func (*MatrixSeries) XXX_Size 

func (m *MatrixSeries) XXX_Size() int

func (*MatrixSeries) XXX_Unmarshal 

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

type Metric 

type Metric struct {
	Labels []LabelAdapter `protobuf:"bytes,1,rep,name=labels,proto3,customtype=LabelAdapter" json:"labels"`
}

func (*Metric) Descriptor 

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

func (*Metric) Equal 

func (this *Metric) Equal(that interface{}) bool

func (*Metric) GoString 

func (this *Metric) GoString() string

func (*Metric) Marshal 

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

func (*Metric) MarshalTo 

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

func (*Metric) MarshalToSizedBuffer 

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

func (*Metric) ProtoMessage 

func (*Metric) ProtoMessage()

func (*Metric) Reset 

func (m *Metric) Reset()

func (*Metric) Size 

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

func (*Metric) String 

func (this *Metric) String() string

func (*Metric) Unmarshal 

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

func (*Metric) XXX_DiscardUnknown 

func (m *Metric) XXX_DiscardUnknown()

func (*Metric) XXX_Marshal 

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

func (*Metric) XXX_Merge 

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

func (*Metric) XXX_Size 

func (m *Metric) XXX_Size() int

func (*Metric) XXX_Unmarshal 

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

type MetricMetadata 

type MetricMetadata struct {
	Type             MetricMetadata_MetricType `protobuf:"varint,1,opt,name=type,proto3,enum=cortexpb.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 

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

func (*MetricMetadata) Equal 

func (this *MetricMetadata) Equal(that interface{}) bool

func (*MetricMetadata) GetHelp 

func (m *MetricMetadata) GetHelp() string

func (*MetricMetadata) GetMetricFamilyName 

func (m *MetricMetadata) GetMetricFamilyName() string

func (*MetricMetadata) GetType 

func (m *MetricMetadata) GetType() MetricMetadata_MetricType

func (*MetricMetadata) GetUnit 

func (m *MetricMetadata) GetUnit() string

func (*MetricMetadata) GoString 

func (this *MetricMetadata) GoString() string

func (*MetricMetadata) Marshal 

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

func (*MetricMetadata) MarshalTo 

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

func (*MetricMetadata) MarshalToSizedBuffer 

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

func (*MetricMetadata) ProtoMessage 

func (*MetricMetadata) ProtoMessage()

func (*MetricMetadata) Reset 

func (m *MetricMetadata) Reset()

func (*MetricMetadata) Size 

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

func (*MetricMetadata) String 

func (this *MetricMetadata) String() string

func (*MetricMetadata) Unmarshal 

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

func (*MetricMetadata) XXX_DiscardUnknown 

func (m *MetricMetadata) XXX_DiscardUnknown()

func (*MetricMetadata) XXX_Marshal 

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

func (*MetricMetadata) XXX_Merge 

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

func (*MetricMetadata) XXX_Size 

func (m *MetricMetadata) XXX_Size() int

func (*MetricMetadata) XXX_Unmarshal 

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

type MetricMetadata_MetricType 

type MetricMetadata_MetricType int32
const (
	UNKNOWN        MetricMetadata_MetricType = 0
	COUNTER        MetricMetadata_MetricType = 1
	GAUGE          MetricMetadata_MetricType = 2
	HISTOGRAM      MetricMetadata_MetricType = 3
	GAUGEHISTOGRAM MetricMetadata_MetricType = 4
	SUMMARY        MetricMetadata_MetricType = 5
	INFO           MetricMetadata_MetricType = 6
	STATESET       MetricMetadata_MetricType = 7
)

func (MetricMetadata_MetricType) EnumDescriptor 

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

func (MetricMetadata_MetricType) String 

func (x MetricMetadata_MetricType) String() string

type PreallocTimeseries 

type PreallocTimeseries struct {
	*TimeSeries
	// contains filtered or unexported fields
}

PreallocTimeseries is a TimeSeries which preallocs slices on Unmarshal.

func DeepCopyTimeseries 

func DeepCopyTimeseries(dst, src PreallocTimeseries, keepHistograms, keepExemplars bool) PreallocTimeseries

DeepCopyTimeseries copies the timeseries of one PreallocTimeseries into another one. It copies all the properties, sub-properties and strings by value to ensure that the two timeseries are not sharing anything after the deep copying. The returned PreallocTimeseries has a yoloSlice property which should be returned to the yoloSlicePool on cleanup.

func PreallocTimeseriesSliceFromPool 

func PreallocTimeseriesSliceFromPool() []PreallocTimeseries

PreallocTimeseriesSliceFromPool retrieves a slice of PreallocTimeseries from a sync.Pool. ReuseSlice should be called once done.

func (*PreallocTimeseries) ClearExemplars 

func (p *PreallocTimeseries) ClearExemplars()

func (*PreallocTimeseries) DeleteExemplarByMovingLast 

func (p *PreallocTimeseries) DeleteExemplarByMovingLast(ix int)

DeleteExemplarByMovingLast deletes the exemplar by moving the last one on top and shortening the slice

func (*PreallocTimeseries) HistogramsUpdated 

func (p *PreallocTimeseries) HistogramsUpdated()

func (*PreallocTimeseries) Marshal 

func (p *PreallocTimeseries) Marshal() ([]byte, error)

func (*PreallocTimeseries) MarshalTo 

func (p *PreallocTimeseries) MarshalTo(buf []byte) (int, error)

func (*PreallocTimeseries) MarshalToSizedBuffer 

func (p *PreallocTimeseries) MarshalToSizedBuffer(buf []byte) (int, error)

func (*PreallocTimeseries) RemoveEmptyLabelValues 

func (p *PreallocTimeseries) RemoveEmptyLabelValues()

RemoveEmptyLabelValues remove labels with value=="" from this timeseries, updating the slice in-place.

func (*PreallocTimeseries) RemoveLabel 

func (p *PreallocTimeseries) RemoveLabel(labelName string)

RemoveLabel removes the label labelName from this timeseries, if it exists.

func (*PreallocTimeseries) SetLabels 

func (p *PreallocTimeseries) SetLabels(lbls []LabelAdapter)

func (*PreallocTimeseries) Size 

func (p *PreallocTimeseries) Size() int

func (*PreallocTimeseries) SortLabelsIfNeeded 

func (p *PreallocTimeseries) SortLabelsIfNeeded()

SortLabelsIfNeeded sorts labels if they were not sorted before.

func (*PreallocTimeseries) Unmarshal 

func (p *PreallocTimeseries) Unmarshal(dAtA []byte) error

Unmarshal implements proto.Message. Input data slice is retained.

type PreallocWriteRequest 

type PreallocWriteRequest struct {
	WriteRequest
}

PreallocWriteRequest is a WriteRequest which preallocs slices on Unmarshal.

func (*PreallocWriteRequest) Unmarshal 

func (p *PreallocWriteRequest) Unmarshal(dAtA []byte) error

Unmarshal implements proto.Message.

type PreallocatingMetric 

type PreallocatingMetric struct {
	Metric
}

PreallocatingMetric overrides the Unmarshal behaviour of Metric.

func (*PreallocatingMetric) Unmarshal 

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

Unmarshal is like Metric.Unmarshal, but it preallocates the slice of labels instead of growing it during append(). Unmarshal traverses the dAtA slice and counts the number of Metric.Labels elements. Then it preallocates a slice of mimirpb.LabelAdapter with that capacity and delegates the actual unmarshalling to Metric.Unmarshal.

Unmarshal should be manually updated when new fields are added to Metric. Unmarshal will give up on counting labels if it encounters unknown fields and will fall back to Metric.Unmarshal

The implementation of Unmarshal is copied from the implementation of Metric.Unmarshal and modified, so it only counts the labels instead of also unmarshalling them.

type QueryResponse 

type QueryResponse struct {
	Status    QueryResponse_Status    `protobuf:"varint,1,opt,name=status,proto3,enum=cortexpb.QueryResponse_Status" json:"status,omitempty"`
	ErrorType QueryResponse_ErrorType `` /* 127-byte string literal not displayed */
	Error     string                  `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// Types that are valid to be assigned to Data:
	//
	//	*QueryResponse_String_
	//	*QueryResponse_Vector
	//	*QueryResponse_Scalar
	//	*QueryResponse_Matrix
	Data     isQueryResponse_Data `protobuf_oneof:"data"`
	Warnings []string             `protobuf:"bytes,8,rep,name=warnings,proto3" json:"warnings,omitempty"`
}

func (*QueryResponse) Descriptor 

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

func (*QueryResponse) Equal 

func (this *QueryResponse) Equal(that interface{}) bool

func (*QueryResponse) GetData 

func (m *QueryResponse) GetData() isQueryResponse_Data

func (*QueryResponse) GetError 

func (m *QueryResponse) GetError() string

func (*QueryResponse) GetErrorType 

func (m *QueryResponse) GetErrorType() QueryResponse_ErrorType

func (*QueryResponse) GetMatrix 

func (m *QueryResponse) GetMatrix() *MatrixData

func (*QueryResponse) GetScalar 

func (m *QueryResponse) GetScalar() *ScalarData

func (*QueryResponse) GetStatus 

func (m *QueryResponse) GetStatus() QueryResponse_Status

func (*QueryResponse) GetString_ 

func (m *QueryResponse) GetString_() *StringData

func (*QueryResponse) GetVector 

func (m *QueryResponse) GetVector() *VectorData

func (*QueryResponse) GetWarnings 

func (m *QueryResponse) GetWarnings() []string

func (*QueryResponse) GoString 

func (this *QueryResponse) GoString() string

func (*QueryResponse) Marshal 

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

func (*QueryResponse) MarshalTo 

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

func (*QueryResponse) MarshalToSizedBuffer 

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

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) Reset 

func (m *QueryResponse) Reset()

func (*QueryResponse) Size 

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

func (*QueryResponse) String 

func (this *QueryResponse) String() string

func (*QueryResponse) Unmarshal 

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

func (*QueryResponse) XXX_DiscardUnknown 

func (m *QueryResponse) XXX_DiscardUnknown()

func (*QueryResponse) XXX_Marshal 

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

func (*QueryResponse) XXX_Merge 

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

func (*QueryResponse) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*QueryResponse) XXX_Size 

func (m *QueryResponse) XXX_Size() int

func (*QueryResponse) XXX_Unmarshal 

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

type QueryResponse_ErrorType 

type QueryResponse_ErrorType int32

These values correspond to the possible error type values defined in https://github.com/prometheus/prometheus/blob/main/web/api/v1/api.go. 

const (
	QueryResponse_NONE           QueryResponse_ErrorType = 0
	QueryResponse_TIMEOUT        QueryResponse_ErrorType = 1
	QueryResponse_CANCELED       QueryResponse_ErrorType = 2
	QueryResponse_EXECUTION      QueryResponse_ErrorType = 3
	QueryResponse_BAD_DATA       QueryResponse_ErrorType = 4
	QueryResponse_INTERNAL       QueryResponse_ErrorType = 5
	QueryResponse_UNAVAILABLE    QueryResponse_ErrorType = 6
	QueryResponse_NOT_FOUND      QueryResponse_ErrorType = 7
	QueryResponse_NOT_ACCEPTABLE QueryResponse_ErrorType = 8
)

func ErrorTypeFromPrometheusString 

func ErrorTypeFromPrometheusString(s string) (QueryResponse_ErrorType, error)

func (QueryResponse_ErrorType) EnumDescriptor 

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

func (QueryResponse_ErrorType) String 

func (x QueryResponse_ErrorType) String() string

func (QueryResponse_ErrorType) ToPrometheusString 

func (t QueryResponse_ErrorType) ToPrometheusString() (string, error)

type QueryResponse_Matrix 

type QueryResponse_Matrix struct {
	Matrix *MatrixData `protobuf:"bytes,7,opt,name=matrix,proto3,oneof"`
}

func (*QueryResponse_Matrix) Equal 

func (this *QueryResponse_Matrix) Equal(that interface{}) bool

func (*QueryResponse_Matrix) GoString 

func (this *QueryResponse_Matrix) GoString() string

func (*QueryResponse_Matrix) MarshalTo 

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

func (*QueryResponse_Matrix) MarshalToSizedBuffer 

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

func (*QueryResponse_Matrix) Size 

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

func (*QueryResponse_Matrix) String 

func (this *QueryResponse_Matrix) String() string

type QueryResponse_Scalar 

type QueryResponse_Scalar struct {
	Scalar *ScalarData `protobuf:"bytes,6,opt,name=scalar,proto3,oneof"`
}

func (*QueryResponse_Scalar) Equal 

func (this *QueryResponse_Scalar) Equal(that interface{}) bool

func (*QueryResponse_Scalar) GoString 

func (this *QueryResponse_Scalar) GoString() string

func (*QueryResponse_Scalar) MarshalTo 

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

func (*QueryResponse_Scalar) MarshalToSizedBuffer 

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

func (*QueryResponse_Scalar) Size 

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

func (*QueryResponse_Scalar) String 

func (this *QueryResponse_Scalar) String() string

type QueryResponse_Status 

type QueryResponse_Status int32

These values correspond to the possible status values defined in https://github.com/prometheus/prometheus/blob/main/web/api/v1/api.go. 

const (
	QueryResponse_ERROR   QueryResponse_Status = 0
	QueryResponse_SUCCESS QueryResponse_Status = 1
)

func StatusFromPrometheusString 

func StatusFromPrometheusString(s string) (QueryResponse_Status, error)

func (QueryResponse_Status) EnumDescriptor 

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

func (QueryResponse_Status) String 

func (x QueryResponse_Status) String() string

func (QueryResponse_Status) ToPrometheusString 

func (s QueryResponse_Status) ToPrometheusString() (string, error)

type QueryResponse_String_ 

type QueryResponse_String_ struct {
	String_ *StringData `protobuf:"bytes,4,opt,name=string,proto3,oneof"`
}

func (*QueryResponse_String_) Equal 

func (this *QueryResponse_String_) Equal(that interface{}) bool

func (*QueryResponse_String_) GoString 

func (this *QueryResponse_String_) GoString() string

func (*QueryResponse_String_) MarshalTo 

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

func (*QueryResponse_String_) MarshalToSizedBuffer 

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

func (*QueryResponse_String_) Size 

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

func (*QueryResponse_String_) String 

func (this *QueryResponse_String_) String() string

type QueryResponse_Vector 

type QueryResponse_Vector struct {
	Vector *VectorData `protobuf:"bytes,5,opt,name=vector,proto3,oneof"`
}

func (*QueryResponse_Vector) Equal 

func (this *QueryResponse_Vector) Equal(that interface{}) bool

func (*QueryResponse_Vector) GoString 

func (this *QueryResponse_Vector) GoString() string

func (*QueryResponse_Vector) MarshalTo 

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

func (*QueryResponse_Vector) MarshalToSizedBuffer 

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

func (*QueryResponse_Vector) Size 

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

func (*QueryResponse_Vector) String 

func (this *QueryResponse_Vector) String() string

type Sample 

type Sample struct {
	// Fields order MUST match promql.FPoint so that we can cast types between them.
	TimestampMs int64   `protobuf:"varint,2,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"`
	Value       float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
}

func FromFPointsToSamples 

func FromFPointsToSamples(points []promql.FPoint) []Sample

FromFPointsToSamples casts []promql.FPoint to []Sample. It uses unsafe.

func (*Sample) Descriptor 

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

func (*Sample) Equal 

func (this *Sample) Equal(that interface{}) bool

func (*Sample) GetTimestampMs 

func (m *Sample) GetTimestampMs() int64

func (*Sample) GetValue 

func (m *Sample) GetValue() float64

func (*Sample) GoString 

func (this *Sample) GoString() string

func (*Sample) Marshal 

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

func (Sample) MarshalJSON 

func (s Sample) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler.

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 (this *Sample) String() string

func (*Sample) Unmarshal 

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

func (*Sample) UnmarshalJSON 

func (s *Sample) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler.

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 SampleHistogram 

type SampleHistogram struct {
	Count   float64            `protobuf:"fixed64,1,opt,name=count,proto3" json:"count,omitempty"`
	Sum     float64            `protobuf:"fixed64,2,opt,name=sum,proto3" json:"sum,omitempty"`
	Buckets []*HistogramBucket `protobuf:"bytes,3,rep,name=buckets,proto3" json:"buckets,omitempty"`
}

SampleHistogram is based on https://github.com/prometheus/common/blob/main/model/value_histogram.go for compatibility with PromQL API results Must keep the same order and type of fields for casting

func FromFloatHistogramToSampleHistogram 

func FromFloatHistogramToSampleHistogram(h *histogram.FloatHistogram) *SampleHistogram

FromFloatHistogramToSampleHistogram converts histogram.FloatHistogram to SampleHistogram.

func FromPromToMimirSampleHistogram 

func FromPromToMimirSampleHistogram(src *model.SampleHistogram) *SampleHistogram

func (*SampleHistogram) Descriptor 

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

func (*SampleHistogram) Equal 

func (this *SampleHistogram) Equal(that interface{}) bool

func (*SampleHistogram) GetBuckets 

func (m *SampleHistogram) GetBuckets() []*HistogramBucket

func (*SampleHistogram) GetCount 

func (m *SampleHistogram) GetCount() float64

func (*SampleHistogram) GetSum 

func (m *SampleHistogram) GetSum() float64

func (*SampleHistogram) GoString 

func (this *SampleHistogram) GoString() string

func (*SampleHistogram) Marshal 

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

func (*SampleHistogram) MarshalTo 

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

func (*SampleHistogram) MarshalToSizedBuffer 

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

func (*SampleHistogram) ProtoMessage 

func (*SampleHistogram) ProtoMessage()

func (*SampleHistogram) Reset 

func (m *SampleHistogram) Reset()

func (*SampleHistogram) Size 

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

func (*SampleHistogram) String 

func (this *SampleHistogram) String() string

func (*SampleHistogram) Unmarshal 

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

func (*SampleHistogram) XXX_DiscardUnknown 

func (m *SampleHistogram) XXX_DiscardUnknown()

func (*SampleHistogram) XXX_Marshal 

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

func (*SampleHistogram) XXX_Merge 

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

func (*SampleHistogram) XXX_Size 

func (m *SampleHistogram) XXX_Size() int

func (*SampleHistogram) XXX_Unmarshal 

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

type SampleHistogramPair 

type SampleHistogramPair struct {
	Timestamp int64            `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Histogram *SampleHistogram `protobuf:"bytes,1,opt,name=histogram,proto3" json:"histogram,omitempty"`
}

Must keep the same order and type of fields for casting, see SampleHistogram

func (*SampleHistogramPair) Descriptor 

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

func (*SampleHistogramPair) Equal 

func (this *SampleHistogramPair) Equal(that interface{}) bool

func (*SampleHistogramPair) GetHistogram 

func (m *SampleHistogramPair) GetHistogram() *SampleHistogram

func (*SampleHistogramPair) GetTimestamp 

func (m *SampleHistogramPair) GetTimestamp() int64

func (*SampleHistogramPair) GoString 

func (this *SampleHistogramPair) GoString() string

func (*SampleHistogramPair) Marshal 

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

func (SampleHistogramPair) MarshalJSON 

func (vs SampleHistogramPair) MarshalJSON() ([]byte, error)

func (*SampleHistogramPair) MarshalTo 

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

func (*SampleHistogramPair) MarshalToSizedBuffer 

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

func (*SampleHistogramPair) ProtoMessage 

func (*SampleHistogramPair) ProtoMessage()

func (*SampleHistogramPair) Reset 

func (m *SampleHistogramPair) Reset()

func (*SampleHistogramPair) Size 

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

func (*SampleHistogramPair) String 

func (this *SampleHistogramPair) String() string

func (*SampleHistogramPair) Unmarshal 

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

func (*SampleHistogramPair) UnmarshalJSON 

func (vs *SampleHistogramPair) UnmarshalJSON(b []byte) error

func (*SampleHistogramPair) XXX_DiscardUnknown 

func (m *SampleHistogramPair) XXX_DiscardUnknown()

func (*SampleHistogramPair) XXX_Marshal 

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

func (*SampleHistogramPair) XXX_Merge 

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

func (*SampleHistogramPair) XXX_Size 

func (m *SampleHistogramPair) XXX_Size() int

func (*SampleHistogramPair) XXX_Unmarshal 

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

type ScalarData 

type ScalarData struct {
	Value       float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	TimestampMs int64   `protobuf:"varint,2,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"`
}

func (*ScalarData) Descriptor 

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

func (*ScalarData) Equal 

func (this *ScalarData) Equal(that interface{}) bool

func (*ScalarData) GetTimestampMs 

func (m *ScalarData) GetTimestampMs() int64

func (*ScalarData) GetValue 

func (m *ScalarData) GetValue() float64

func (*ScalarData) GoString 

func (this *ScalarData) GoString() string

func (*ScalarData) Marshal 

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

func (*ScalarData) MarshalTo 

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

func (*ScalarData) MarshalToSizedBuffer 

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

func (*ScalarData) ProtoMessage 

func (*ScalarData) ProtoMessage()

func (*ScalarData) Reset 

func (m *ScalarData) Reset()

func (*ScalarData) Size 

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

func (*ScalarData) String 

func (this *ScalarData) String() string

func (*ScalarData) Unmarshal 

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

func (*ScalarData) XXX_DiscardUnknown 

func (m *ScalarData) XXX_DiscardUnknown()

func (*ScalarData) XXX_Marshal 

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

func (*ScalarData) XXX_Merge 

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

func (*ScalarData) XXX_Size 

func (m *ScalarData) XXX_Size() int

func (*ScalarData) XXX_Unmarshal 

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

type StringData 

type StringData struct {
	Value       string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	TimestampMs int64  `protobuf:"varint,2,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"`
}

func (*StringData) Descriptor 

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

func (*StringData) Equal 

func (this *StringData) Equal(that interface{}) bool

func (*StringData) GetTimestampMs 

func (m *StringData) GetTimestampMs() int64

func (*StringData) GetValue 

func (m *StringData) GetValue() string

func (*StringData) GoString 

func (this *StringData) GoString() string

func (*StringData) Marshal 

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

func (*StringData) MarshalTo 

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

func (*StringData) MarshalToSizedBuffer 

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

func (*StringData) ProtoMessage 

func (*StringData) ProtoMessage()

func (*StringData) Reset 

func (m *StringData) Reset()

func (*StringData) Size 

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

func (*StringData) String 

func (this *StringData) String() string

func (*StringData) Unmarshal 

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

func (*StringData) XXX_DiscardUnknown 

func (m *StringData) XXX_DiscardUnknown()

func (*StringData) XXX_Marshal 

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

func (*StringData) XXX_Merge 

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

func (*StringData) XXX_Size 

func (m *StringData) XXX_Size() int

func (*StringData) XXX_Unmarshal 

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

type TimeSeries 

type TimeSeries struct {
	Labels []LabelAdapter `protobuf:"bytes,1,rep,name=labels,proto3,customtype=LabelAdapter" json:"labels"`
	// Sorted by time, oldest sample first.
	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"`
}

func TimeseriesFromPool 

func TimeseriesFromPool() *TimeSeries

TimeseriesFromPool retrieves a pointer to a TimeSeries from a sync.Pool. ReuseTimeseries should be called once done, unless ReuseSlice was called on the slice that contains this TimeSeries.

func (*TimeSeries) Descriptor 

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

func (*TimeSeries) Equal 

func (this *TimeSeries) Equal(that interface{}) bool

func (*TimeSeries) GetExemplars 

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

func (*TimeSeries) GetHistograms 

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

func (*TimeSeries) GetSamples 

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

func (*TimeSeries) GoString 

func (this *TimeSeries) GoString() string

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 (this *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 UnsafeByteSlice 

type UnsafeByteSlice []byte

UnsafeByteSlice is an alternative to the default handling of []byte values in protobuf messages. Unlike the default protobuf implementation, when unmarshalling, UnsafeByteSlice holds a reference to the subslice of the original protobuf-encoded bytes, rather than copying them from the encoded buffer to a second slice. This reduces memory pressure when unmarshalling byte slices, at the cost of retaining the full buffer in memory. This tradeoff is usually only worthwhile when the protobuf message is dominated by []byte values (eg. when sending chunks to queriers).

The implementations of all other methods are identical to those generated by the protobuf compiler.

Note that UnsafeByteSlice will not behave correctly if the protobuf-encoded bytes are reused (eg. if the buffer is used for one request and then pooled and reused for a later request). At the time of writing, the gRPC client does not do this, but there is a TODO to investigate it (see https://github.com/grafana/mimir/blob/117f0d68785b8a3ca07a8b1dda5a350b17cdc09b/vendor/google.golang.org/grpc/rpc_util.go#L575-L576).

func (UnsafeByteSlice) Equal 

func (t UnsafeByteSlice) Equal(other UnsafeByteSlice) bool

func (*UnsafeByteSlice) MarshalTo 

func (t *UnsafeByteSlice) MarshalTo(data []byte) (n int, err error)

func (*UnsafeByteSlice) Size 

func (t *UnsafeByteSlice) Size() int

func (*UnsafeByteSlice) Unmarshal 

func (t *UnsafeByteSlice) Unmarshal(data []byte) error

type VectorData 

type VectorData struct {
	Samples    []VectorSample    `protobuf:"bytes,1,rep,name=samples,proto3" json:"samples"`
	Histograms []VectorHistogram `protobuf:"bytes,2,rep,name=histograms,proto3" json:"histograms"`
}

func (*VectorData) Descriptor 

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

func (*VectorData) Equal 

func (this *VectorData) Equal(that interface{}) bool

func (*VectorData) GetHistograms 

func (m *VectorData) GetHistograms() []VectorHistogram

func (*VectorData) GetSamples 

func (m *VectorData) GetSamples() []VectorSample

func (*VectorData) GoString 

func (this *VectorData) GoString() string

func (*VectorData) Marshal 

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

func (*VectorData) MarshalTo 

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

func (*VectorData) MarshalToSizedBuffer 

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

func (*VectorData) ProtoMessage 

func (*VectorData) ProtoMessage()

func (*VectorData) Reset 

func (m *VectorData) Reset()

func (*VectorData) Size 

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

func (*VectorData) String 

func (this *VectorData) String() string

func (*VectorData) Unmarshal 

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

func (*VectorData) XXX_DiscardUnknown 

func (m *VectorData) XXX_DiscardUnknown()

func (*VectorData) XXX_Marshal 

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

func (*VectorData) XXX_Merge 

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

func (*VectorData) XXX_Size 

func (m *VectorData) XXX_Size() int

func (*VectorData) XXX_Unmarshal 

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

type VectorHistogram 

type VectorHistogram struct {
	// Why not use a map<...> here? We want to preserve the order of the labels, as labels.Labels expects them to be sorted.
	Metric      []string       `protobuf:"bytes,1,rep,name=metric,proto3" json:"metric,omitempty"`
	Histogram   FloatHistogram `protobuf:"bytes,2,opt,name=histogram,proto3" json:"histogram"`
	TimestampMs int64          `protobuf:"varint,3,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"`
}

func (*VectorHistogram) Descriptor 

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

func (*VectorHistogram) Equal 

func (this *VectorHistogram) Equal(that interface{}) bool

func (*VectorHistogram) GetHistogram 

func (m *VectorHistogram) GetHistogram() FloatHistogram

func (*VectorHistogram) GetMetric 

func (m *VectorHistogram) GetMetric() []string

func (*VectorHistogram) GetTimestampMs 

func (m *VectorHistogram) GetTimestampMs() int64

func (*VectorHistogram) GoString 

func (this *VectorHistogram) GoString() string

func (*VectorHistogram) Marshal 

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

func (*VectorHistogram) MarshalTo 

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

func (*VectorHistogram) MarshalToSizedBuffer 

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

func (*VectorHistogram) ProtoMessage 

func (*VectorHistogram) ProtoMessage()

func (*VectorHistogram) Reset 

func (m *VectorHistogram) Reset()

func (*VectorHistogram) Size 

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

func (*VectorHistogram) String 

func (this *VectorHistogram) String() string

func (*VectorHistogram) Unmarshal 

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

func (*VectorHistogram) XXX_DiscardUnknown 

func (m *VectorHistogram) XXX_DiscardUnknown()

func (*VectorHistogram) XXX_Marshal 

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

func (*VectorHistogram) XXX_Merge 

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

func (*VectorHistogram) XXX_Size 

func (m *VectorHistogram) XXX_Size() int

func (*VectorHistogram) XXX_Unmarshal 

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

type VectorSample 

type VectorSample struct {
	// Why not use a map<...> here? We want to preserve the order of the labels, as labels.Labels expects them to be sorted.
	Metric      []string `protobuf:"bytes,1,rep,name=metric,proto3" json:"metric,omitempty"`
	Value       float64  `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
	TimestampMs int64    `protobuf:"varint,3,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"`
}

func (*VectorSample) Descriptor 

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

func (*VectorSample) Equal 

func (this *VectorSample) Equal(that interface{}) bool

func (*VectorSample) GetMetric 

func (m *VectorSample) GetMetric() []string

func (*VectorSample) GetTimestampMs 

func (m *VectorSample) GetTimestampMs() int64

func (*VectorSample) GetValue 

func (m *VectorSample) GetValue() float64

func (*VectorSample) GoString 

func (this *VectorSample) GoString() string

func (*VectorSample) Marshal 

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

func (*VectorSample) MarshalTo 

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

func (*VectorSample) MarshalToSizedBuffer 

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

func (*VectorSample) ProtoMessage 

func (*VectorSample) ProtoMessage()

func (*VectorSample) Reset 

func (m *VectorSample) Reset()

func (*VectorSample) Size 

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

func (*VectorSample) String 

func (this *VectorSample) String() string

func (*VectorSample) Unmarshal 

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

func (*VectorSample) XXX_DiscardUnknown 

func (m *VectorSample) XXX_DiscardUnknown()

func (*VectorSample) XXX_Marshal 

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

func (*VectorSample) XXX_Merge 

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

func (*VectorSample) XXX_Size 

func (m *VectorSample) XXX_Size() int

func (*VectorSample) XXX_Unmarshal 

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

type WriteRequest 

type WriteRequest struct {
	Timeseries []PreallocTimeseries    `protobuf:"bytes,1,rep,name=timeseries,proto3,customtype=PreallocTimeseries" json:"timeseries"`
	Source     WriteRequest_SourceEnum `protobuf:"varint,2,opt,name=Source,proto3,enum=cortexpb.WriteRequest_SourceEnum" json:"Source,omitempty"`
	Metadata   []*MetricMetadata       `protobuf:"bytes,3,rep,name=metadata,proto3" json:"metadata,omitempty"`
	// Skip validation of label names.
	SkipLabelNameValidation bool `` /* 138-byte string literal not displayed */
}

func NewWriteRequest 

func NewWriteRequest(metadata []*MetricMetadata, source WriteRequest_SourceEnum) *WriteRequest

NewWriteRequest creates a new empty WriteRequest with metadata

func ToWriteRequest 

func ToWriteRequest(lbls [][]LabelAdapter, samples []Sample, exemplars []*Exemplar, metadata []*MetricMetadata, source WriteRequest_SourceEnum) *WriteRequest

ToWriteRequest converts matched slices of Labels, Samples, Exemplars, and Metadata into a WriteRequest proto. It gets timeseries from the pool, so ReuseSlice() should be called when done. Note that this method implies that only a single sample and optionally exemplar can be set for each series.

For histograms use NewWriteRequest and Add* functions to build write request with Floats and Histograms

func (*WriteRequest) AddExemplarsAt 

func (req *WriteRequest) AddExemplarsAt(i int, exemplars []*Exemplar) *WriteRequest

AddExemplarsAt appends exemplars to the timeseries at index i. This is needed as the Add*Series functions only allow for a single exemplar to be added per time series for simplicity.

func (*WriteRequest) AddFloatSeries 

func (req *WriteRequest) AddFloatSeries(lbls [][]LabelAdapter, samples []Sample, exemplars []*Exemplar) *WriteRequest

AddFloatSeries converts matched slices of Labels, Samples, Exemplars into a WriteRequest proto. It gets timeseries from the pool, so ReuseSlice() should be called when done. Note that this method implies that only a single sample and optionally exemplar can be set for each series.

func (*WriteRequest) AddHistogramSeries 

func (req *WriteRequest) AddHistogramSeries(lbls [][]LabelAdapter, histograms []Histogram, exemplars []*Exemplar) *WriteRequest

AddHistogramSeries converts matched slices of Labels, Histograms, Exemplars into a WriteRequest proto. It gets timeseries from the pool, so ReuseSlice() should be called when done. Note that this method implies that only a single sample and optionally exemplar can be set for each series.

func (*WriteRequest) ClearTimeseriesUnmarshalData 

func (p *WriteRequest) ClearTimeseriesUnmarshalData()

func (*WriteRequest) Descriptor 

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

func (*WriteRequest) Equal 

func (this *WriteRequest) Equal(that interface{}) bool

func (*WriteRequest) ForIndexes 

func (p *WriteRequest) ForIndexes(indexes []int, initialMetadataIndex int) *WriteRequest

ForIndexes builds a new WriteRequest from the given WriteRequest, containing only the timeseries and metadata for the given indexes. It assumes the indexes before the initialMetadataIndex are timeseries, and the rest are metadata.

func (*WriteRequest) GetMetadata 

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

func (*WriteRequest) GetSkipLabelNameValidation 

func (m *WriteRequest) GetSkipLabelNameValidation() bool

func (*WriteRequest) GetSource 

func (m *WriteRequest) GetSource() WriteRequest_SourceEnum

func (*WriteRequest) GoString 

func (this *WriteRequest) GoString() string

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) MinTimestamp 

func (m *WriteRequest) MinTimestamp() int64

MinTimestamp returns the minimum timestamp (milliseconds) among all series in the WriteRequest. Returns math.MaxInt64 if the request is empty.

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 (this *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

type WriteRequest_SourceEnum 

type WriteRequest_SourceEnum int32
const (
	API  WriteRequest_SourceEnum = 0
	RULE WriteRequest_SourceEnum = 1
)

func (WriteRequest_SourceEnum) EnumDescriptor 

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

func (WriteRequest_SourceEnum) String 

func (x WriteRequest_SourceEnum) String() string

type WriteResponse 

type WriteResponse struct {
}

func (*WriteResponse) Descriptor 

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

func (*WriteResponse) Equal 

func (this *WriteResponse) Equal(that interface{}) bool

func (*WriteResponse) GoString 

func (this *WriteResponse) GoString() string

func (*WriteResponse) Marshal 

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

func (*WriteResponse) MarshalTo 

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

func (*WriteResponse) MarshalToSizedBuffer 

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

func (*WriteResponse) ProtoMessage 

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) Reset 

func (m *WriteResponse) Reset()

func (*WriteResponse) Size 

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

func (*WriteResponse) String 

func (this *WriteResponse) String() string

func (*WriteResponse) Unmarshal 

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

func (*WriteResponse) XXX_DiscardUnknown 

func (m *WriteResponse) XXX_DiscardUnknown()

func (*WriteResponse) XXX_Marshal 

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

func (*WriteResponse) XXX_Merge 

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

func (*WriteResponse) XXX_Size 

func (m *WriteResponse) XXX_Size() int

func (*WriteResponse) XXX_Unmarshal 

func (m *WriteResponse) 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.