Documentation ¶
Overview ¶
Package remote is a generated protocol buffer package.
It is generated from these files:
remote.proto
It has these top-level messages:
Sample LabelPair TimeSeries WriteRequest ReadRequest ReadResponse Query LabelMatcher QueryResult
Index ¶
- Variables
- type LabelMatcher
- func (*LabelMatcher) Descriptor() ([]byte, []int)
- func (m *LabelMatcher) GetName() string
- func (m *LabelMatcher) GetType() MatchType
- func (m *LabelMatcher) GetValue() string
- func (m *LabelMatcher) Marshal() (dAtA []byte, err error)
- func (m *LabelMatcher) MarshalTo(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
- type LabelPair
- func (*LabelPair) Descriptor() ([]byte, []int)
- func (m *LabelPair) GetName() string
- func (m *LabelPair) GetValue() string
- func (m *LabelPair) Marshal() (dAtA []byte, err error)
- func (m *LabelPair) MarshalTo(dAtA []byte) (int, error)
- func (*LabelPair) ProtoMessage()
- func (m *LabelPair) Reset()
- func (m *LabelPair) Size() (n int)
- func (m *LabelPair) String() string
- func (m *LabelPair) Unmarshal(dAtA []byte) error
- type MatchType
- type Query
- func (*Query) Descriptor() ([]byte, []int)
- func (m *Query) GetEndTimestampMs() int64
- 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 (*Query) ProtoMessage()
- func (m *Query) Reset()
- func (m *Query) Size() (n int)
- func (m *Query) String() string
- func (m *Query) Unmarshal(dAtA []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 (*QueryResult) ProtoMessage()
- func (m *QueryResult) Reset()
- func (m *QueryResult) Size() (n int)
- func (m *QueryResult) String() string
- func (m *QueryResult) Unmarshal(dAtA []byte) error
- type ReadRequest
- func (*ReadRequest) Descriptor() ([]byte, []int)
- func (m *ReadRequest) GetQueries() []*Query
- func (m *ReadRequest) Marshal() (dAtA []byte, err error)
- func (m *ReadRequest) MarshalTo(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
- 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 (*ReadResponse) ProtoMessage()
- func (m *ReadResponse) Reset()
- func (m *ReadResponse) Size() (n int)
- func (m *ReadResponse) String() string
- func (m *ReadResponse) Unmarshal(dAtA []byte) error
- type Sample
- func (*Sample) Descriptor() ([]byte, []int)
- func (m *Sample) GetTimestampMs() int64
- func (m *Sample) GetValue() float64
- func (m *Sample) Marshal() (dAtA []byte, err error)
- func (m *Sample) MarshalTo(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) Unmarshal(dAtA []byte) error
- type TimeSeries
- func (*TimeSeries) Descriptor() ([]byte, []int)
- func (m *TimeSeries) GetLabels() []*LabelPair
- func (m *TimeSeries) GetSamples() []*Sample
- func (m *TimeSeries) Marshal() (dAtA []byte, err error)
- func (m *TimeSeries) MarshalTo(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
- type WriteRequest
- func (*WriteRequest) Descriptor() ([]byte, []int)
- func (m *WriteRequest) GetTimeseries() []*TimeSeries
- func (m *WriteRequest) Marshal() (dAtA []byte, err error)
- func (m *WriteRequest) MarshalTo(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
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthRemote = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowRemote = fmt.Errorf("proto: integer overflow") )
View Source
var MatchType_name = map[int32]string{
0: "EQUAL",
1: "NOT_EQUAL",
2: "REGEX_MATCH",
3: "REGEX_NO_MATCH",
}
View Source
var MatchType_value = map[string]int32{
"EQUAL": 0,
"NOT_EQUAL": 1,
"REGEX_MATCH": 2,
"REGEX_NO_MATCH": 3,
}
Functions ¶
This section is empty.
Types ¶
type LabelMatcher ¶
type LabelMatcher struct { Type MatchType `protobuf:"varint,1,opt,name=type,proto3,enum=remote.MatchType" 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"` }
func (*LabelMatcher) Descriptor ¶
func (*LabelMatcher) Descriptor() ([]byte, []int)
func (*LabelMatcher) GetName ¶
func (m *LabelMatcher) GetName() string
func (*LabelMatcher) GetType ¶
func (m *LabelMatcher) GetType() MatchType
func (*LabelMatcher) GetValue ¶
func (m *LabelMatcher) GetValue() string
func (*LabelMatcher) Marshal ¶
func (m *LabelMatcher) Marshal() (dAtA []byte, err 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
type LabelPair ¶
type LabelPair 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"` }
func (*LabelPair) Descriptor ¶
func (*LabelPair) ProtoMessage ¶
func (*LabelPair) ProtoMessage()
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" json:"matchers,omitempty"` }
func (*Query) Descriptor ¶
func (*Query) GetEndTimestampMs ¶
func (*Query) GetMatchers ¶
func (m *Query) GetMatchers() []*LabelMatcher
func (*Query) GetStartTimestampMs ¶
func (*Query) ProtoMessage ¶
func (*Query) ProtoMessage()
type QueryResult ¶
type QueryResult struct {
Timeseries []*TimeSeries `protobuf:"bytes,1,rep,name=timeseries" json:"timeseries,omitempty"`
}
func (*QueryResult) Descriptor ¶
func (*QueryResult) Descriptor() ([]byte, []int)
func (*QueryResult) GetTimeseries ¶
func (m *QueryResult) GetTimeseries() []*TimeSeries
func (*QueryResult) Marshal ¶
func (m *QueryResult) Marshal() (dAtA []byte, err error)
func (*QueryResult) 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
type ReadRequest ¶
type ReadRequest struct {
Queries []*Query `protobuf:"bytes,1,rep,name=queries" json:"queries,omitempty"`
}
func (*ReadRequest) Descriptor ¶
func (*ReadRequest) Descriptor() ([]byte, []int)
func (*ReadRequest) GetQueries ¶
func (m *ReadRequest) GetQueries() []*Query
func (*ReadRequest) Marshal ¶
func (m *ReadRequest) Marshal() (dAtA []byte, err 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
type ReadResponse ¶
type ReadResponse struct { // In same order as the request's queries. Results []*QueryResult `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"` }
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) 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
type Sample ¶
type Sample 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 (*Sample) Descriptor ¶
func (*Sample) GetTimestampMs ¶
func (*Sample) ProtoMessage ¶
func (*Sample) ProtoMessage()
type TimeSeries ¶
type TimeSeries struct { Labels []*LabelPair `protobuf:"bytes,1,rep,name=labels" json:"labels,omitempty"` // Sorted by time, oldest sample first. Samples []*Sample `protobuf:"bytes,2,rep,name=samples" json:"samples,omitempty"` }
func (*TimeSeries) Descriptor ¶
func (*TimeSeries) Descriptor() ([]byte, []int)
func (*TimeSeries) GetLabels ¶
func (m *TimeSeries) GetLabels() []*LabelPair
func (*TimeSeries) GetSamples ¶
func (m *TimeSeries) GetSamples() []*Sample
func (*TimeSeries) Marshal ¶
func (m *TimeSeries) Marshal() (dAtA []byte, err 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
type WriteRequest ¶
type WriteRequest struct {
Timeseries []*TimeSeries `protobuf:"bytes,1,rep,name=timeseries" json:"timeseries,omitempty"`
}
func (*WriteRequest) Descriptor ¶
func (*WriteRequest) Descriptor() ([]byte, []int)
func (*WriteRequest) GetTimeseries ¶
func (m *WriteRequest) GetTimeseries() []*TimeSeries
func (*WriteRequest) Marshal ¶
func (m *WriteRequest) Marshal() (dAtA []byte, err 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
Click to show internal directories.
Click to hide internal directories.