storepb

package
v0.2.0 Latest Latest
Warning

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

Go to latest
Published: Dec 10, 2018 License: Apache-2.0 Imports: 8 Imported by: 46

Documentation

Overview

Package storepb is a generated protocol buffer package.

It is generated from these files:

rpc.proto
types.proto

It has these top-level messages:

InfoRequest
InfoResponse
SeriesRequest
SeriesResponse
LabelNamesRequest
LabelNamesResponse
LabelValuesRequest
LabelValuesResponse
Label
Chunk
Series
AggrChunk
LabelMatcher

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRpc   = 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 Aggr_name = map[int32]string{
	0: "RAW",
	1: "COUNT",
	2: "SUM",
	3: "MIN",
	4: "MAX",
	5: "COUNTER",
}
View Source
var Aggr_value = map[string]int32{
	"RAW":     0,
	"COUNT":   1,
	"SUM":     2,
	"MIN":     3,
	"MAX":     4,
	"COUNTER": 5,
}
View Source
var Chunk_Encoding_name = map[int32]string{
	0: "XOR",
}
View Source
var Chunk_Encoding_value = map[string]int32{
	"XOR": 0,
}
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

func CompareLabels

func CompareLabels(a, b []Label) int

CompareLabels compares two sets of labels.

func RegisterStoreServer

func RegisterStoreServer(s *grpc.Server, srv StoreServer)

Types

type Aggr

type Aggr int32
const (
	Aggr_RAW     Aggr = 0
	Aggr_COUNT   Aggr = 1
	Aggr_SUM     Aggr = 2
	Aggr_MIN     Aggr = 3
	Aggr_MAX     Aggr = 4
	Aggr_COUNTER Aggr = 5
)

func (Aggr) EnumDescriptor

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

func (Aggr) String

func (x Aggr) String() string

type AggrChunk

type AggrChunk struct {
	MinTime int64  `protobuf:"varint,1,opt,name=min_time,json=minTime,proto3" json:"min_time,omitempty"`
	MaxTime int64  `protobuf:"varint,2,opt,name=max_time,json=maxTime,proto3" json:"max_time,omitempty"`
	Raw     *Chunk `protobuf:"bytes,3,opt,name=raw" json:"raw,omitempty"`
	Count   *Chunk `protobuf:"bytes,4,opt,name=count" json:"count,omitempty"`
	Sum     *Chunk `protobuf:"bytes,5,opt,name=sum" json:"sum,omitempty"`
	Min     *Chunk `protobuf:"bytes,6,opt,name=min" json:"min,omitempty"`
	Max     *Chunk `protobuf:"bytes,7,opt,name=max" json:"max,omitempty"`
	Counter *Chunk `protobuf:"bytes,8,opt,name=counter" json:"counter,omitempty"`
}

func (*AggrChunk) Descriptor

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

func (*AggrChunk) Marshal

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

func (*AggrChunk) MarshalTo

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

func (*AggrChunk) ProtoMessage

func (*AggrChunk) ProtoMessage()

func (*AggrChunk) Reset

func (m *AggrChunk) Reset()

func (*AggrChunk) Size

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

func (*AggrChunk) String

func (m *AggrChunk) String() string

func (*AggrChunk) Unmarshal

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

type Chunk

type Chunk struct {
	Type Chunk_Encoding `protobuf:"varint,1,opt,name=type,proto3,enum=thanos.Chunk_Encoding" json:"type,omitempty"`
	Data []byte         `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Chunk) Descriptor

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

func (*Chunk) Marshal

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

func (*Chunk) MarshalTo

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

func (*Chunk) ProtoMessage

func (*Chunk) ProtoMessage()

func (*Chunk) Reset

func (m *Chunk) Reset()

func (*Chunk) Size

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

func (*Chunk) String

func (m *Chunk) String() string

func (*Chunk) Unmarshal

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

type Chunk_Encoding

type Chunk_Encoding int32
const (
	Chunk_XOR Chunk_Encoding = 0
)

func (Chunk_Encoding) EnumDescriptor

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

func (Chunk_Encoding) String

func (x Chunk_Encoding) String() string

type InfoRequest

type InfoRequest struct {
}

func (*InfoRequest) Descriptor

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

func (*InfoRequest) Marshal

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

func (*InfoRequest) MarshalTo

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

func (*InfoRequest) ProtoMessage

func (*InfoRequest) ProtoMessage()

func (*InfoRequest) Reset

func (m *InfoRequest) Reset()

func (*InfoRequest) Size

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

func (*InfoRequest) String

func (m *InfoRequest) String() string

func (*InfoRequest) Unmarshal

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

type InfoResponse

type InfoResponse struct {
	Labels  []Label `protobuf:"bytes,1,rep,name=labels" json:"labels"`
	MinTime int64   `protobuf:"varint,2,opt,name=min_time,json=minTime,proto3" json:"min_time,omitempty"`
	MaxTime int64   `protobuf:"varint,3,opt,name=max_time,json=maxTime,proto3" json:"max_time,omitempty"`
}

func (*InfoResponse) Descriptor

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

func (*InfoResponse) Marshal

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

func (*InfoResponse) MarshalTo

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

func (*InfoResponse) ProtoMessage

func (*InfoResponse) ProtoMessage()

func (*InfoResponse) Reset

func (m *InfoResponse) Reset()

func (*InfoResponse) Size

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

func (*InfoResponse) String

func (m *InfoResponse) String() string

func (*InfoResponse) Unmarshal

func (m *InfoResponse) Unmarshal(dAtA []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"`
}

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

type LabelMatcher

type LabelMatcher struct {
	Type  LabelMatcher_Type `protobuf:"varint,1,opt,name=type,proto3,enum=thanos.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"`
}

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

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 LabelNamesRequest

type LabelNamesRequest struct {
}

func (*LabelNamesRequest) Descriptor

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

func (*LabelNamesRequest) Marshal

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

func (*LabelNamesRequest) MarshalTo

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

func (*LabelNamesRequest) ProtoMessage

func (*LabelNamesRequest) ProtoMessage()

func (*LabelNamesRequest) Reset

func (m *LabelNamesRequest) Reset()

func (*LabelNamesRequest) Size

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

func (*LabelNamesRequest) String

func (m *LabelNamesRequest) String() string

func (*LabelNamesRequest) Unmarshal

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

type LabelNamesResponse

type LabelNamesResponse struct {
	Names    []string `protobuf:"bytes,1,rep,name=names" json:"names,omitempty"`
	Warnings []string `protobuf:"bytes,2,rep,name=warnings" json:"warnings,omitempty"`
}

func (*LabelNamesResponse) Descriptor

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

func (*LabelNamesResponse) Marshal

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

func (*LabelNamesResponse) MarshalTo

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

func (*LabelNamesResponse) ProtoMessage

func (*LabelNamesResponse) ProtoMessage()

func (*LabelNamesResponse) Reset

func (m *LabelNamesResponse) Reset()

func (*LabelNamesResponse) Size

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

func (*LabelNamesResponse) String

func (m *LabelNamesResponse) String() string

func (*LabelNamesResponse) Unmarshal

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

type LabelValuesRequest

type LabelValuesRequest struct {
	Label string `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
}

func (*LabelValuesRequest) Descriptor

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

func (*LabelValuesRequest) Marshal

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

func (*LabelValuesRequest) MarshalTo

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

func (*LabelValuesRequest) ProtoMessage

func (*LabelValuesRequest) ProtoMessage()

func (*LabelValuesRequest) Reset

func (m *LabelValuesRequest) Reset()

func (*LabelValuesRequest) Size

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

func (*LabelValuesRequest) String

func (m *LabelValuesRequest) String() string

func (*LabelValuesRequest) Unmarshal

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

type LabelValuesResponse

type LabelValuesResponse struct {
	Values   []string `protobuf:"bytes,1,rep,name=values" json:"values,omitempty"`
	Warnings []string `protobuf:"bytes,2,rep,name=warnings" json:"warnings,omitempty"`
}

func (*LabelValuesResponse) Descriptor

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

func (*LabelValuesResponse) Marshal

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

func (*LabelValuesResponse) MarshalTo

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

func (*LabelValuesResponse) ProtoMessage

func (*LabelValuesResponse) ProtoMessage()

func (*LabelValuesResponse) Reset

func (m *LabelValuesResponse) Reset()

func (*LabelValuesResponse) Size

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

func (*LabelValuesResponse) String

func (m *LabelValuesResponse) String() string

func (*LabelValuesResponse) Unmarshal

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

type Series

type Series struct {
	Labels []Label     `protobuf:"bytes,1,rep,name=labels" json:"labels"`
	Chunks []AggrChunk `protobuf:"bytes,2,rep,name=chunks" json:"chunks"`
}

func (*Series) Descriptor

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

func (*Series) Marshal

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

func (*Series) MarshalTo

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

func (*Series) ProtoMessage

func (*Series) ProtoMessage()

func (*Series) Reset

func (m *Series) Reset()

func (*Series) Size

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

func (*Series) String

func (m *Series) String() string

func (*Series) Unmarshal

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

type SeriesRequest

type SeriesRequest struct {
	MinTime             int64          `protobuf:"varint,1,opt,name=min_time,json=minTime,proto3" json:"min_time,omitempty"`
	MaxTime             int64          `protobuf:"varint,2,opt,name=max_time,json=maxTime,proto3" json:"max_time,omitempty"`
	Matchers            []LabelMatcher `protobuf:"bytes,3,rep,name=matchers" json:"matchers"`
	MaxResolutionWindow int64          `protobuf:"varint,4,opt,name=max_resolution_window,json=maxResolutionWindow,proto3" json:"max_resolution_window,omitempty"`
	Aggregates          []Aggr         `protobuf:"varint,5,rep,packed,name=aggregates,enum=thanos.Aggr" json:"aggregates,omitempty"`
}

func (*SeriesRequest) Descriptor

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

func (*SeriesRequest) Marshal

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

func (*SeriesRequest) MarshalTo

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

func (*SeriesRequest) ProtoMessage

func (*SeriesRequest) ProtoMessage()

func (*SeriesRequest) Reset

func (m *SeriesRequest) Reset()

func (*SeriesRequest) Size

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

func (*SeriesRequest) String

func (m *SeriesRequest) String() string

func (*SeriesRequest) Unmarshal

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

type SeriesResponse

type SeriesResponse struct {
	// Types that are valid to be assigned to Result:
	//	*SeriesResponse_Series
	//	*SeriesResponse_Warning
	Result isSeriesResponse_Result `protobuf_oneof:"result"`
}

func NewSeriesResponse

func NewSeriesResponse(series *Series) *SeriesResponse

func NewWarnSeriesResponse

func NewWarnSeriesResponse(err error) *SeriesResponse

func (*SeriesResponse) Descriptor

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

func (*SeriesResponse) GetResult

func (m *SeriesResponse) GetResult() isSeriesResponse_Result

func (*SeriesResponse) GetSeries

func (m *SeriesResponse) GetSeries() *Series

func (*SeriesResponse) GetWarning

func (m *SeriesResponse) GetWarning() string

func (*SeriesResponse) Marshal

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

func (*SeriesResponse) MarshalTo

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

func (*SeriesResponse) ProtoMessage

func (*SeriesResponse) ProtoMessage()

func (*SeriesResponse) Reset

func (m *SeriesResponse) Reset()

func (*SeriesResponse) Size

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

func (*SeriesResponse) String

func (m *SeriesResponse) String() string

func (*SeriesResponse) Unmarshal

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

func (*SeriesResponse) XXX_OneofFuncs

func (*SeriesResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type SeriesResponse_Series

type SeriesResponse_Series struct {
	Series *Series `protobuf:"bytes,1,opt,name=series,oneof"`
}

func (*SeriesResponse_Series) MarshalTo

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

func (*SeriesResponse_Series) Size

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

type SeriesResponse_Warning

type SeriesResponse_Warning struct {
	Warning string `protobuf:"bytes,2,opt,name=warning,proto3,oneof"`
}

func (*SeriesResponse_Warning) MarshalTo

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

func (*SeriesResponse_Warning) Size

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

type SeriesSet

type SeriesSet interface {
	Next() bool
	At() ([]Label, []AggrChunk)
	Err() error
}

SeriesSet is a set of series and their corresponding chunks. The set is sorted by the label sets. Chunks may be overlapping or out of order.

func EmptySeriesSet

func EmptySeriesSet() SeriesSet

EmptySeriesSet returns a new series set that contains no series.

func MergeSeriesSets

func MergeSeriesSets(all ...SeriesSet) SeriesSet

MergeSeriesSets returns a new series set that is the union of the input sets.

type StoreClient

type StoreClient interface {
	// / Info returns meta information about a store e.g labels that makes that store unique.
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)
	Series(ctx context.Context, in *SeriesRequest, opts ...grpc.CallOption) (Store_SeriesClient, error)
	LabelNames(ctx context.Context, in *LabelNamesRequest, opts ...grpc.CallOption) (*LabelNamesResponse, error)
	LabelValues(ctx context.Context, in *LabelValuesRequest, opts ...grpc.CallOption) (*LabelValuesResponse, error)
}

func NewStoreClient

func NewStoreClient(cc *grpc.ClientConn) StoreClient

type StoreServer

type StoreServer interface {
	// / Info returns meta information about a store e.g labels that makes that store unique.
	Info(context.Context, *InfoRequest) (*InfoResponse, error)
	Series(*SeriesRequest, Store_SeriesServer) error
	LabelNames(context.Context, *LabelNamesRequest) (*LabelNamesResponse, error)
	LabelValues(context.Context, *LabelValuesRequest) (*LabelValuesResponse, error)
}

type Store_SeriesClient

type Store_SeriesClient interface {
	Recv() (*SeriesResponse, error)
	grpc.ClientStream
}

type Store_SeriesServer

type Store_SeriesServer interface {
	Send(*SeriesResponse) error
	grpc.ServerStream
}

Jump to

Keyboard shortcuts

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