Documentation ¶
Index ¶
- Variables
- type Chunk
- func (*Chunk) Descriptor() ([]byte, []int)
- func (m *Chunk) GetData() []byte
- func (m *Chunk) GetMaxTimeMs() int64
- func (m *Chunk) GetMinTimeMs() int64
- func (m *Chunk) GetType() Chunk_Encoding
- func (m *Chunk) Marshal() (dAtA []byte, err error)
- func (m *Chunk) MarshalTo(dAtA []byte) (int, error)
- func (m *Chunk) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Chunk) ProtoMessage()
- func (m *Chunk) Reset()
- func (m *Chunk) Size() (n int)
- func (m *Chunk) String() string
- func (m *Chunk) Unmarshal(dAtA []byte) error
- func (m *Chunk) XXX_DiscardUnknown()
- func (m *Chunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Chunk) XXX_Merge(src proto.Message)
- func (m *Chunk) XXX_Size() int
- func (m *Chunk) XXX_Unmarshal(b []byte) error
- type Chunk_Encoding
- type ChunkedReadResponse
- func (*ChunkedReadResponse) Descriptor() ([]byte, []int)
- func (m *ChunkedReadResponse) GetChunkedSeries() []*ChunkedSeries
- func (m *ChunkedReadResponse) GetQueryIndex() int64
- func (m *ChunkedReadResponse) Marshal() (dAtA []byte, err error)
- func (m *ChunkedReadResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ChunkedReadResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ChunkedReadResponse) ProtoMessage()
- func (m *ChunkedReadResponse) Reset()
- func (m *ChunkedReadResponse) Size() (n int)
- func (m *ChunkedReadResponse) String() string
- func (m *ChunkedReadResponse) Unmarshal(dAtA []byte) error
- func (m *ChunkedReadResponse) XXX_DiscardUnknown()
- func (m *ChunkedReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChunkedReadResponse) XXX_Merge(src proto.Message)
- func (m *ChunkedReadResponse) XXX_Size() int
- func (m *ChunkedReadResponse) XXX_Unmarshal(b []byte) error
- type ChunkedSeries
- func (*ChunkedSeries) Descriptor() ([]byte, []int)
- func (m *ChunkedSeries) GetChunks() []Chunk
- func (m *ChunkedSeries) GetLabels() []Label
- func (m *ChunkedSeries) Marshal() (dAtA []byte, err error)
- func (m *ChunkedSeries) MarshalTo(dAtA []byte) (int, error)
- func (m *ChunkedSeries) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ChunkedSeries) ProtoMessage()
- func (m *ChunkedSeries) Reset()
- func (m *ChunkedSeries) Size() (n int)
- func (m *ChunkedSeries) String() string
- func (m *ChunkedSeries) Unmarshal(dAtA []byte) error
- func (m *ChunkedSeries) XXX_DiscardUnknown()
- func (m *ChunkedSeries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChunkedSeries) XXX_Merge(src proto.Message)
- func (m *ChunkedSeries) XXX_Size() int
- func (m *ChunkedSeries) XXX_Unmarshal(b []byte) error
- type Exemplar
- func (*Exemplar) Descriptor() ([]byte, []int)
- func (m *Exemplar) GetLabels() []Label
- func (m *Exemplar) GetTimestamp() int64
- func (m *Exemplar) GetValue() float64
- func (m *Exemplar) Marshal() (dAtA []byte, err error)
- func (m *Exemplar) MarshalTo(dAtA []byte) (int, error)
- func (m *Exemplar) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Exemplar) ProtoMessage()
- func (m *Exemplar) Reset()
- func (m *Exemplar) Size() (n int)
- func (m *Exemplar) String() string
- func (m *Exemplar) Unmarshal(dAtA []byte) error
- func (m *Exemplar) XXX_DiscardUnknown()
- func (m *Exemplar) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Exemplar) XXX_Merge(src proto.Message)
- func (m *Exemplar) XXX_Size() int
- func (m *Exemplar) XXX_Unmarshal(b []byte) error
- type Label
- func (*Label) Descriptor() ([]byte, []int)
- func (m *Label) GetName() string
- func (m *Label) GetValue() string
- func (m *Label) Marshal() (dAtA []byte, err error)
- func (m *Label) MarshalTo(dAtA []byte) (int, error)
- func (m *Label) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Label) ProtoMessage()
- func (m *Label) Reset()
- func (m *Label) Size() (n int)
- func (m *Label) String() string
- func (m *Label) Unmarshal(dAtA []byte) error
- func (m *Label) XXX_DiscardUnknown()
- func (m *Label) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Label) XXX_Merge(src proto.Message)
- func (m *Label) XXX_Size() int
- func (m *Label) XXX_Unmarshal(b []byte) error
- type LabelMatcher
- func (*LabelMatcher) Descriptor() ([]byte, []int)
- func (m *LabelMatcher) GetName() string
- func (m *LabelMatcher) GetType() LabelMatcher_Type
- func (m *LabelMatcher) GetValue() string
- func (m *LabelMatcher) Marshal() (dAtA []byte, err error)
- func (m *LabelMatcher) MarshalTo(dAtA []byte) (int, error)
- func (m *LabelMatcher) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LabelMatcher) ProtoMessage()
- func (m *LabelMatcher) Reset()
- func (m *LabelMatcher) Size() (n int)
- func (m *LabelMatcher) String() string
- func (m *LabelMatcher) Unmarshal(dAtA []byte) error
- func (m *LabelMatcher) XXX_DiscardUnknown()
- func (m *LabelMatcher) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LabelMatcher) XXX_Merge(src proto.Message)
- func (m *LabelMatcher) XXX_Size() int
- func (m *LabelMatcher) XXX_Unmarshal(b []byte) error
- type LabelMatcher_Type
- type Labels
- func (*Labels) Descriptor() ([]byte, []int)
- func (m *Labels) GetLabels() []Label
- func (m *Labels) Marshal() (dAtA []byte, err error)
- func (m *Labels) MarshalTo(dAtA []byte) (int, error)
- func (m *Labels) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Labels) ProtoMessage()
- func (m *Labels) Reset()
- func (m *Labels) Size() (n int)
- func (m *Labels) String() string
- func (m *Labels) Unmarshal(dAtA []byte) error
- func (m *Labels) XXX_DiscardUnknown()
- func (m *Labels) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Labels) XXX_Merge(src proto.Message)
- func (m *Labels) XXX_Size() int
- func (m *Labels) XXX_Unmarshal(b []byte) error
- type MetricMetadata
- func (*MetricMetadata) Descriptor() ([]byte, []int)
- func (m *MetricMetadata) GetHelp() string
- func (m *MetricMetadata) GetMetricFamilyName() string
- func (m *MetricMetadata) GetType() MetricMetadata_MetricType
- func (m *MetricMetadata) GetUnit() string
- func (m *MetricMetadata) Marshal() (dAtA []byte, err error)
- func (m *MetricMetadata) MarshalTo(dAtA []byte) (int, error)
- func (m *MetricMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MetricMetadata) ProtoMessage()
- func (m *MetricMetadata) Reset()
- func (m *MetricMetadata) Size() (n int)
- func (m *MetricMetadata) String() string
- func (m *MetricMetadata) Unmarshal(dAtA []byte) error
- func (m *MetricMetadata) XXX_DiscardUnknown()
- func (m *MetricMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MetricMetadata) XXX_Merge(src proto.Message)
- func (m *MetricMetadata) XXX_Size() int
- func (m *MetricMetadata) XXX_Unmarshal(b []byte) error
- type MetricMetadata_MetricType
- type Query
- func (*Query) Descriptor() ([]byte, []int)
- func (m *Query) GetEndTimestampMs() int64
- func (m *Query) GetHints() *ReadHints
- func (m *Query) GetMatchers() []*LabelMatcher
- func (m *Query) GetStartTimestampMs() int64
- func (m *Query) Marshal() (dAtA []byte, err error)
- func (m *Query) MarshalTo(dAtA []byte) (int, error)
- func (m *Query) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Query) ProtoMessage()
- func (m *Query) Reset()
- func (m *Query) Size() (n int)
- func (m *Query) String() string
- func (m *Query) Unmarshal(dAtA []byte) error
- func (m *Query) XXX_DiscardUnknown()
- func (m *Query) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Query) XXX_Merge(src proto.Message)
- func (m *Query) XXX_Size() int
- func (m *Query) XXX_Unmarshal(b []byte) error
- type QueryResult
- func (*QueryResult) Descriptor() ([]byte, []int)
- func (m *QueryResult) GetTimeseries() []*TimeSeries
- func (m *QueryResult) Marshal() (dAtA []byte, err error)
- func (m *QueryResult) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryResult) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryResult) ProtoMessage()
- func (m *QueryResult) Reset()
- func (m *QueryResult) Size() (n int)
- func (m *QueryResult) String() string
- func (m *QueryResult) Unmarshal(dAtA []byte) error
- func (m *QueryResult) XXX_DiscardUnknown()
- func (m *QueryResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryResult) XXX_Merge(src proto.Message)
- func (m *QueryResult) XXX_Size() int
- func (m *QueryResult) XXX_Unmarshal(b []byte) error
- type ReadHints
- func (*ReadHints) Descriptor() ([]byte, []int)
- func (m *ReadHints) GetBy() bool
- func (m *ReadHints) GetEndMs() int64
- func (m *ReadHints) GetFunc() string
- func (m *ReadHints) GetGrouping() []string
- func (m *ReadHints) GetRangeMs() int64
- func (m *ReadHints) GetStartMs() int64
- func (m *ReadHints) GetStepMs() int64
- func (m *ReadHints) Marshal() (dAtA []byte, err error)
- func (m *ReadHints) MarshalTo(dAtA []byte) (int, error)
- func (m *ReadHints) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReadHints) ProtoMessage()
- func (m *ReadHints) Reset()
- func (m *ReadHints) Size() (n int)
- func (m *ReadHints) String() string
- func (m *ReadHints) Unmarshal(dAtA []byte) error
- func (m *ReadHints) XXX_DiscardUnknown()
- func (m *ReadHints) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadHints) XXX_Merge(src proto.Message)
- func (m *ReadHints) XXX_Size() int
- func (m *ReadHints) XXX_Unmarshal(b []byte) error
- type ReadRequest
- func (*ReadRequest) Descriptor() ([]byte, []int)
- func (m *ReadRequest) GetAcceptedResponseTypes() []ReadRequest_ResponseType
- func (m *ReadRequest) GetQueries() []*Query
- func (m *ReadRequest) Marshal() (dAtA []byte, err error)
- func (m *ReadRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ReadRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReadRequest) ProtoMessage()
- func (m *ReadRequest) Reset()
- func (m *ReadRequest) Size() (n int)
- func (m *ReadRequest) String() string
- func (m *ReadRequest) Unmarshal(dAtA []byte) error
- func (m *ReadRequest) XXX_DiscardUnknown()
- func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadRequest) XXX_Merge(src proto.Message)
- func (m *ReadRequest) XXX_Size() int
- func (m *ReadRequest) XXX_Unmarshal(b []byte) error
- type ReadRequest_ResponseType
- type ReadResponse
- func (*ReadResponse) Descriptor() ([]byte, []int)
- func (m *ReadResponse) GetResults() []*QueryResult
- func (m *ReadResponse) Marshal() (dAtA []byte, err error)
- func (m *ReadResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ReadResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReadResponse) ProtoMessage()
- func (m *ReadResponse) Reset()
- func (m *ReadResponse) Size() (n int)
- func (m *ReadResponse) String() string
- func (m *ReadResponse) Unmarshal(dAtA []byte) error
- func (m *ReadResponse) XXX_DiscardUnknown()
- func (m *ReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadResponse) XXX_Merge(src proto.Message)
- func (m *ReadResponse) XXX_Size() int
- func (m *ReadResponse) XXX_Unmarshal(b []byte) error
- type Sample
- func (*Sample) Descriptor() ([]byte, []int)
- func (m *Sample) GetTimestamp() int64
- func (m *Sample) GetValue() float64
- func (m *Sample) Marshal() (dAtA []byte, err error)
- func (m *Sample) MarshalTo(dAtA []byte) (int, error)
- func (m *Sample) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Sample) ProtoMessage()
- func (m *Sample) Reset()
- func (m *Sample) Size() (n int)
- func (m *Sample) String() string
- func (m Sample) T() int64
- func (m *Sample) Unmarshal(dAtA []byte) error
- func (m Sample) V() float64
- func (m *Sample) XXX_DiscardUnknown()
- func (m *Sample) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Sample) XXX_Merge(src proto.Message)
- func (m *Sample) XXX_Size() int
- func (m *Sample) XXX_Unmarshal(b []byte) error
- type TimeSeries
- func (*TimeSeries) Descriptor() ([]byte, []int)
- func (m *TimeSeries) GetExemplars() []Exemplar
- func (m *TimeSeries) GetLabels() []Label
- func (m *TimeSeries) GetSamples() []Sample
- func (m *TimeSeries) Marshal() (dAtA []byte, err error)
- func (m *TimeSeries) MarshalTo(dAtA []byte) (int, error)
- func (m *TimeSeries) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TimeSeries) ProtoMessage()
- func (m *TimeSeries) Reset()
- func (m *TimeSeries) Size() (n int)
- func (m *TimeSeries) String() string
- func (m *TimeSeries) Unmarshal(dAtA []byte) error
- func (m *TimeSeries) XXX_DiscardUnknown()
- func (m *TimeSeries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TimeSeries) XXX_Merge(src proto.Message)
- func (m *TimeSeries) XXX_Size() int
- func (m *TimeSeries) XXX_Unmarshal(b []byte) error
- type WriteRequest
- func (*WriteRequest) Descriptor() ([]byte, []int)
- func (m *WriteRequest) GetMetadata() []MetricMetadata
- func (m *WriteRequest) GetTimeseries() []TimeSeries
- func (m *WriteRequest) Marshal() (dAtA []byte, err error)
- func (m *WriteRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WriteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WriteRequest) ProtoMessage()
- func (m *WriteRequest) Reset()
- func (m *WriteRequest) Size() (n int)
- func (m *WriteRequest) String() string
- func (m *WriteRequest) Unmarshal(dAtA []byte) error
- func (m *WriteRequest) XXX_DiscardUnknown()
- func (m *WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WriteRequest) XXX_Merge(src proto.Message)
- func (m *WriteRequest) XXX_Size() int
- func (m *WriteRequest) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthRemote = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowRemote = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupRemote = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthTypes = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTypes = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group") )
var Chunk_Encoding_name = map[int32]string{
0: "UNKNOWN",
1: "XOR",
}
var Chunk_Encoding_value = map[string]int32{
"UNKNOWN": 0,
"XOR": 1,
}
var LabelMatcher_Type_name = map[int32]string{
0: "EQ",
1: "NEQ",
2: "RE",
3: "NRE",
}
var LabelMatcher_Type_value = map[string]int32{
"EQ": 0,
"NEQ": 1,
"RE": 2,
"NRE": 3,
}
var MetricMetadata_MetricType_name = map[int32]string{
0: "UNKNOWN",
1: "COUNTER",
2: "GAUGE",
3: "HISTOGRAM",
4: "GAUGEHISTOGRAM",
5: "SUMMARY",
6: "INFO",
7: "STATESET",
}
var MetricMetadata_MetricType_value = map[string]int32{
"UNKNOWN": 0,
"COUNTER": 1,
"GAUGE": 2,
"HISTOGRAM": 3,
"GAUGEHISTOGRAM": 4,
"SUMMARY": 5,
"INFO": 6,
"STATESET": 7,
}
var ReadRequest_ResponseType_name = map[int32]string{
0: "SAMPLES",
1: "STREAMED_XOR_CHUNKS",
}
var ReadRequest_ResponseType_value = map[string]int32{
"SAMPLES": 0,
"STREAMED_XOR_CHUNKS": 1,
}
Functions ¶
This section is empty.
Types ¶
type Chunk ¶
type Chunk struct { MinTimeMs int64 `protobuf:"varint,1,opt,name=min_time_ms,json=minTimeMs,proto3" json:"min_time_ms,omitempty"` MaxTimeMs int64 `protobuf:"varint,2,opt,name=max_time_ms,json=maxTimeMs,proto3" json:"max_time_ms,omitempty"` Type Chunk_Encoding `protobuf:"varint,3,opt,name=type,proto3,enum=prometheus.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 ¶
func (*Chunk) GetMaxTimeMs ¶
func (*Chunk) GetMinTimeMs ¶
func (*Chunk) GetType ¶
func (m *Chunk) GetType() Chunk_Encoding
func (*Chunk) ProtoMessage ¶
func (*Chunk) ProtoMessage()
func (*Chunk) XXX_DiscardUnknown ¶
func (m *Chunk) XXX_DiscardUnknown()
func (*Chunk) XXX_Marshal ¶
func (*Chunk) XXX_Unmarshal ¶
type Chunk_Encoding ¶
type Chunk_Encoding int32
We require this to match chunkenc.Encoding.
const ( Chunk_UNKNOWN Chunk_Encoding = 0 Chunk_XOR Chunk_Encoding = 1 )
func (Chunk_Encoding) EnumDescriptor ¶
func (Chunk_Encoding) EnumDescriptor() ([]byte, []int)
func (Chunk_Encoding) String ¶
func (x Chunk_Encoding) String() string
type ChunkedReadResponse ¶
type ChunkedReadResponse struct { ChunkedSeries []*ChunkedSeries `protobuf:"bytes,1,rep,name=chunked_series,json=chunkedSeries,proto3" json:"chunked_series,omitempty"` // query_index represents an index of the query from ReadRequest.queries these chunks relates to. QueryIndex int64 `protobuf:"varint,2,opt,name=query_index,json=queryIndex,proto3" json:"query_index,omitempty"` 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 ¶
func (*ChunkedReadResponse) Descriptor() ([]byte, []int)
func (*ChunkedReadResponse) GetChunkedSeries ¶
func (m *ChunkedReadResponse) GetChunkedSeries() []*ChunkedSeries
func (*ChunkedReadResponse) GetQueryIndex ¶
func (m *ChunkedReadResponse) GetQueryIndex() int64
func (*ChunkedReadResponse) Marshal ¶
func (m *ChunkedReadResponse) Marshal() (dAtA []byte, err error)
func (*ChunkedReadResponse) MarshalTo ¶
func (m *ChunkedReadResponse) MarshalTo(dAtA []byte) (int, error)
func (*ChunkedReadResponse) MarshalToSizedBuffer ¶
func (m *ChunkedReadResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ChunkedReadResponse) ProtoMessage ¶
func (*ChunkedReadResponse) ProtoMessage()
func (*ChunkedReadResponse) Reset ¶
func (m *ChunkedReadResponse) Reset()
func (*ChunkedReadResponse) Size ¶
func (m *ChunkedReadResponse) Size() (n int)
func (*ChunkedReadResponse) String ¶
func (m *ChunkedReadResponse) String() string
func (*ChunkedReadResponse) Unmarshal ¶
func (m *ChunkedReadResponse) Unmarshal(dAtA []byte) error
func (*ChunkedReadResponse) XXX_DiscardUnknown ¶
func (m *ChunkedReadResponse) XXX_DiscardUnknown()
func (*ChunkedReadResponse) XXX_Marshal ¶
func (m *ChunkedReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChunkedReadResponse) XXX_Merge ¶
func (m *ChunkedReadResponse) XXX_Merge(src proto.Message)
func (*ChunkedReadResponse) XXX_Size ¶
func (m *ChunkedReadResponse) XXX_Size() int
func (*ChunkedReadResponse) XXX_Unmarshal ¶
func (m *ChunkedReadResponse) XXX_Unmarshal(b []byte) error
type ChunkedSeries ¶
type ChunkedSeries struct { // Labels should be sorted. Labels []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 ¶
func (*ChunkedSeries) Descriptor() ([]byte, []int)
func (*ChunkedSeries) GetChunks ¶
func (m *ChunkedSeries) GetChunks() []Chunk
func (*ChunkedSeries) GetLabels ¶
func (m *ChunkedSeries) GetLabels() []Label
func (*ChunkedSeries) Marshal ¶
func (m *ChunkedSeries) Marshal() (dAtA []byte, err error)
func (*ChunkedSeries) MarshalToSizedBuffer ¶
func (m *ChunkedSeries) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ChunkedSeries) ProtoMessage ¶
func (*ChunkedSeries) ProtoMessage()
func (*ChunkedSeries) Reset ¶
func (m *ChunkedSeries) Reset()
func (*ChunkedSeries) Size ¶
func (m *ChunkedSeries) Size() (n int)
func (*ChunkedSeries) String ¶
func (m *ChunkedSeries) String() string
func (*ChunkedSeries) Unmarshal ¶
func (m *ChunkedSeries) Unmarshal(dAtA []byte) error
func (*ChunkedSeries) XXX_DiscardUnknown ¶
func (m *ChunkedSeries) XXX_DiscardUnknown()
func (*ChunkedSeries) XXX_Marshal ¶
func (m *ChunkedSeries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChunkedSeries) XXX_Merge ¶
func (m *ChunkedSeries) XXX_Merge(src proto.Message)
func (*ChunkedSeries) XXX_Size ¶
func (m *ChunkedSeries) XXX_Size() int
func (*ChunkedSeries) XXX_Unmarshal ¶
func (m *ChunkedSeries) XXX_Unmarshal(b []byte) error
type Exemplar ¶
type Exemplar struct { // Optional, can be empty. Labels []Label `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels"` Value float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"` // timestamp is in ms format, see pkg/timestamp/timestamp.go for // conversion from time.Time to Prometheus timestamp. Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Exemplar) Descriptor ¶
func (*Exemplar) GetTimestamp ¶
func (*Exemplar) MarshalToSizedBuffer ¶
func (*Exemplar) ProtoMessage ¶
func (*Exemplar) ProtoMessage()
func (*Exemplar) XXX_DiscardUnknown ¶
func (m *Exemplar) XXX_DiscardUnknown()
func (*Exemplar) XXX_Marshal ¶
func (*Exemplar) XXX_Unmarshal ¶
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) ProtoMessage ¶
func (*Label) ProtoMessage()
func (*Label) XXX_DiscardUnknown ¶
func (m *Label) XXX_DiscardUnknown()
func (*Label) XXX_Marshal ¶
func (*Label) XXX_Unmarshal ¶
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) 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) MarshalToSizedBuffer ¶
func (*Labels) ProtoMessage ¶
func (*Labels) ProtoMessage()
func (*Labels) XXX_DiscardUnknown ¶
func (m *Labels) XXX_DiscardUnknown()
func (*Labels) XXX_Marshal ¶
func (*Labels) XXX_Unmarshal ¶
type MetricMetadata ¶
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 ¶
func (*MetricMetadata) Descriptor() ([]byte, []int)
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) Marshal ¶
func (m *MetricMetadata) Marshal() (dAtA []byte, err 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 (m *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 ( 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 ¶
func (MetricMetadata_MetricType) EnumDescriptor() ([]byte, []int)
func (MetricMetadata_MetricType) String ¶
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) GetEndTimestampMs ¶
func (*Query) GetMatchers ¶
func (m *Query) GetMatchers() []*LabelMatcher
func (*Query) GetStartTimestampMs ¶
func (*Query) ProtoMessage ¶
func (*Query) ProtoMessage()
func (*Query) XXX_DiscardUnknown ¶
func (m *Query) XXX_DiscardUnknown()
func (*Query) XXX_Marshal ¶
func (*Query) XXX_Unmarshal ¶
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) 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) GetGrouping ¶
func (*ReadHints) GetRangeMs ¶
func (*ReadHints) GetStartMs ¶
func (*ReadHints) MarshalToSizedBuffer ¶
func (*ReadHints) ProtoMessage ¶
func (*ReadHints) ProtoMessage()
func (*ReadHints) XXX_DiscardUnknown ¶
func (m *ReadHints) XXX_DiscardUnknown()
func (*ReadHints) XXX_Marshal ¶
func (*ReadHints) XXX_Unmarshal ¶
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 ¶
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) MarshalToSizedBuffer ¶
func (m *ReadRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReadRequest) ProtoMessage ¶
func (*ReadRequest) ProtoMessage()
func (*ReadRequest) Reset ¶
func (m *ReadRequest) Reset()
func (*ReadRequest) Size ¶
func (m *ReadRequest) Size() (n int)
func (*ReadRequest) String ¶
func (m *ReadRequest) String() string
func (*ReadRequest) Unmarshal ¶
func (m *ReadRequest) Unmarshal(dAtA []byte) error
func (*ReadRequest) XXX_DiscardUnknown ¶
func (m *ReadRequest) XXX_DiscardUnknown()
func (*ReadRequest) XXX_Marshal ¶
func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReadRequest) XXX_Merge ¶
func (m *ReadRequest) XXX_Merge(src proto.Message)
func (*ReadRequest) XXX_Size ¶
func (m *ReadRequest) XXX_Size() int
func (*ReadRequest) XXX_Unmarshal ¶
func (m *ReadRequest) XXX_Unmarshal(b []byte) error
type ReadRequest_ResponseType ¶
type ReadRequest_ResponseType int32
const ( // Server will return a single ReadResponse message with matched series that includes list of raw samples. // It's recommended to use streamed response types instead. // // Response headers: // Content-Type: "application/x-protobuf" // Content-Encoding: "snappy" ReadRequest_SAMPLES ReadRequest_ResponseType = 0 // Server will stream a delimited ChunkedReadResponse message that contains XOR encoded chunks for a single series. // Each message is following varint size and fixed size bigendian uint32 for CRC32 Castagnoli checksum. // // Response headers: // Content-Type: "application/x-streamed-protobuf; proto=prometheus.ChunkedReadResponse" // Content-Encoding: "" ReadRequest_STREAMED_XOR_CHUNKS ReadRequest_ResponseType = 1 )
func (ReadRequest_ResponseType) EnumDescriptor ¶
func (ReadRequest_ResponseType) EnumDescriptor() ([]byte, []int)
func (ReadRequest_ResponseType) String ¶
func (x ReadRequest_ResponseType) String() string
type ReadResponse ¶
type ReadResponse struct { // In same order as the request's queries. Results []*QueryResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"` 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) 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 is in ms format, see pkg/timestamp/timestamp.go for // conversion from time.Time to Prometheus timestamp. 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) GetTimestamp ¶
func (*Sample) MarshalToSizedBuffer ¶
func (*Sample) ProtoMessage ¶
func (*Sample) ProtoMessage()
func (*Sample) XXX_DiscardUnknown ¶
func (m *Sample) XXX_DiscardUnknown()
func (*Sample) XXX_Marshal ¶
func (*Sample) XXX_Unmarshal ¶
type TimeSeries ¶
type TimeSeries struct { // For a timeseries to be valid, and for the samples and exemplars // to be ingested by the remote system properly, the labels field is required. Labels []Label `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels"` Samples []Sample `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples"` Exemplars []Exemplar `protobuf:"bytes,3,rep,name=exemplars,proto3" json:"exemplars"` 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) GetExemplars ¶
func (m *TimeSeries) GetExemplars() []Exemplar
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) 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 ¶
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) 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