storepb

package
v0.30.0 Latest Latest
Warning

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

 Go to latest Published: Jan 2, 2023 License: Apache-2.0 Imports: 22 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)
	}
	sort.Strings(s)
	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",
	6: "DEBUG",
}
View Source 
var StoreType_value = map[string]int32{
	"UNKNOWN": 0,
	"QUERY":   1,
	"RULE":    2,
	"SIDECAR": 3,
	"STORE":   4,
	"RECEIVE": 5,
	"DEBUG":   6,
}

Functions

func CompareLabels 

func CompareLabels(a, b []Label) int

Deprecated. TODO(bwplotka): Remove this once Cortex dep will stop using it.

func GRPCCodeFromWarn added in v0.30.0 

func GRPCCodeFromWarn(warn string) codes.Code

func LabelsToPromLabelsUnsafe added in v0.12.0 

func LabelsToPromLabelsUnsafe(lset []Label) labels.Labels

Deprecated. TODO(bwplotka): Remove this once Cortex dep will stop using it.

func MatchersToPromMatchers added in v0.18.0 

func MatchersToPromMatchers(ms ...LabelMatcher) ([]*labels.Matcher, error)

MatchersToPromMatchers returns Prometheus matchers from proto matchers. NOTE: It allocates memory.

func MatchersToString added in v0.16.0 

func MatchersToString(ms ...LabelMatcher) string

MatchersToString converts label matchers to string format. String should be parsable as a valid PromQL query metric selector.

func PromMatchersToString added in v0.16.0 

func PromMatchersToString(ms ...*labels.Matcher) string

PromMatchersToString converts prometheus label matchers to string format. String should be parsable as a valid PromQL query metric selector.

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) Compare added in v0.13.0 

func (m AggrChunk) Compare(b AggrChunk) int

Compare returns positive 1 if chunk is smaller -1 if larger than b by min time, then max time. It returns 0 if chunks are exactly the same.

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"`
	Hash uint64         `protobuf:"varint,3,opt,name=hash,proto3" json:"hash,omitempty"`
}

func (*Chunk) Compare added in v0.13.0 

func (m *Chunk) Compare(b *Chunk) int

Compare returns positive 1 if chunk is smaller -1 if larger. It returns 0 if chunks are exactly the same.

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) XORNumSamples added in v0.23.0 

func (m *Chunk) XORNumSamples() int

XORNumSamples return number of samples. Returns 0 if it's not XOR chunk.

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 Func added in v0.25.0 

type Func struct {
	// The function or aggregation name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*Func) Descriptor added in v0.25.0 

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

func (*Func) Marshal added in v0.25.0 

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

func (*Func) MarshalTo added in v0.25.0 

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

func (*Func) MarshalToSizedBuffer added in v0.25.0 

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

func (*Func) ProtoMessage added in v0.25.0 

func (*Func) ProtoMessage()

func (*Func) Reset added in v0.25.0 

func (m *Func) Reset()

func (*Func) Size added in v0.25.0 

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

func (*Func) String added in v0.25.0 

func (m *Func) String() string

func (*Func) Unmarshal added in v0.25.0 

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

func (*Func) XXX_DiscardUnknown added in v0.25.0 

func (m *Func) XXX_DiscardUnknown()

func (*Func) XXX_Marshal added in v0.25.0 

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

func (*Func) XXX_Merge added in v0.25.0 

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

func (*Func) XXX_Size added in v0.25.0 

func (m *Func) XXX_Size() int

func (*Func) XXX_Unmarshal added in v0.25.0 

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

type Grouping added in v0.25.0 

type Grouping struct {
	// Indicate whether it is without or by.
	By bool `protobuf:"varint,1,opt,name=by,proto3" json:"by,omitempty"`
	// List of label names used in the grouping.
	Labels []string `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty"`
}

func (*Grouping) Descriptor added in v0.25.0 

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

func (*Grouping) Marshal added in v0.25.0 

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

func (*Grouping) MarshalTo added in v0.25.0 

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

func (*Grouping) MarshalToSizedBuffer added in v0.25.0 

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

func (*Grouping) ProtoMessage added in v0.25.0 

func (*Grouping) ProtoMessage()

func (*Grouping) Reset added in v0.25.0 

func (m *Grouping) Reset()

func (*Grouping) Size added in v0.25.0 

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

func (*Grouping) String added in v0.25.0 

func (m *Grouping) String() string

func (*Grouping) Unmarshal added in v0.25.0 

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

func (*Grouping) XXX_DiscardUnknown added in v0.25.0 

func (m *Grouping) XXX_DiscardUnknown()

func (*Grouping) XXX_Marshal added in v0.25.0 

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

func (*Grouping) XXX_Merge added in v0.25.0 

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

func (*Grouping) XXX_Size added in v0.25.0 

func (m *Grouping) XXX_Size() int

func (*Grouping) XXX_Unmarshal added in v0.25.0 

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

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    []github_com_thanos_io_thanos_pkg_store_labelpb.ZLabel `protobuf:"bytes,1,rep,name=labels,proto3,customtype=github.com/thanos-io/thanos/pkg/store/labelpb.ZLabel" 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 `ZLabelSet`s.
	LabelSets []labelpb.ZLabelSet `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 = labelpb.ZLabel

Deprecated. TODO(bwplotka): Remove this once Cortex dep will stop using it.

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 PromMatchersToMatchers added in v0.18.0 

func PromMatchersToMatchers(ms ...*labels.Matcher) ([]LabelMatcher, error)

PromMatchersToMatchers returns proto matchers from Prometheus matchers. NOTE: It allocates memory.

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) PromString added in v0.16.0 

func (m *LabelMatcher) PromString() string

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) PromString added in v0.16.0 

func (x LabelMatcher_Type) PromString() string

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 */
	Start                   int64                   `protobuf:"varint,3,opt,name=start,proto3" json:"start,omitempty"`
	End                     int64                   `protobuf:"varint,4,opt,name=end,proto3" json:"end,omitempty"`
	// hints is an opaque data structure that can be used to carry additional information.
	// The content of this field and whether it's supported depends on the
	// implementation of a specific store.
	Hints    *types.Any     `protobuf:"bytes,5,opt,name=hints,proto3" json:"hints,omitempty"`
	Matchers []LabelMatcher `protobuf:"bytes,6,rep,name=matchers,proto3" json:"matchers"`
}

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"`
	/// hints is an opaque data structure that can be used to carry additional information from
	/// the store. The content of this field and whether it's supported depends on the
	/// implementation of a specific store.
	Hints *types.Any `protobuf:"bytes,3,opt,name=hints,proto3" json:"hints,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 = labelpb.ZLabelSet

Deprecated. TODO(bwplotka): Remove this in next PR. Done to reduce diff only.

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 */
	Start                   int64                   `protobuf:"varint,4,opt,name=start,proto3" json:"start,omitempty"`
	End                     int64                   `protobuf:"varint,5,opt,name=end,proto3" json:"end,omitempty"`
	// hints is an opaque data structure that can be used to carry additional information.
	// The content of this field and whether it's supported depends on the
	// implementation of a specific store.
	Hints    *types.Any     `protobuf:"bytes,6,opt,name=hints,proto3" json:"hints,omitempty"`
	Matchers []LabelMatcher `protobuf:"bytes,7,rep,name=matchers,proto3" json:"matchers"`
}

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"`
	/// hints is an opaque data structure that can be used to carry additional information from
	/// the store. The content of this field and whether it's supported depends on the
	/// implementation of a specific store.
	Hints *types.Any `protobuf:"bytes,3,opt,name=hints,proto3" json:"hints,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) MarshalJSON added in v0.14.0 

func (x *PartialResponseStrategy) MarshalJSON() ([]byte, error)

func (PartialResponseStrategy) String added in v0.7.0 

func (x PartialResponseStrategy) String() string

func (*PartialResponseStrategy) UnmarshalJSON added in v0.14.0 

func (x *PartialResponseStrategy) UnmarshalJSON(entry []byte) error

type QueryHints added in v0.25.0 

type QueryHints struct {
	// Query step size in milliseconds.
	StepMillis int64 `protobuf:"varint,1,opt,name=step_millis,json=stepMillis,proto3" json:"step_millis,omitempty"`
	// The surrounding function or aggregation.
	Func *Func `protobuf:"bytes,2,opt,name=func,proto3" json:"func,omitempty"`
	// The grouping expression
	Grouping *Grouping `protobuf:"bytes,4,opt,name=grouping,proto3" json:"grouping,omitempty"`
	// Range vector selector.
	Range *Range `protobuf:"bytes,5,opt,name=range,proto3" json:"range,omitempty"`
}

Analogous to storage.SelectHints.

func (*QueryHints) Descriptor added in v0.25.0 

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

func (*QueryHints) IsSafeToExecute added in v0.25.0 

func (m *QueryHints) IsSafeToExecute() bool

IsSafeToExecute returns true if the function or aggregation from the query hint can be safely executed by the underlying Prometheus instance without affecting the result of the query.

func (*QueryHints) Marshal added in v0.25.0 

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

func (*QueryHints) MarshalTo added in v0.25.0 

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

func (*QueryHints) MarshalToSizedBuffer added in v0.25.0 

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

func (*QueryHints) ProtoMessage added in v0.25.0 

func (*QueryHints) ProtoMessage()

func (*QueryHints) Reset added in v0.25.0 

func (m *QueryHints) Reset()

func (*QueryHints) Size added in v0.25.0 

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

func (*QueryHints) String added in v0.25.0 

func (m *QueryHints) String() string

func (*QueryHints) Unmarshal added in v0.25.0 

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

func (*QueryHints) XXX_DiscardUnknown added in v0.25.0 

func (m *QueryHints) XXX_DiscardUnknown()

func (*QueryHints) XXX_Marshal added in v0.25.0 

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

func (*QueryHints) XXX_Merge added in v0.25.0 

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

func (*QueryHints) XXX_Size added in v0.25.0 

func (m *QueryHints) XXX_Size() int

func (*QueryHints) XXX_Unmarshal added in v0.25.0 

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

type Range added in v0.25.0 

type Range struct {
	Millis int64 `protobuf:"varint,1,opt,name=millis,proto3" json:"millis,omitempty"`
}

func (*Range) Descriptor added in v0.25.0 

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

func (*Range) Marshal added in v0.25.0 

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

func (*Range) MarshalTo added in v0.25.0 

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

func (*Range) MarshalToSizedBuffer added in v0.25.0 

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

func (*Range) ProtoMessage added in v0.25.0 

func (*Range) ProtoMessage()

func (*Range) Reset added in v0.25.0 

func (m *Range) Reset()

func (*Range) Size added in v0.25.0 

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

func (*Range) String added in v0.25.0 

func (m *Range) String() string

func (*Range) Unmarshal added in v0.25.0 

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

func (*Range) XXX_DiscardUnknown added in v0.25.0 

func (m *Range) XXX_DiscardUnknown()

func (*Range) XXX_Marshal added in v0.25.0 

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

func (*Range) XXX_Merge added in v0.25.0 

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

func (*Range) XXX_Size added in v0.25.0 

func (m *Range) XXX_Size() int

func (*Range) XXX_Unmarshal added in v0.25.0 

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

type Series 

type Series struct {
	Labels []github_com_thanos_io_thanos_pkg_store_labelpb.ZLabel `protobuf:"bytes,1,rep,name=labels,proto3,customtype=github.com/thanos-io/thanos/pkg/store/labelpb.ZLabel" 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) PromLabels added in v0.16.0 

func (m *Series) PromLabels() labels.Labels

PromLabels return Prometheus labels.Labels without extra allocation.

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"`
	// hints is an opaque data structure that can be used to carry additional information.
	// The content of this field and whether it's supported depends on the
	// implementation of a specific store.
	Hints *types.Any `protobuf:"bytes,9,opt,name=hints,proto3" json:"hints,omitempty"`
	// Query step size in milliseconds.
	// Deprecated: Use query_hints instead.
	Step int64 `protobuf:"varint,10,opt,name=step,proto3" json:"step,omitempty"`
	// Range vector selector range in milliseconds.
	// Deprecated: Use query_hints instead.
	Range int64 `protobuf:"varint,11,opt,name=range,proto3" json:"range,omitempty"`
	// query_hints are the hints coming from the PromQL engine when
	// requesting a storage.SeriesSet for a given expression.
	QueryHints *QueryHints `protobuf:"bytes,12,opt,name=query_hints,json=queryHints,proto3" json:"query_hints,omitempty"`
	// shard_info is used by the querier to request a specific
	// shard of blocks instead of entire blocks.
	ShardInfo *ShardInfo `protobuf:"bytes,13,opt,name=shard_info,json=shardInfo,proto3" json:"shard_info,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) ToPromQL added in v0.25.0 

func (m *SeriesRequest) ToPromQL() 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
	//	*SeriesResponse_Hints
	Result isSeriesResponse_Result `protobuf_oneof:"result"`
}

func NewHintsSeriesResponse added in v0.13.0 

func NewHintsSeriesResponse(hints *types.Any) *SeriesResponse

func NewSeriesResponse 

func NewSeriesResponse(series *Series) *SeriesResponse

func NewWarnSeriesResponse 

func NewWarnSeriesResponse(err error) *SeriesResponse

func (*SeriesResponse) Descriptor 

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

func (*SeriesResponse) GetHints added in v0.13.0 

func (m *SeriesResponse) GetHints() *types.Any

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_Hints added in v0.13.0 

type SeriesResponse_Hints struct {
	Hints *types.Any `protobuf:"bytes,3,opt,name=hints,proto3,oneof" json:"hints,omitempty"`
}

func (*SeriesResponse_Hints) MarshalTo added in v0.13.0 

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

func (*SeriesResponse_Hints) MarshalToSizedBuffer added in v0.13.0 

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

func (*SeriesResponse_Hints) Size added in v0.13.0 

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

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() (labels.Labels, []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 takes all series sets and returns as a union single series set. It assumes series are sorted by labels within single SeriesSet, similar to remote read guarantees. However, they can be partial: in such case, if the single SeriesSet returns the same series within many iterations, MergeSeriesSets will merge those into one.

It also assumes in a "best effort" way that chunks are sorted by min time. It's done as an optimization only, so if input series' chunks are NOT sorted, the only consequence is that the duplicates might be not correctly removed. This is double checked which on just-before PromQL level as well, so the only consequence is increased network bandwidth. If all chunks were sorted, MergeSeriesSet ALSO returns sorted chunks by min time.

Chunks within the same series can also overlap (within all SeriesSet as well as single SeriesSet alone). If the chunk ranges overlap, the *exact* chunk duplicates will be removed (except one), and any other overlaps will be appended into on chunks slice.

type SeriesStatsCounter added in v0.23.0 

type SeriesStatsCounter struct {
	Series  int
	Chunks  int
	Samples int
	// contains filtered or unexported fields
}

func (*SeriesStatsCounter) Count added in v0.23.0 

func (c *SeriesStatsCounter) Count(series *Series)

func (*SeriesStatsCounter) CountSeries added in v0.23.0 

func (c *SeriesStatsCounter) CountSeries(seriesLabels []labelpb.ZLabel)

type ShardInfo added in v0.28.0 

type ShardInfo struct {
	// The index of the current shard.
	ShardIndex int64 `protobuf:"varint,1,opt,name=shard_index,json=shardIndex,proto3" json:"shard_index,omitempty"`
	// The total number of shards.
	TotalShards int64 `protobuf:"varint,2,opt,name=total_shards,json=totalShards,proto3" json:"total_shards,omitempty"`
	// Group by or without labels.
	By bool `protobuf:"varint,3,opt,name=by,proto3" json:"by,omitempty"`
	// Labels on which to partition series.
	Labels []string `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty"`
}

ShardInfo are the parameters used to shard series in Stores.

func (*ShardInfo) Descriptor added in v0.28.0 

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

func (*ShardInfo) Marshal added in v0.28.0 

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

func (*ShardInfo) MarshalTo added in v0.28.0 

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

func (*ShardInfo) MarshalToSizedBuffer added in v0.28.0 

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

func (*ShardInfo) Matcher added in v0.28.0 

func (m *ShardInfo) Matcher(buffers *sync.Pool) *ShardMatcher

func (*ShardInfo) ProtoMessage added in v0.28.0 

func (*ShardInfo) ProtoMessage()

func (*ShardInfo) Reset added in v0.28.0 

func (m *ShardInfo) Reset()

func (*ShardInfo) Size added in v0.28.0 

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

func (*ShardInfo) String added in v0.28.0 

func (m *ShardInfo) String() string

func (*ShardInfo) Unmarshal added in v0.28.0 

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

func (*ShardInfo) XXX_DiscardUnknown added in v0.28.0 

func (m *ShardInfo) XXX_DiscardUnknown()

func (*ShardInfo) XXX_Marshal added in v0.28.0 

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

func (*ShardInfo) XXX_Merge added in v0.28.0 

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

func (*ShardInfo) XXX_Size added in v0.28.0 

func (m *ShardInfo) XXX_Size() int

func (*ShardInfo) XXX_Unmarshal added in v0.28.0 

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

type ShardMatcher added in v0.28.0 

type ShardMatcher struct {
	// contains filtered or unexported fields
}

func (*ShardMatcher) Close added in v0.28.0 

func (s *ShardMatcher) Close()

func (*ShardMatcher) IsSharded added in v0.28.0 

func (s *ShardMatcher) IsSharded() bool

func (*ShardMatcher) MatchesLabels added in v0.28.0 

func (s *ShardMatcher) MatchesLabels(lbls labels.Labels) bool

func (*ShardMatcher) MatchesZLabels added in v0.28.0 

func (s *ShardMatcher) MatchesZLabels(zLabels []labelpb.ZLabel) bool

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.
	///
	/// There is no requirements on chunk sorting, however it is recommended to have chunk sorted by chunk min time.
	/// This heavily optimizes the resource usage on Querier / Federated Queries.
	Series(ctx context.Context, in *SeriesRequest, opts ...grpc.CallOption) (Store_SeriesClient, error)
	/// LabelNames returns all label names constrained by the given matchers.
	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

func ServerAsClient added in v0.18.0 

func ServerAsClient(srv StoreServer, clientReceiveBufferSize int) 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.
	///
	/// There is no requirements on chunk sorting, however it is recommended to have chunk sorted by chunk min time.
	/// This heavily optimizes the resource usage on Querier / Federated Queries.
	Series(*SeriesRequest, Store_SeriesServer) error
	/// LabelNames returns all label names constrained by the given matchers.
	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
	// DEBUG represents some debug StoreAPI components e.g. thanos tools store-api-serve.
	StoreType_DEBUG StoreType = 6
)

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

Directories

Path Synopsis

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.