prompb

package
v2.25.1 Latest Latest
Warning

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

Go to latest
Published: Jan 27, 2021 License: Apache-2.0 Imports: 7 Imported by: 0

README

The compiled protobufs are version controlled and you won't normally need to re-compile them when building Prometheus.

If however you have modified the defs and do need to re-compile, run make proto from the parent dir.

In order for the script to run, you'll need protoc (version 3.12.3) in your PATH.

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

Types

type Chunk added in v2.25.0

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

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

func (*Chunk) Descriptor added in v2.25.0

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

func (*Chunk) GetData added in v2.25.0

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

func (*Chunk) GetMaxTimeMs added in v2.25.0

func (m *Chunk) GetMaxTimeMs() int64

func (*Chunk) GetMinTimeMs added in v2.25.0

func (m *Chunk) GetMinTimeMs() int64

func (*Chunk) GetType added in v2.25.0

func (m *Chunk) GetType() Chunk_Encoding

func (*Chunk) Marshal added in v2.25.0

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

func (*Chunk) MarshalTo added in v2.25.0

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

func (*Chunk) MarshalToSizedBuffer added in v2.25.0

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

func (*Chunk) ProtoMessage added in v2.25.0

func (*Chunk) ProtoMessage()

func (*Chunk) Reset added in v2.25.0

func (m *Chunk) Reset()

func (*Chunk) Size added in v2.25.0

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

func (*Chunk) String added in v2.25.0

func (m *Chunk) String() string

func (*Chunk) Unmarshal added in v2.25.0

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

func (*Chunk) XXX_DiscardUnknown added in v2.25.0

func (m *Chunk) XXX_DiscardUnknown()

func (*Chunk) XXX_Marshal added in v2.25.0

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

func (*Chunk) XXX_Merge added in v2.25.0

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

func (*Chunk) XXX_Size added in v2.25.0

func (m *Chunk) XXX_Size() int

func (*Chunk) XXX_Unmarshal added in v2.25.0

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

type Chunk_Encoding added in v2.25.0

type Chunk_Encoding int32

We require this to match chunkenc.Encoding.

const (
	Chunk_UNKNOWN Chunk_Encoding = 0
	Chunk_XOR     Chunk_Encoding = 1
)

func (Chunk_Encoding) EnumDescriptor added in v2.25.0

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

func (Chunk_Encoding) String added in v2.25.0

func (x Chunk_Encoding) String() string

type ChunkedReadResponse added in v2.25.0

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

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

func (*ChunkedReadResponse) Descriptor added in v2.25.0

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

func (*ChunkedReadResponse) GetChunkedSeries added in v2.25.0

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

func (*ChunkedReadResponse) GetQueryIndex added in v2.25.0

func (m *ChunkedReadResponse) GetQueryIndex() int64

func (*ChunkedReadResponse) Marshal added in v2.25.0

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

func (*ChunkedReadResponse) MarshalTo added in v2.25.0

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

func (*ChunkedReadResponse) MarshalToSizedBuffer added in v2.25.0

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

func (*ChunkedReadResponse) ProtoMessage added in v2.25.0

func (*ChunkedReadResponse) ProtoMessage()

func (*ChunkedReadResponse) Reset added in v2.25.0

func (m *ChunkedReadResponse) Reset()

func (*ChunkedReadResponse) Size added in v2.25.0

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

func (*ChunkedReadResponse) String added in v2.25.0

func (m *ChunkedReadResponse) String() string

func (*ChunkedReadResponse) Unmarshal added in v2.25.0

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

func (*ChunkedReadResponse) XXX_DiscardUnknown added in v2.25.0

func (m *ChunkedReadResponse) XXX_DiscardUnknown()

func (*ChunkedReadResponse) XXX_Marshal added in v2.25.0

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

func (*ChunkedReadResponse) XXX_Merge added in v2.25.0

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

func (*ChunkedReadResponse) XXX_Size added in v2.25.0

func (m *ChunkedReadResponse) XXX_Size() int

func (*ChunkedReadResponse) XXX_Unmarshal added in v2.25.0

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

type ChunkedSeries added in v2.25.0

type ChunkedSeries struct {
	// Labels should be sorted.
	Labels []Label `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels"`
	// Chunks will be in start time order and may overlap.
	Chunks               []Chunk  `protobuf:"bytes,2,rep,name=chunks,proto3" json:"chunks"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ChunkedSeries represents single, encoded time series.

func (*ChunkedSeries) Descriptor added in v2.25.0

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

func (*ChunkedSeries) GetChunks added in v2.25.0

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

func (*ChunkedSeries) GetLabels added in v2.25.0

func (m *ChunkedSeries) GetLabels() []Label

func (*ChunkedSeries) Marshal added in v2.25.0

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

func (*ChunkedSeries) MarshalTo added in v2.25.0

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

func (*ChunkedSeries) MarshalToSizedBuffer added in v2.25.0

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

func (*ChunkedSeries) ProtoMessage added in v2.25.0

func (*ChunkedSeries) ProtoMessage()

func (*ChunkedSeries) Reset added in v2.25.0

func (m *ChunkedSeries) Reset()

func (*ChunkedSeries) Size added in v2.25.0

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

func (*ChunkedSeries) String added in v2.25.0

func (m *ChunkedSeries) String() string

func (*ChunkedSeries) Unmarshal added in v2.25.0

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

func (*ChunkedSeries) XXX_DiscardUnknown added in v2.25.0

func (m *ChunkedSeries) XXX_DiscardUnknown()

func (*ChunkedSeries) XXX_Marshal added in v2.25.0

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

func (*ChunkedSeries) XXX_Merge added in v2.25.0

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

func (*ChunkedSeries) XXX_Size added in v2.25.0

func (m *ChunkedSeries) XXX_Size() int

func (*ChunkedSeries) XXX_Unmarshal added in v2.25.0

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

type Label

type Label struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Label) Descriptor

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

func (*Label) GetName

func (m *Label) GetName() string

func (*Label) GetValue

func (m *Label) GetValue() string

func (*Label) Marshal

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

func (*Label) MarshalTo

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

func (*Label) MarshalToSizedBuffer

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

func (*Label) ProtoMessage

func (*Label) ProtoMessage()

func (*Label) Reset

func (m *Label) Reset()

func (*Label) Size

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

func (*Label) String

func (m *Label) String() string

func (*Label) Unmarshal

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

func (*Label) XXX_DiscardUnknown

func (m *Label) XXX_DiscardUnknown()

func (*Label) XXX_Marshal

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

func (*Label) XXX_Merge

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

func (*Label) XXX_Size

func (m *Label) XXX_Size() int

func (*Label) XXX_Unmarshal

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

type LabelMatcher

type LabelMatcher struct {
	Type                 LabelMatcher_Type `protobuf:"varint,1,opt,name=type,proto3,enum=prometheus.LabelMatcher_Type" json:"type,omitempty"`
	Name                 string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Value                string            `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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

func (*LabelMatcher) Descriptor

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

func (*LabelMatcher) GetName

func (m *LabelMatcher) GetName() string

func (*LabelMatcher) GetType

func (m *LabelMatcher) GetType() LabelMatcher_Type

func (*LabelMatcher) GetValue

func (m *LabelMatcher) GetValue() string

func (*LabelMatcher) Marshal

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

func (*LabelMatcher) MarshalTo

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

func (*LabelMatcher) MarshalToSizedBuffer

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

func (*LabelMatcher) ProtoMessage

func (*LabelMatcher) ProtoMessage()

func (*LabelMatcher) Reset

func (m *LabelMatcher) Reset()

func (*LabelMatcher) Size

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

func (*LabelMatcher) String

func (m *LabelMatcher) String() string

func (*LabelMatcher) Unmarshal

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

func (*LabelMatcher) XXX_DiscardUnknown

func (m *LabelMatcher) XXX_DiscardUnknown()

func (*LabelMatcher) XXX_Marshal

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

func (*LabelMatcher) XXX_Merge

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

func (*LabelMatcher) XXX_Size

func (m *LabelMatcher) XXX_Size() int

func (*LabelMatcher) XXX_Unmarshal

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

type LabelMatcher_Type

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

func (LabelMatcher_Type) EnumDescriptor

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

func (LabelMatcher_Type) String

func (x LabelMatcher_Type) String() string

type Labels

type Labels struct {
	Labels               []Label  `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Labels) Descriptor

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

func (*Labels) GetLabels

func (m *Labels) GetLabels() []Label

func (*Labels) Marshal

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

func (*Labels) MarshalTo

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

func (*Labels) MarshalToSizedBuffer

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

func (*Labels) ProtoMessage

func (*Labels) ProtoMessage()

func (*Labels) Reset

func (m *Labels) Reset()

func (*Labels) Size

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

func (*Labels) String

func (m *Labels) String() string

func (*Labels) Unmarshal

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

func (*Labels) XXX_DiscardUnknown

func (m *Labels) XXX_DiscardUnknown()

func (*Labels) XXX_Marshal

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

func (*Labels) XXX_Merge

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

func (*Labels) XXX_Size

func (m *Labels) XXX_Size() int

func (*Labels) XXX_Unmarshal

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

type MetricMetadata added in v2.25.0

type MetricMetadata struct {
	// Represents the metric type, these match the set from Prometheus.
	// Refer to pkg/textparse/interface.go for details.
	Type                 MetricMetadata_MetricType `protobuf:"varint,1,opt,name=type,proto3,enum=prometheus.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"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*MetricMetadata) Descriptor added in v2.25.0

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

func (*MetricMetadata) GetHelp added in v2.25.0

func (m *MetricMetadata) GetHelp() string

func (*MetricMetadata) GetMetricFamilyName added in v2.25.0

func (m *MetricMetadata) GetMetricFamilyName() string

func (*MetricMetadata) GetType added in v2.25.0

func (*MetricMetadata) GetUnit added in v2.25.0

func (m *MetricMetadata) GetUnit() string

func (*MetricMetadata) Marshal added in v2.25.0

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

func (*MetricMetadata) MarshalTo added in v2.25.0

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

func (*MetricMetadata) MarshalToSizedBuffer added in v2.25.0

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

func (*MetricMetadata) ProtoMessage added in v2.25.0

func (*MetricMetadata) ProtoMessage()

func (*MetricMetadata) Reset added in v2.25.0

func (m *MetricMetadata) Reset()

func (*MetricMetadata) Size added in v2.25.0

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

func (*MetricMetadata) String added in v2.25.0

func (m *MetricMetadata) String() string

func (*MetricMetadata) Unmarshal added in v2.25.0

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

func (*MetricMetadata) XXX_DiscardUnknown added in v2.25.0

func (m *MetricMetadata) XXX_DiscardUnknown()

func (*MetricMetadata) XXX_Marshal added in v2.25.0

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

func (*MetricMetadata) XXX_Merge added in v2.25.0

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

func (*MetricMetadata) XXX_Size added in v2.25.0

func (m *MetricMetadata) XXX_Size() int

func (*MetricMetadata) XXX_Unmarshal added in v2.25.0

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

type MetricMetadata_MetricType added in v2.25.0

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

func (MetricMetadata_MetricType) EnumDescriptor added in v2.25.0

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

func (MetricMetadata_MetricType) String added in v2.25.0

func (x MetricMetadata_MetricType) String() string

type Query

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

func (*Query) Descriptor

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

func (*Query) GetEndTimestampMs

func (m *Query) GetEndTimestampMs() int64

func (*Query) GetHints

func (m *Query) GetHints() *ReadHints

func (*Query) GetMatchers

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

func (*Query) GetStartTimestampMs

func (m *Query) GetStartTimestampMs() int64

func (*Query) Marshal

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

func (*Query) MarshalTo

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

func (*Query) MarshalToSizedBuffer

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

func (*Query) ProtoMessage

func (*Query) ProtoMessage()

func (*Query) Reset

func (m *Query) Reset()

func (*Query) Size

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

func (*Query) String

func (m *Query) String() string

func (*Query) Unmarshal

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

func (*Query) XXX_DiscardUnknown

func (m *Query) XXX_DiscardUnknown()

func (*Query) XXX_Marshal

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

func (*Query) XXX_Merge

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

func (*Query) XXX_Size

func (m *Query) XXX_Size() int

func (*Query) XXX_Unmarshal

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

type QueryResult

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

func (*QueryResult) Descriptor

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

func (*QueryResult) GetTimeseries

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

func (*QueryResult) Marshal

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

func (*QueryResult) MarshalTo

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

func (*QueryResult) MarshalToSizedBuffer

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

func (*QueryResult) ProtoMessage

func (*QueryResult) ProtoMessage()

func (*QueryResult) Reset

func (m *QueryResult) Reset()

func (*QueryResult) Size

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

func (*QueryResult) String

func (m *QueryResult) String() string

func (*QueryResult) Unmarshal

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

func (*QueryResult) XXX_DiscardUnknown

func (m *QueryResult) XXX_DiscardUnknown()

func (*QueryResult) XXX_Marshal

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

func (*QueryResult) XXX_Merge

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

func (*QueryResult) XXX_Size

func (m *QueryResult) XXX_Size() int

func (*QueryResult) XXX_Unmarshal

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

type ReadHints

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

func (*ReadHints) Descriptor

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

func (*ReadHints) GetBy added in v2.25.0

func (m *ReadHints) GetBy() bool

func (*ReadHints) GetEndMs

func (m *ReadHints) GetEndMs() int64

func (*ReadHints) GetFunc

func (m *ReadHints) GetFunc() string

func (*ReadHints) GetGrouping added in v2.25.0

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

func (*ReadHints) GetRangeMs added in v2.25.0

func (m *ReadHints) GetRangeMs() int64

func (*ReadHints) GetStartMs

func (m *ReadHints) GetStartMs() int64

func (*ReadHints) GetStepMs

func (m *ReadHints) GetStepMs() int64

func (*ReadHints) Marshal

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

func (*ReadHints) MarshalTo

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

func (*ReadHints) MarshalToSizedBuffer

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

func (*ReadHints) ProtoMessage

func (*ReadHints) ProtoMessage()

func (*ReadHints) Reset

func (m *ReadHints) Reset()

func (*ReadHints) Size

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

func (*ReadHints) String

func (m *ReadHints) String() string

func (*ReadHints) Unmarshal

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

func (*ReadHints) XXX_DiscardUnknown

func (m *ReadHints) XXX_DiscardUnknown()

func (*ReadHints) XXX_Marshal

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

func (*ReadHints) XXX_Merge

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

func (*ReadHints) XXX_Size

func (m *ReadHints) XXX_Size() int

func (*ReadHints) XXX_Unmarshal

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

type ReadRequest

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

ReadRequest represents a remote read request.

func (*ReadRequest) Descriptor

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

func (*ReadRequest) GetAcceptedResponseTypes added in v2.25.0

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

func (*ReadRequest) GetQueries

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

func (*ReadRequest) Marshal

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

func (*ReadRequest) MarshalTo

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

func (*ReadRequest) MarshalToSizedBuffer

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

func (*ReadRequest) ProtoMessage

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) Reset

func (m *ReadRequest) Reset()

func (*ReadRequest) Size

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

func (*ReadRequest) String

func (m *ReadRequest) String() string

func (*ReadRequest) Unmarshal

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

func (*ReadRequest) XXX_DiscardUnknown

func (m *ReadRequest) XXX_DiscardUnknown()

func (*ReadRequest) XXX_Marshal

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

func (*ReadRequest) XXX_Merge

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

func (*ReadRequest) XXX_Size

func (m *ReadRequest) XXX_Size() int

func (*ReadRequest) XXX_Unmarshal

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

type ReadRequest_ResponseType added in v2.25.0

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

func (ReadRequest_ResponseType) EnumDescriptor added in v2.25.0

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

func (ReadRequest_ResponseType) String added in v2.25.0

func (x ReadRequest_ResponseType) String() string

type ReadResponse

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

ReadResponse is a response when response_type equals SAMPLES.

func (*ReadResponse) Descriptor

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

func (*ReadResponse) GetResults

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

func (*ReadResponse) Marshal

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

func (*ReadResponse) MarshalTo

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

func (*ReadResponse) MarshalToSizedBuffer

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

func (*ReadResponse) ProtoMessage

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) Reset

func (m *ReadResponse) Reset()

func (*ReadResponse) Size

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

func (*ReadResponse) String

func (m *ReadResponse) String() string

func (*ReadResponse) Unmarshal

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

func (*ReadResponse) XXX_DiscardUnknown

func (m *ReadResponse) XXX_DiscardUnknown()

func (*ReadResponse) XXX_Marshal

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

func (*ReadResponse) XXX_Merge

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

func (*ReadResponse) XXX_Size

func (m *ReadResponse) XXX_Size() int

func (*ReadResponse) XXX_Unmarshal

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

type Sample

type Sample struct {
	Value                float64  `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp            int64    `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Sample) Descriptor

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

func (*Sample) GetTimestamp

func (m *Sample) GetTimestamp() int64

func (*Sample) GetValue

func (m *Sample) GetValue() float64

func (*Sample) Marshal

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

func (*Sample) MarshalTo

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

func (*Sample) MarshalToSizedBuffer

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

func (*Sample) ProtoMessage

func (*Sample) ProtoMessage()

func (*Sample) Reset

func (m *Sample) Reset()

func (*Sample) Size

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

func (*Sample) String

func (m *Sample) String() string

func (Sample) T added in v2.25.0

func (m Sample) T() int64

func (*Sample) Unmarshal

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

func (Sample) V added in v2.25.0

func (m Sample) V() float64

func (*Sample) XXX_DiscardUnknown

func (m *Sample) XXX_DiscardUnknown()

func (*Sample) XXX_Marshal

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

func (*Sample) XXX_Merge

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

func (*Sample) XXX_Size

func (m *Sample) XXX_Size() int

func (*Sample) XXX_Unmarshal

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

type TimeSeries

type TimeSeries struct {
	Labels               []Label  `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels"`
	Samples              []Sample `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TimeSeries represents samples and labels for a single time series.

func (*TimeSeries) Descriptor

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

func (*TimeSeries) GetLabels

func (m *TimeSeries) GetLabels() []Label

func (*TimeSeries) GetSamples

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

func (*TimeSeries) Marshal

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

func (*TimeSeries) MarshalTo

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

func (*TimeSeries) MarshalToSizedBuffer

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

func (*TimeSeries) ProtoMessage

func (*TimeSeries) ProtoMessage()

func (*TimeSeries) Reset

func (m *TimeSeries) Reset()

func (*TimeSeries) Size

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

func (*TimeSeries) String

func (m *TimeSeries) String() string

func (*TimeSeries) Unmarshal

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

func (*TimeSeries) XXX_DiscardUnknown

func (m *TimeSeries) XXX_DiscardUnknown()

func (*TimeSeries) XXX_Marshal

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

func (*TimeSeries) XXX_Merge

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

func (*TimeSeries) XXX_Size

func (m *TimeSeries) XXX_Size() int

func (*TimeSeries) XXX_Unmarshal

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

type WriteRequest

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

func (*WriteRequest) Descriptor

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

func (*WriteRequest) GetMetadata added in v2.25.0

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

func (*WriteRequest) GetTimeseries

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

func (*WriteRequest) Marshal

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

func (*WriteRequest) MarshalTo

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

func (*WriteRequest) MarshalToSizedBuffer

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

func (*WriteRequest) ProtoMessage

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset

func (m *WriteRequest) Reset()

func (*WriteRequest) Size

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

func (*WriteRequest) String

func (m *WriteRequest) String() string

func (*WriteRequest) Unmarshal

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

func (*WriteRequest) XXX_DiscardUnknown

func (m *WriteRequest) XXX_DiscardUnknown()

func (*WriteRequest) XXX_Marshal

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

func (*WriteRequest) XXX_Merge

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

func (*WriteRequest) XXX_Size

func (m *WriteRequest) XXX_Size() int

func (*WriteRequest) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL