prompb

package
v0.6.1 Latest Latest
Warning

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

Go to latest
Published: Aug 14, 2019 License: Apache-2.0 Imports: 6 Imported by: 0

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

func (*Label) XXX_DiscardUnknown added in v0.2.1

func (m *Label) XXX_DiscardUnknown()

func (*Label) XXX_Marshal added in v0.2.1

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

func (*Label) XXX_Merge added in v0.2.1

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

func (*Label) XXX_Size added in v0.2.1

func (m *Label) XXX_Size() int

func (*Label) XXX_Unmarshal added in v0.2.1

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

func (*LabelMatcher) XXX_DiscardUnknown added in v0.2.1

func (m *LabelMatcher) XXX_DiscardUnknown()

func (*LabelMatcher) XXX_Marshal added in v0.2.1

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

func (*LabelMatcher) XXX_Merge added in v0.2.1

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

func (*LabelMatcher) XXX_Size added in v0.2.1

func (m *LabelMatcher) XXX_Size() int

func (*LabelMatcher) XXX_Unmarshal added in v0.2.1

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

func (*Query) XXX_DiscardUnknown added in v0.2.1

func (m *Query) XXX_DiscardUnknown()

func (*Query) XXX_Marshal added in v0.2.1

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

func (*Query) XXX_Merge added in v0.2.1

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

func (*Query) XXX_Size added in v0.2.1

func (m *Query) XXX_Size() int

func (*Query) XXX_Unmarshal added in v0.2.1

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

type QueryResult

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

func (*QueryResult) Descriptor

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

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

func (*QueryResult) XXX_DiscardUnknown added in v0.2.1

func (m *QueryResult) XXX_DiscardUnknown()

func (*QueryResult) XXX_Marshal added in v0.2.1

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

func (*QueryResult) XXX_Merge added in v0.2.1

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

func (*QueryResult) XXX_Size added in v0.2.1

func (m *QueryResult) XXX_Size() int

func (*QueryResult) XXX_Unmarshal added in v0.2.1

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

type ReadHints added in v0.4.0

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadHints) Descriptor added in v0.4.0

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

func (*ReadHints) Marshal added in v0.4.0

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

func (*ReadHints) MarshalTo added in v0.4.0

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

func (*ReadHints) ProtoMessage added in v0.4.0

func (*ReadHints) ProtoMessage()

func (*ReadHints) Reset added in v0.4.0

func (m *ReadHints) Reset()

func (*ReadHints) Size added in v0.4.0

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

func (*ReadHints) String added in v0.4.0

func (m *ReadHints) String() string

func (*ReadHints) Unmarshal added in v0.4.0

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

func (*ReadHints) XXX_DiscardUnknown added in v0.4.0

func (m *ReadHints) XXX_DiscardUnknown()

func (*ReadHints) XXX_Marshal added in v0.4.0

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

func (*ReadHints) XXX_Merge added in v0.4.0

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

func (*ReadHints) XXX_Size added in v0.4.0

func (m *ReadHints) XXX_Size() int

func (*ReadHints) XXX_Unmarshal added in v0.4.0

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

type ReadRequest

type ReadRequest struct {
	Queries              []Query  `protobuf:"bytes,1,rep,name=queries,proto3" json:"queries"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadRequest) Descriptor

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

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

func (*ReadRequest) XXX_DiscardUnknown added in v0.2.1

func (m *ReadRequest) XXX_DiscardUnknown()

func (*ReadRequest) XXX_Marshal added in v0.2.1

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

func (*ReadRequest) XXX_Merge added in v0.2.1

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

func (*ReadRequest) XXX_Size added in v0.2.1

func (m *ReadRequest) XXX_Size() int

func (*ReadRequest) XXX_Unmarshal added in v0.2.1

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

type ReadResponse

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

func (*ReadResponse) Descriptor

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

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

func (*ReadResponse) XXX_DiscardUnknown added in v0.2.1

func (m *ReadResponse) XXX_DiscardUnknown()

func (*ReadResponse) XXX_Marshal added in v0.2.1

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

func (*ReadResponse) XXX_Merge added in v0.2.1

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

func (*ReadResponse) XXX_Size added in v0.2.1

func (m *ReadResponse) XXX_Size() int

func (*ReadResponse) XXX_Unmarshal added in v0.2.1

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

func (*Sample) XXX_DiscardUnknown added in v0.2.1

func (m *Sample) XXX_DiscardUnknown()

func (*Sample) XXX_Marshal added in v0.2.1

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

func (*Sample) XXX_Merge added in v0.2.1

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

func (*Sample) XXX_Size added in v0.2.1

func (m *Sample) XXX_Size() int

func (*Sample) XXX_Unmarshal added in v0.2.1

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

func (*TimeSeries) Descriptor

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

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

func (*TimeSeries) XXX_DiscardUnknown added in v0.2.1

func (m *TimeSeries) XXX_DiscardUnknown()

func (*TimeSeries) XXX_Marshal added in v0.2.1

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

func (*TimeSeries) XXX_Merge added in v0.2.1

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

func (*TimeSeries) XXX_Size added in v0.2.1

func (m *TimeSeries) XXX_Size() int

func (*TimeSeries) XXX_Unmarshal added in v0.2.1

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

type WriteRequest added in v0.4.0

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

func (*WriteRequest) Descriptor added in v0.4.0

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

func (*WriteRequest) Marshal added in v0.4.0

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

func (*WriteRequest) MarshalTo added in v0.4.0

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

func (*WriteRequest) ProtoMessage added in v0.4.0

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset added in v0.4.0

func (m *WriteRequest) Reset()

func (*WriteRequest) Size added in v0.4.0

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

func (*WriteRequest) String added in v0.4.0

func (m *WriteRequest) String() string

func (*WriteRequest) Unmarshal added in v0.4.0

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

func (*WriteRequest) XXX_DiscardUnknown added in v0.4.0

func (m *WriteRequest) XXX_DiscardUnknown()

func (*WriteRequest) XXX_Marshal added in v0.4.0

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

func (*WriteRequest) XXX_Merge added in v0.4.0

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

func (*WriteRequest) XXX_Size added in v0.4.0

func (m *WriteRequest) XXX_Size() int

func (*WriteRequest) XXX_Unmarshal added in v0.4.0

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