storepb

package
v0.11.0 Latest Latest
Warning

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

 Go to latest Published: Mar 2, 2020 License: Apache-2.0 Imports: 13 Imported by: 46

Documentation

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")
	ErrUnexpectedEndOfGroupRpc = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)
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,
}
View Source 
var PartialResponseStrategyValues = func() []string {
	var s []string
	for k := range PartialResponseStrategy_value {
		s = append(s, k)
	}
	return s
}()
View Source 
var PartialResponseStrategy_name = map[int32]string{
	0: "WARN",
	1: "ABORT",
}
View Source 
var PartialResponseStrategy_value = map[string]int32{
	"WARN":  0,
	"ABORT": 1,
}
View Source 
var StoreType_name = map[int32]string{
	0: "UNKNOWN",
	1: "QUERY",
	2: "RULE",
	3: "SIDECAR",
	4: "STORE",
	5: "RECEIVE",
}
View Source 
var StoreType_value = map[string]int32{
	"UNKNOWN": 0,
	"QUERY":   1,
	"RULE":    2,
	"SIDECAR": 3,
	"STORE":   4,
	"RECEIVE": 5,
}

Functions

func CompareLabels 

func CompareLabels(a, b []Label) int

CompareLabels compares two sets of labels.

func LabelSetsToString added in v0.7.0 

func LabelSetsToString(lsets []LabelSet) string

func LabelsToPromLabels added in v0.2.1 

func LabelsToPromLabels(lset []Label) labels.Labels

func LabelsToString added in v0.3.0 

func LabelsToString(lset []Label) string

func RegisterStoreServer 

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

func RegisterWriteableStoreServer added in v0.11.0 

func RegisterWriteableStoreServer(s *grpc.Server, srv WriteableStoreServer)

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,proto3" json:"raw,omitempty"`
	Count   *Chunk `protobuf:"bytes,4,opt,name=count,proto3" json:"count,omitempty"`
	Sum     *Chunk `protobuf:"bytes,5,opt,name=sum,proto3" json:"sum,omitempty"`
	Min     *Chunk `protobuf:"bytes,6,opt,name=min,proto3" json:"min,omitempty"`
	Max     *Chunk `protobuf:"bytes,7,opt,name=max,proto3" json:"max,omitempty"`
	Counter *Chunk `protobuf:"bytes,8,opt,name=counter,proto3" 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) MarshalToSizedBuffer added in v0.7.0 

func (m *AggrChunk) MarshalToSizedBuffer(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

func (*AggrChunk) XXX_DiscardUnknown added in v0.2.1 

func (m *AggrChunk) XXX_DiscardUnknown()

func (*AggrChunk) XXX_Marshal added in v0.2.1 

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

func (*AggrChunk) XXX_Merge added in v0.2.1 

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

func (*AggrChunk) XXX_Size added in v0.2.1 

func (m *AggrChunk) XXX_Size() int

func (*AggrChunk) XXX_Unmarshal added in v0.2.1 

func (m *AggrChunk) XXX_Unmarshal(b []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) MarshalToSizedBuffer added in v0.7.0 

func (m *Chunk) MarshalToSizedBuffer(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

func (*Chunk) XXX_DiscardUnknown added in v0.2.1 

func (m *Chunk) XXX_DiscardUnknown()

func (*Chunk) XXX_Marshal added in v0.2.1 

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

func (*Chunk) XXX_Merge added in v0.2.1 

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

func (*Chunk) XXX_Size added in v0.2.1 

func (m *Chunk) XXX_Size() int

func (*Chunk) XXX_Unmarshal added in v0.2.1 

func (m *Chunk) XXX_Unmarshal(b []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) MarshalToSizedBuffer added in v0.7.0 

func (m *InfoRequest) MarshalToSizedBuffer(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

func (*InfoRequest) XXX_DiscardUnknown added in v0.2.1 

func (m *InfoRequest) XXX_DiscardUnknown()

func (*InfoRequest) XXX_Marshal added in v0.2.1 

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

func (*InfoRequest) XXX_Merge added in v0.2.1 

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

func (*InfoRequest) XXX_Size added in v0.2.1 

func (m *InfoRequest) XXX_Size() int

func (*InfoRequest) XXX_Unmarshal added in v0.2.1 

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

type InfoResponse 

type InfoResponse struct {
	// Deprecated. Use label_sets instead.
	Labels    []Label   `protobuf:"bytes,1,rep,name=labels,proto3" 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"`
	StoreType StoreType `protobuf:"varint,4,opt,name=storeType,proto3,enum=thanos.StoreType" json:"storeType,omitempty"`
	// label_sets is an unsorted list of `LabelSet`s.
	LabelSets []LabelSet `protobuf:"bytes,5,rep,name=label_sets,json=labelSets,proto3" json:"label_sets"`
}

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) MarshalToSizedBuffer added in v0.7.0 

func (m *InfoResponse) MarshalToSizedBuffer(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

func (*InfoResponse) XXX_DiscardUnknown added in v0.2.1 

func (m *InfoResponse) XXX_DiscardUnknown()

func (*InfoResponse) XXX_Marshal added in v0.2.1 

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

func (*InfoResponse) XXX_Merge added in v0.2.1 

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

func (*InfoResponse) XXX_Size added in v0.2.1 

func (m *InfoResponse) XXX_Size() int

func (*InfoResponse) XXX_Unmarshal added in v0.2.1 

func (m *InfoResponse) XXX_Unmarshal(b []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) MarshalToSizedBuffer added in v0.7.0 

func (m *Label) MarshalToSizedBuffer(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=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) MarshalToSizedBuffer added in v0.7.0 

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

type LabelNamesRequest struct {
	PartialResponseDisabled bool `` /* 133-byte string literal not displayed */
	// TODO(bwplotka): Move Thanos components to use strategy instead. Including QueryAPI.
	PartialResponseStrategy PartialResponseStrategy `` /* 169-byte string literal not displayed */
}

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) MarshalToSizedBuffer added in v0.7.0 

func (m *LabelNamesRequest) MarshalToSizedBuffer(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

func (*LabelNamesRequest) XXX_DiscardUnknown added in v0.2.1 

func (m *LabelNamesRequest) XXX_DiscardUnknown()

func (*LabelNamesRequest) XXX_Marshal added in v0.2.1 

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

func (*LabelNamesRequest) XXX_Merge added in v0.2.1 

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

func (*LabelNamesRequest) XXX_Size added in v0.2.1 

func (m *LabelNamesRequest) XXX_Size() int

func (*LabelNamesRequest) XXX_Unmarshal added in v0.2.1 

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

type LabelNamesResponse 

type LabelNamesResponse struct {
	Names    []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	Warnings []string `protobuf:"bytes,2,rep,name=warnings,proto3" 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) MarshalToSizedBuffer added in v0.7.0 

func (m *LabelNamesResponse) MarshalToSizedBuffer(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

func (*LabelNamesResponse) XXX_DiscardUnknown added in v0.2.1 

func (m *LabelNamesResponse) XXX_DiscardUnknown()

func (*LabelNamesResponse) XXX_Marshal added in v0.2.1 

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

func (*LabelNamesResponse) XXX_Merge added in v0.2.1 

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

func (*LabelNamesResponse) XXX_Size added in v0.2.1 

func (m *LabelNamesResponse) XXX_Size() int

func (*LabelNamesResponse) XXX_Unmarshal added in v0.2.1 

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

type LabelSet added in v0.7.0 

type LabelSet struct {
	Labels []Label `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels"`
}

func (*LabelSet) Descriptor added in v0.7.0 

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

func (*LabelSet) Marshal added in v0.7.0 

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

func (*LabelSet) MarshalTo added in v0.7.0 

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

func (*LabelSet) MarshalToSizedBuffer added in v0.7.0 

func (m *LabelSet) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LabelSet) ProtoMessage added in v0.7.0 

func (*LabelSet) ProtoMessage()

func (*LabelSet) Reset added in v0.7.0 

func (m *LabelSet) Reset()

func (*LabelSet) Size added in v0.7.0 

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

func (*LabelSet) String added in v0.7.0 

func (m *LabelSet) String() string

func (*LabelSet) Unmarshal added in v0.7.0 

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

func (*LabelSet) XXX_DiscardUnknown added in v0.7.0 

func (m *LabelSet) XXX_DiscardUnknown()

func (*LabelSet) XXX_Marshal added in v0.7.0 

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

func (*LabelSet) XXX_Merge added in v0.7.0 

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

func (*LabelSet) XXX_Size added in v0.7.0 

func (m *LabelSet) XXX_Size() int

func (*LabelSet) XXX_Unmarshal added in v0.7.0 

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

type LabelValuesRequest 

type LabelValuesRequest struct {
	Label                   string `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	PartialResponseDisabled bool   `` /* 133-byte string literal not displayed */
	// TODO(bwplotka): Move Thanos components to use strategy instead. Including QueryAPI.
	PartialResponseStrategy PartialResponseStrategy `` /* 169-byte string literal not displayed */
}

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) MarshalToSizedBuffer added in v0.7.0 

func (m *LabelValuesRequest) MarshalToSizedBuffer(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

func (*LabelValuesRequest) XXX_DiscardUnknown added in v0.2.1 

func (m *LabelValuesRequest) XXX_DiscardUnknown()

func (*LabelValuesRequest) XXX_Marshal added in v0.2.1 

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

func (*LabelValuesRequest) XXX_Merge added in v0.2.1 

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

func (*LabelValuesRequest) XXX_Size added in v0.2.1 

func (m *LabelValuesRequest) XXX_Size() int

func (*LabelValuesRequest) XXX_Unmarshal added in v0.2.1 

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

type LabelValuesResponse 

type LabelValuesResponse struct {
	Values   []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	Warnings []string `protobuf:"bytes,2,rep,name=warnings,proto3" 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) MarshalToSizedBuffer added in v0.7.0 

func (m *LabelValuesResponse) MarshalToSizedBuffer(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

func (*LabelValuesResponse) XXX_DiscardUnknown added in v0.2.1 

func (m *LabelValuesResponse) XXX_DiscardUnknown()

func (*LabelValuesResponse) XXX_Marshal added in v0.2.1 

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

func (*LabelValuesResponse) XXX_Merge added in v0.2.1 

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

func (*LabelValuesResponse) XXX_Size added in v0.2.1 

func (m *LabelValuesResponse) XXX_Size() int

func (*LabelValuesResponse) XXX_Unmarshal added in v0.2.1 

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

type PartialResponseStrategy added in v0.7.0 

type PartialResponseStrategy int32

/ PartialResponseStrategy controls partial response handling. 

const (
	/// WARN strategy tells server to treat any error that will related to single StoreAPI (e.g missing chunk series because of underlying
	/// storeAPI is temporarily not available) as warning which will not fail the whole query (still OK response).
	/// Server should produce those as a warnings field in response.
	PartialResponseStrategy_WARN PartialResponseStrategy = 0
	/// ABORT strategy tells server to treat any error that will related to single StoreAPI (e.g missing chunk series because of underlying
	/// storeAPI is temporarily not available) as the gRPC error that aborts the query.
	///
	/// This is especially useful for any rule/alert evaluations on top of StoreAPI which usually does not tolerate partial
	/// errors.
	PartialResponseStrategy_ABORT PartialResponseStrategy = 1
)

func (PartialResponseStrategy) EnumDescriptor added in v0.7.0 

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

func (PartialResponseStrategy) String added in v0.7.0 

func (x PartialResponseStrategy) String() string

type Series 

type Series struct {
	Labels []Label     `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels"`
	Chunks []AggrChunk `protobuf:"bytes,2,rep,name=chunks,proto3" 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) MarshalToSizedBuffer added in v0.7.0 

func (m *Series) MarshalToSizedBuffer(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

func (*Series) XXX_DiscardUnknown added in v0.2.1 

func (m *Series) XXX_DiscardUnknown()

func (*Series) XXX_Marshal added in v0.2.1 

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

func (*Series) XXX_Merge added in v0.2.1 

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

func (*Series) XXX_Size added in v0.2.1 

func (m *Series) XXX_Size() int

func (*Series) XXX_Unmarshal added in v0.2.1 

func (m *Series) XXX_Unmarshal(b []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,proto3" 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,proto3,enum=thanos.Aggr" json:"aggregates,omitempty"`
	// Deprecated. Use partial_response_strategy instead.
	PartialResponseDisabled bool `` /* 133-byte string literal not displayed */
	// TODO(bwplotka): Move Thanos components to use strategy instead. Including QueryAPI.
	PartialResponseStrategy PartialResponseStrategy `` /* 169-byte string literal not displayed */
	// skip_chunks controls whether sending chunks or not in series responses.
	SkipChunks bool `protobuf:"varint,8,opt,name=skip_chunks,json=skipChunks,proto3" json:"skip_chunks,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) MarshalToSizedBuffer added in v0.7.0 

func (m *SeriesRequest) MarshalToSizedBuffer(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

func (*SeriesRequest) XXX_DiscardUnknown added in v0.2.1 

func (m *SeriesRequest) XXX_DiscardUnknown()

func (*SeriesRequest) XXX_Marshal added in v0.2.1 

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

func (*SeriesRequest) XXX_Merge added in v0.2.1 

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

func (*SeriesRequest) XXX_Size added in v0.2.1 

func (m *SeriesRequest) XXX_Size() int

func (*SeriesRequest) XXX_Unmarshal added in v0.2.1 

func (m *SeriesRequest) XXX_Unmarshal(b []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) MarshalToSizedBuffer added in v0.7.0 

func (m *SeriesResponse) MarshalToSizedBuffer(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_DiscardUnknown added in v0.2.1 

func (m *SeriesResponse) XXX_DiscardUnknown()

func (*SeriesResponse) XXX_Marshal added in v0.2.1 

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

func (*SeriesResponse) XXX_Merge added in v0.2.1 

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

func (*SeriesResponse) XXX_OneofWrappers added in v0.10.0 

func (*SeriesResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SeriesResponse) XXX_Size added in v0.2.1 

func (m *SeriesResponse) XXX_Size() int

func (*SeriesResponse) XXX_Unmarshal added in v0.2.1 

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

type SeriesResponse_Series 

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

func (*SeriesResponse_Series) MarshalTo 

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

func (*SeriesResponse_Series) MarshalToSizedBuffer added in v0.7.0 

func (m *SeriesResponse_Series) MarshalToSizedBuffer(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" json:"warning,omitempty"`
}

func (*SeriesResponse_Warning) MarshalTo 

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

func (*SeriesResponse_Warning) MarshalToSizedBuffer added in v0.7.0 

func (m *SeriesResponse_Warning) MarshalToSizedBuffer(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 expected 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 as well as time range that is
	/// available.
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)
	/// Series streams each Series (Labels and chunk/downsampling chunk) for given label matchers and time range.
	///
	/// Series should strictly stream full series after series, optionally split by time. This means that a single frame can contain
	/// partition of the single series, but once a new series is started to be streamed it means that no more data will
	/// be sent for previous one.
	/// Series has to be sorted.
	Series(ctx context.Context, in *SeriesRequest, opts ...grpc.CallOption) (Store_SeriesClient, error)
	/// LabelNames returns all label names that is available.
	/// Currently unimplemented in all Thanos implementations, because Query API does not implement this either.
	LabelNames(ctx context.Context, in *LabelNamesRequest, opts ...grpc.CallOption) (*LabelNamesResponse, error)
	/// LabelValues returns all label values for given label name.
	LabelValues(ctx context.Context, in *LabelValuesRequest, opts ...grpc.CallOption) (*LabelValuesResponse, error)
}

StoreClient is the client API for Store service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

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 as well as time range that is
	/// available.
	Info(context.Context, *InfoRequest) (*InfoResponse, error)
	/// Series streams each Series (Labels and chunk/downsampling chunk) for given label matchers and time range.
	///
	/// Series should strictly stream full series after series, optionally split by time. This means that a single frame can contain
	/// partition of the single series, but once a new series is started to be streamed it means that no more data will
	/// be sent for previous one.
	/// Series has to be sorted.
	Series(*SeriesRequest, Store_SeriesServer) error
	/// LabelNames returns all label names that is available.
	/// Currently unimplemented in all Thanos implementations, because Query API does not implement this either.
	LabelNames(context.Context, *LabelNamesRequest) (*LabelNamesResponse, error)
	/// LabelValues returns all label values for given label name.
	LabelValues(context.Context, *LabelValuesRequest) (*LabelValuesResponse, error)
}

StoreServer is the server API for Store service.

type StoreType added in v0.3.0 

type StoreType int32
const (
	StoreType_UNKNOWN StoreType = 0
	StoreType_QUERY   StoreType = 1
	StoreType_RULE    StoreType = 2
	StoreType_SIDECAR StoreType = 3
	StoreType_STORE   StoreType = 4
	StoreType_RECEIVE StoreType = 5
)

func (StoreType) EnumDescriptor added in v0.3.0 

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

func (StoreType) String added in v0.3.0 

func (x StoreType) String() string

type Store_SeriesClient 

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

type Store_SeriesServer 

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

type UnimplementedStoreServer added in v0.7.0 

type UnimplementedStoreServer struct {
}

UnimplementedStoreServer can be embedded to have forward compatible implementations.

func (*UnimplementedStoreServer) Info added in v0.7.0 

func (*UnimplementedStoreServer) Info(ctx context.Context, req *InfoRequest) (*InfoResponse, error)

func (*UnimplementedStoreServer) LabelNames added in v0.7.0 

func (*UnimplementedStoreServer) LabelNames(ctx context.Context, req *LabelNamesRequest) (*LabelNamesResponse, error)

func (*UnimplementedStoreServer) LabelValues added in v0.7.0 

func (*UnimplementedStoreServer) LabelValues(ctx context.Context, req *LabelValuesRequest) (*LabelValuesResponse, error)

func (*UnimplementedStoreServer) Series added in v0.7.0 

func (*UnimplementedStoreServer) Series(req *SeriesRequest, srv Store_SeriesServer) error

type UnimplementedWriteableStoreServer added in v0.11.0 

type UnimplementedWriteableStoreServer struct {
}

UnimplementedWriteableStoreServer can be embedded to have forward compatible implementations.

func (*UnimplementedWriteableStoreServer) RemoteWrite added in v0.11.0 

func (*UnimplementedWriteableStoreServer) RemoteWrite(ctx context.Context, req *WriteRequest) (*WriteResponse, error)

type WriteRequest added in v0.11.0 

type WriteRequest struct {
	Timeseries []prompb.TimeSeries `protobuf:"bytes,1,rep,name=timeseries,proto3" json:"timeseries"`
	Tenant     string              `protobuf:"bytes,2,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Replica    int64               `protobuf:"varint,3,opt,name=replica,proto3" json:"replica,omitempty"`
}

func (*WriteRequest) Descriptor added in v0.11.0 

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

func (*WriteRequest) Marshal added in v0.11.0 

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

func (*WriteRequest) MarshalTo added in v0.11.0 

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

func (*WriteRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*WriteRequest) ProtoMessage added in v0.11.0 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset added in v0.11.0 

func (m *WriteRequest) Reset()

func (*WriteRequest) Size added in v0.11.0 

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

func (*WriteRequest) String added in v0.11.0 

func (m *WriteRequest) String() string

func (*WriteRequest) Unmarshal added in v0.11.0 

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

func (*WriteRequest) XXX_DiscardUnknown added in v0.11.0 

func (m *WriteRequest) XXX_DiscardUnknown()

func (*WriteRequest) XXX_Marshal added in v0.11.0 

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

func (*WriteRequest) XXX_Merge added in v0.11.0 

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

func (*WriteRequest) XXX_Size added in v0.11.0 

func (m *WriteRequest) XXX_Size() int

func (*WriteRequest) XXX_Unmarshal added in v0.11.0 

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

type WriteResponse added in v0.11.0 

type WriteResponse struct {
}

func (*WriteResponse) Descriptor added in v0.11.0 

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

func (*WriteResponse) Marshal added in v0.11.0 

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

func (*WriteResponse) MarshalTo added in v0.11.0 

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

func (*WriteResponse) MarshalToSizedBuffer added in v0.11.0 

func (m *WriteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WriteResponse) ProtoMessage added in v0.11.0 

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) Reset added in v0.11.0 

func (m *WriteResponse) Reset()

func (*WriteResponse) Size added in v0.11.0 

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

func (*WriteResponse) String added in v0.11.0 

func (m *WriteResponse) String() string

func (*WriteResponse) Unmarshal added in v0.11.0 

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

func (*WriteResponse) XXX_DiscardUnknown added in v0.11.0 

func (m *WriteResponse) XXX_DiscardUnknown()

func (*WriteResponse) XXX_Marshal added in v0.11.0 

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

func (*WriteResponse) XXX_Merge added in v0.11.0 

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

func (*WriteResponse) XXX_Size added in v0.11.0 

func (m *WriteResponse) XXX_Size() int

func (*WriteResponse) XXX_Unmarshal added in v0.11.0 

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

type WriteableStoreClient added in v0.11.0 

type WriteableStoreClient interface {
	// WriteRequest allows you to write metrics to this store via remote write
	RemoteWrite(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)
}

WriteableStoreClient is the client API for WriteableStore service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewWriteableStoreClient added in v0.11.0 

func NewWriteableStoreClient(cc *grpc.ClientConn) WriteableStoreClient

type WriteableStoreServer added in v0.11.0 

type WriteableStoreServer interface {
	// WriteRequest allows you to write metrics to this store via remote write
	RemoteWrite(context.Context, *WriteRequest) (*WriteResponse, error)
}

WriteableStoreServer is the server API for WriteableStore service.

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.