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
}

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.