Help us shape the future of Go! Take the 2026 Go Developer Survey

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: 0

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.