prompb

package
v0.15.0-rc.6 Latest Latest
Warning

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

 Go to latest Published: Apr 24, 2020 License: Apache-2.0 Imports: 6 Imported by: 15

Documentation

Overview

Package prompb is a generated protocol buffer package.

It is generated from these files: 

github.com/m3db/m3/src/query/generated/proto/prompb/annotations.proto
github.com/m3db/m3/src/query/generated/proto/prompb/remote.proto
github.com/m3db/m3/src/query/generated/proto/prompb/types.proto

It has these top-level messages: 

AnnotatedSample
AnnotatedTimeSeries
AnnotatedWriteRequest
WriteRequest
ReadRequest
ReadResponse
Query
QueryResult
Sample
TimeSeries
Label
Labels
LabelMatcher

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthAnnotations = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAnnotations   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthRemote = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRemote   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthTypes = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes   = fmt.Errorf("proto: integer overflow")
)
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,
}

Functions

This section is empty.

Types

type AnnotatedSample added in v0.15.0 

type AnnotatedSample 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"`
	Annotation []byte  `protobuf:"bytes,3,opt,name=annotation,proto3" json:"annotation,omitempty"`
}

func (*AnnotatedSample) Descriptor added in v0.15.0 

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

func (*AnnotatedSample) GetAnnotation added in v0.15.0 

func (m *AnnotatedSample) GetAnnotation() []byte

func (*AnnotatedSample) GetTimestamp added in v0.15.0 

func (m *AnnotatedSample) GetTimestamp() int64

func (*AnnotatedSample) GetValue added in v0.15.0 

func (m *AnnotatedSample) GetValue() float64

func (*AnnotatedSample) Marshal added in v0.15.0 

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

func (*AnnotatedSample) MarshalTo added in v0.15.0 

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

func (*AnnotatedSample) ProtoMessage added in v0.15.0 

func (*AnnotatedSample) ProtoMessage()

func (*AnnotatedSample) Reset added in v0.15.0 

func (m *AnnotatedSample) Reset()

func (*AnnotatedSample) Size added in v0.15.0 

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

func (*AnnotatedSample) String added in v0.15.0 

func (m *AnnotatedSample) String() string

func (*AnnotatedSample) Unmarshal added in v0.15.0 

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

type AnnotatedTimeSeries added in v0.15.0 

type AnnotatedTimeSeries struct {
	Labels  []Label           `protobuf:"bytes,1,rep,name=labels" json:"labels"`
	Samples []AnnotatedSample `protobuf:"bytes,2,rep,name=samples" json:"samples"`
}

func (*AnnotatedTimeSeries) Descriptor added in v0.15.0 

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

func (*AnnotatedTimeSeries) GetLabels added in v0.15.0 

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

func (*AnnotatedTimeSeries) GetSamples added in v0.15.0 

func (m *AnnotatedTimeSeries) GetSamples() []AnnotatedSample

func (*AnnotatedTimeSeries) Marshal added in v0.15.0 

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

func (*AnnotatedTimeSeries) MarshalTo added in v0.15.0 

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

func (*AnnotatedTimeSeries) ProtoMessage added in v0.15.0 

func (*AnnotatedTimeSeries) ProtoMessage()

func (*AnnotatedTimeSeries) Reset added in v0.15.0 

func (m *AnnotatedTimeSeries) Reset()

func (*AnnotatedTimeSeries) Size added in v0.15.0 

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

func (*AnnotatedTimeSeries) String added in v0.15.0 

func (m *AnnotatedTimeSeries) String() string

func (*AnnotatedTimeSeries) Unmarshal added in v0.15.0 

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

type AnnotatedWriteRequest added in v0.15.0 

type AnnotatedWriteRequest struct {
	Timeseries []AnnotatedTimeSeries `protobuf:"bytes,1,rep,name=timeseries" json:"timeseries"`
}

func (*AnnotatedWriteRequest) Descriptor added in v0.15.0 

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

func (*AnnotatedWriteRequest) GetTimeseries added in v0.15.0 

func (m *AnnotatedWriteRequest) GetTimeseries() []AnnotatedTimeSeries

func (*AnnotatedWriteRequest) Marshal added in v0.15.0 

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

func (*AnnotatedWriteRequest) MarshalTo added in v0.15.0 

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

func (*AnnotatedWriteRequest) ProtoMessage added in v0.15.0 

func (*AnnotatedWriteRequest) ProtoMessage()

func (*AnnotatedWriteRequest) Reset added in v0.15.0 

func (m *AnnotatedWriteRequest) Reset()

func (*AnnotatedWriteRequest) Size added in v0.15.0 

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

func (*AnnotatedWriteRequest) String added in v0.15.0 

func (m *AnnotatedWriteRequest) String() string

func (*AnnotatedWriteRequest) Unmarshal added in v0.15.0 

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

type Label 

type Label 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 (*Label) Descriptor 

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

func (*Label) GetName 

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

func (*Label) GetValue 

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

func (*Label) Marshal 

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

func (*Label) MarshalTo 

func (m *Label) MarshalTo(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

type LabelMatcher 

type LabelMatcher struct {
	Type  LabelMatcher_Type `protobuf:"varint,1,opt,name=type,proto3,enum=m3prometheus.LabelMatcher_Type" json:"type,omitempty"`
	Name  []byte            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Value []byte            `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

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() []byte

func (*LabelMatcher) GetType 

func (m *LabelMatcher) GetType() LabelMatcher_Type

func (*LabelMatcher) GetValue 

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

func (*LabelMatcher) Marshal 

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

func (*LabelMatcher) MarshalTo 

func (m *LabelMatcher) MarshalTo(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

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" json:"labels"`
}

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

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) Descriptor() ([]byte, []int)

func (*Query) GetEndTimestampMs 

func (m *Query) GetEndTimestampMs() int64

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

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

func (m *QueryResult) MarshalTo(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

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

func (m *ReadRequest) MarshalTo(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

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

func (m *ReadResponse) MarshalTo(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

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"`
}

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

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

type TimeSeries 

type TimeSeries struct {
	Labels  []Label  `protobuf:"bytes,1,rep,name=labels" json:"labels"`
	Samples []Sample `protobuf:"bytes,2,rep,name=samples" json:"samples"`
}

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) 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"`
}

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

func (m *WriteRequest) MarshalTo(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

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.