client

package
v0.0.0-...-748a726 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2024 License: AGPL-3.0 Imports: 45 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthIngester = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowIngester   = fmt.Errorf("proto: integer overflow")
)
View Source 
var CountMethod_name = map[int32]string{
	0: "IN_MEMORY",
	1: "ACTIVE",
}
View Source 
var CountMethod_value = map[string]int32{
	"IN_MEMORY": 0,
	"ACTIVE":    1,
}
View Source 
var MatchType_name = map[int32]string{
	0: "EQUAL",
	1: "NOT_EQUAL",
	2: "REGEX_MATCH",
	3: "REGEX_NO_MATCH",
}
View Source 
var MatchType_value = map[string]int32{
	"EQUAL":          0,
	"NOT_EQUAL":      1,
	"REGEX_MATCH":    2,
	"REGEX_NO_MATCH": 3,
}
View Source 
var ReadRequest_ResponseType_name = map[int32]string{
	0: "SAMPLES",
	1: "STREAMED_XOR_CHUNKS",
}
View Source 
var ReadRequest_ResponseType_value = map[string]int32{
	"SAMPLES":             0,
	"STREAMED_XOR_CHUNKS": 1,
}
View Source 
var StreamChunk_Encoding_name = map[int32]string{
	0: "UNKNOWN",
	1: "XOR",
	2: "HISTOGRAM",
	3: "FLOAT_HISTOGRAM",
}
View Source 
var StreamChunk_Encoding_value = map[string]int32{
	"UNKNOWN":         0,
	"XOR":             1,
	"HISTOGRAM":       2,
	"FLOAT_HISTOGRAM": 3,
}

Functions

func ChunksCount 

func ChunksCount(series []TimeSeriesChunk) int

func ChunksSize 

func ChunksSize(series []TimeSeriesChunk) int

func FromChunks 

func FromChunks(metric labels.Labels, in []Chunk) ([]chunk.Chunk, error)

FromChunks converts []client.Chunk to []chunk.Chunk.

func FromExemplarQueryRequest 

func FromExemplarQueryRequest(req *ExemplarQueryRequest) (int64, int64, [][]*labels.Matcher, error)

FromExemplarQueryRequest unpacks a ExemplarQueryRequest proto.

func FromLabelMatchers 

func FromLabelMatchers(matchers []*LabelMatcher) ([]*labels.Matcher, error)

func FromLabelNamesRequest 

func FromLabelNamesRequest(req *LabelNamesRequest) (int64, int64, []*labels.Matcher, error)

FromLabelNamesRequest unpacks a LabelNamesRequest proto

func FromLabelValuesRequest 

func FromLabelValuesRequest(req *LabelValuesRequest) (string, int64, int64, []*labels.Matcher, error)

FromLabelValuesRequest unpacks a LabelValuesRequest proto

func FromMetricsForLabelMatchersRequest 

func FromMetricsForLabelMatchersRequest(req *MetricsForLabelMatchersRequest) ([][]*labels.Matcher, error)

FromMetricsForLabelMatchersRequest unpacks a MetricsForLabelMatchersRequest proto.

func FromMetricsForLabelMatchersResponse 

func FromMetricsForLabelMatchersResponse(resp *MetricsForLabelMatchersResponse) []labels.Labels

FromMetricsForLabelMatchersResponse unpacks a MetricsForLabelMatchersResponse proto

func FromQueryRequest 

func FromQueryRequest(req *QueryRequest) (model.Time, model.Time, []*labels.Matcher, error)

FromQueryRequest unpacks a QueryRequest proto.

func LabelsToKeyString 

func LabelsToKeyString(l labels.Labels) string

LabelsToKeyString is used to form a string to be used as the hashKey. Don't print, use l.String() for printing.

func NewCircuitBreaker 

func NewCircuitBreaker(inst ring.InstanceDesc, cfg CircuitBreakerConfig, metrics *Metrics, logger log.Logger) grpc.UnaryClientInterceptor

func RegisterIngesterServer 

func RegisterIngesterServer(s *grpc.Server, srv IngesterServer)

func SendActiveSeriesResponse 

func SendActiveSeriesResponse(s Ingester_ActiveSeriesServer, response *ActiveSeriesResponse) error

func SendLabelNamesAndValuesResponse 

func SendLabelNamesAndValuesResponse(s Ingester_LabelNamesAndValuesServer, response *LabelNamesAndValuesResponse) error

SendLabelNamesAndValuesResponse wraps the stream's Send() checking if the context is done before calling Send().

func SendLabelValuesCardinalityResponse 

func SendLabelValuesCardinalityResponse(s Ingester_LabelValuesCardinalityServer, response *LabelValuesCardinalityResponse) error

SendLabelValuesCardinalityResponse wraps the stream's Send() checking if the context is done before calling Send().

func SendQueryStream 

func SendQueryStream(s Ingester_QueryStreamServer, m *QueryStreamResponse) error

SendQueryStream wraps the stream's Send() checking if the context is done before calling Send().

func StreamingSeriesToMatrix 

func StreamingSeriesToMatrix(from, through model.Time, sSeries []StreamingSeries) (model.Matrix, error)

StreamingSeriesToMatrix converts slice of []client.TimeSeriesChunk to a model.Matrix.

func StreamsToMatrix 

func StreamsToMatrix(from, through model.Time, responses []*QueryStreamResponse) (model.Matrix, error)

StreamsToMatrix converts a slice of QueryStreamResponse to a model.Matrix.

func TimeSeriesChunksToMatrix 

func TimeSeriesChunksToMatrix(from, through model.Time, serieses []TimeSeriesChunk) (model.Matrix, error)

TimeSeriesChunksToMatrix converts slice of []client.TimeSeriesChunk to a model.Matrix.

func TimeseriesToMatrix 

func TimeseriesToMatrix(from, through model.Time, series []mimirpb.TimeSeries) (model.Matrix, error)

func WithSlabPool 

func WithSlabPool(ctx context.Context, pool *pool.FastReleasingSlabPool[byte]) context.Context

Types

type ActiveSeriesRequest 

type ActiveSeriesRequest struct {
	Matchers []*LabelMatcher `protobuf:"bytes,1,rep,name=matchers,proto3" json:"matchers,omitempty"`
}

func ToActiveSeriesRequest 

func ToActiveSeriesRequest(matchers []*labels.Matcher) (*ActiveSeriesRequest, error)

func (*ActiveSeriesRequest) Descriptor 

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

func (*ActiveSeriesRequest) Equal 

func (this *ActiveSeriesRequest) Equal(that interface{}) bool

func (*ActiveSeriesRequest) GetMatchers 

func (m *ActiveSeriesRequest) GetMatchers() []*LabelMatcher

func (*ActiveSeriesRequest) GoString 

func (this *ActiveSeriesRequest) GoString() string

func (*ActiveSeriesRequest) Marshal 

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

func (*ActiveSeriesRequest) MarshalTo 

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

func (*ActiveSeriesRequest) MarshalToSizedBuffer 

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

func (*ActiveSeriesRequest) ProtoMessage 

func (*ActiveSeriesRequest) ProtoMessage()

func (*ActiveSeriesRequest) Reset 

func (m *ActiveSeriesRequest) Reset()

func (*ActiveSeriesRequest) Size 

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

func (*ActiveSeriesRequest) String 

func (this *ActiveSeriesRequest) String() string

func (*ActiveSeriesRequest) Unmarshal 

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

func (*ActiveSeriesRequest) XXX_DiscardUnknown 

func (m *ActiveSeriesRequest) XXX_DiscardUnknown()

func (*ActiveSeriesRequest) XXX_Marshal 

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

func (*ActiveSeriesRequest) XXX_Merge 

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

func (*ActiveSeriesRequest) XXX_Size 

func (m *ActiveSeriesRequest) XXX_Size() int

func (*ActiveSeriesRequest) XXX_Unmarshal 

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

type ActiveSeriesResponse 

type ActiveSeriesResponse struct {
	Metric []*mimirpb.Metric `protobuf:"bytes,1,rep,name=metric,proto3" json:"metric,omitempty"`
}

func (*ActiveSeriesResponse) Descriptor 

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

func (*ActiveSeriesResponse) Equal 

func (this *ActiveSeriesResponse) Equal(that interface{}) bool

func (*ActiveSeriesResponse) GetMetric 

func (m *ActiveSeriesResponse) GetMetric() []*mimirpb.Metric

func (*ActiveSeriesResponse) GoString 

func (this *ActiveSeriesResponse) GoString() string

func (*ActiveSeriesResponse) Marshal 

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

func (*ActiveSeriesResponse) MarshalTo 

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

func (*ActiveSeriesResponse) MarshalToSizedBuffer 

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

func (*ActiveSeriesResponse) ProtoMessage 

func (*ActiveSeriesResponse) ProtoMessage()

func (*ActiveSeriesResponse) Reset 

func (m *ActiveSeriesResponse) Reset()

func (*ActiveSeriesResponse) Size 

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

func (*ActiveSeriesResponse) String 

func (this *ActiveSeriesResponse) String() string

func (*ActiveSeriesResponse) Unmarshal 

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

func (*ActiveSeriesResponse) XXX_DiscardUnknown 

func (m *ActiveSeriesResponse) XXX_DiscardUnknown()

func (*ActiveSeriesResponse) XXX_Marshal 

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

func (*ActiveSeriesResponse) XXX_Merge 

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

func (*ActiveSeriesResponse) XXX_Size 

func (m *ActiveSeriesResponse) XXX_Size() int

func (*ActiveSeriesResponse) XXX_Unmarshal 

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

type Chunk 

type Chunk struct {
	StartTimestampMs int64                                                `protobuf:"varint,1,opt,name=start_timestamp_ms,json=startTimestampMs,proto3" json:"start_timestamp_ms,omitempty"`
	EndTimestampMs   int64                                                `protobuf:"varint,2,opt,name=end_timestamp_ms,json=endTimestampMs,proto3" json:"end_timestamp_ms,omitempty"`
	Encoding         int32                                                `protobuf:"varint,3,opt,name=encoding,proto3" json:"encoding,omitempty"`
	Data             github_com_grafana_mimir_pkg_mimirpb.UnsafeByteSlice `protobuf:"bytes,4,opt,name=data,proto3,customtype=github.com/grafana/mimir/pkg/mimirpb.UnsafeByteSlice" json:"data"`
}

func AccumulateChunks 

func AccumulateChunks(a, b []Chunk) []Chunk

AccumulateChunks builds a slice of chunks, eliminating duplicates. This is O(N^2) but most of the time N is small.

func ChunkFromMeta 

func ChunkFromMeta(meta chunks.Meta) (Chunk, error)

func ToChunks 

func ToChunks(in []chunk.Chunk) ([]Chunk, error)

ToChunks converts []chunk.Chunk to []client.Chunk.

func (*Chunk) Descriptor 

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

func (*Chunk) Equal 

func (this *Chunk) Equal(that interface{}) bool

func (*Chunk) GetEncoding 

func (m *Chunk) GetEncoding() int32

func (*Chunk) GetEndTimestampMs 

func (m *Chunk) GetEndTimestampMs() int64

func (*Chunk) GetStartTimestampMs 

func (m *Chunk) GetStartTimestampMs() int64

func (*Chunk) GoString 

func (this *Chunk) GoString() string

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 

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 (this *Chunk) String() string

func (*Chunk) Unmarshal 

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

func (*Chunk) XXX_DiscardUnknown 

func (m *Chunk) XXX_DiscardUnknown()

func (*Chunk) XXX_Marshal 

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

func (*Chunk) XXX_Merge 

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

func (*Chunk) XXX_Size 

func (m *Chunk) XXX_Size() int

func (*Chunk) XXX_Unmarshal 

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

type CircuitBreakerConfig 

type CircuitBreakerConfig struct {
	Enabled                   bool          `yaml:"enabled" category:"experimental"`
	FailureThreshold          uint          `yaml:"failure_threshold" category:"experimental"`
	FailureExecutionThreshold uint          `yaml:"failure_execution_threshold" category:"experimental"`
	ThresholdingPeriod        time.Duration `yaml:"thresholding_period" category:"experimental"`
	CooldownPeriod            time.Duration `yaml:"cooldown_period" category:"experimental"`
}

func (*CircuitBreakerConfig) RegisterFlagsWithPrefix 

func (cfg *CircuitBreakerConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

func (*CircuitBreakerConfig) Validate 

func (cfg *CircuitBreakerConfig) Validate() error

type CombinedQueryStreamResponse 

type CombinedQueryStreamResponse struct {
	Chunkseries     []TimeSeriesChunk
	Timeseries      []mimirpb.TimeSeries
	StreamingSeries []StreamingSeries
}

type Config 

type Config struct {
	GRPCClientConfig                grpcclient.Config    `` /* 145-byte string literal not displayed */
	CircuitBreaker                  CircuitBreakerConfig `yaml:"circuit_breaker"`
	DeprecatedReportGRPCStatusCodes bool                 `yaml:"report_grpc_codes_in_instrumentation_label_enabled" category:"deprecated"` // Deprecated: Deprecated in Mimir 2.12, remove in Mimir 2.14 (https://github.com/grafana/mimir/issues/6008#issuecomment-1854320098)
}

Config is the configuration struct for the ingester client

func (*Config) RegisterFlags 

func (cfg *Config) RegisterFlags(f *flag.FlagSet)

RegisterFlags registers configuration settings used by the ingester client config.

func (*Config) Validate 

func (cfg *Config) Validate(logger log.Logger) error

type CountMethod 

type CountMethod int32
const (
	IN_MEMORY CountMethod = 0
	ACTIVE    CountMethod = 1
)

func (CountMethod) EnumDescriptor 

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

func (CountMethod) String 

func (x CountMethod) String() string

type ErrCircuitBreakerOpen 

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

func (ErrCircuitBreakerOpen) Error 

func (e ErrCircuitBreakerOpen) Error() string

func (ErrCircuitBreakerOpen) RemainingDelay 

func (e ErrCircuitBreakerOpen) RemainingDelay() time.Duration

func (ErrCircuitBreakerOpen) Unwrap 

func (e ErrCircuitBreakerOpen) Unwrap() error

type ExemplarQueryRequest 

type ExemplarQueryRequest struct {
	StartTimestampMs int64            `protobuf:"varint,1,opt,name=start_timestamp_ms,json=startTimestampMs,proto3" json:"start_timestamp_ms,omitempty"`
	EndTimestampMs   int64            `protobuf:"varint,2,opt,name=end_timestamp_ms,json=endTimestampMs,proto3" json:"end_timestamp_ms,omitempty"`
	Matchers         []*LabelMatchers `protobuf:"bytes,3,rep,name=matchers,proto3" json:"matchers,omitempty"`
}

func ToExemplarQueryRequest 

func ToExemplarQueryRequest(from, to model.Time, matchers ...[]*labels.Matcher) (*ExemplarQueryRequest, error)

ToExemplarQueryRequest builds an ExemplarQueryRequest proto.

func (*ExemplarQueryRequest) Descriptor 

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

func (*ExemplarQueryRequest) Equal 

func (this *ExemplarQueryRequest) Equal(that interface{}) bool

func (*ExemplarQueryRequest) GetEndTimestampMs 

func (m *ExemplarQueryRequest) GetEndTimestampMs() int64

func (*ExemplarQueryRequest) GetMatchers 

func (m *ExemplarQueryRequest) GetMatchers() []*LabelMatchers

func (*ExemplarQueryRequest) GetStartTimestampMs 

func (m *ExemplarQueryRequest) GetStartTimestampMs() int64

func (*ExemplarQueryRequest) GoString 

func (this *ExemplarQueryRequest) GoString() string

func (*ExemplarQueryRequest) Marshal 

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

func (*ExemplarQueryRequest) MarshalTo 

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

func (*ExemplarQueryRequest) MarshalToSizedBuffer 

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

func (*ExemplarQueryRequest) ProtoMessage 

func (*ExemplarQueryRequest) ProtoMessage()

func (*ExemplarQueryRequest) Reset 

func (m *ExemplarQueryRequest) Reset()

func (*ExemplarQueryRequest) Size 

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

func (*ExemplarQueryRequest) String 

func (this *ExemplarQueryRequest) String() string

func (*ExemplarQueryRequest) Unmarshal 

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

func (*ExemplarQueryRequest) XXX_DiscardUnknown 

func (m *ExemplarQueryRequest) XXX_DiscardUnknown()

func (*ExemplarQueryRequest) XXX_Marshal 

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

func (*ExemplarQueryRequest) XXX_Merge 

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

func (*ExemplarQueryRequest) XXX_Size 

func (m *ExemplarQueryRequest) XXX_Size() int

func (*ExemplarQueryRequest) XXX_Unmarshal 

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

type ExemplarQueryResponse 

type ExemplarQueryResponse struct {
	Timeseries []mimirpb.TimeSeries `protobuf:"bytes,1,rep,name=timeseries,proto3" json:"timeseries"`
}

func (*ExemplarQueryResponse) Descriptor 

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

func (*ExemplarQueryResponse) Equal 

func (this *ExemplarQueryResponse) Equal(that interface{}) bool

func (*ExemplarQueryResponse) GetTimeseries 

func (m *ExemplarQueryResponse) GetTimeseries() []mimirpb.TimeSeries

func (*ExemplarQueryResponse) GoString 

func (this *ExemplarQueryResponse) GoString() string

func (*ExemplarQueryResponse) Marshal 

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

func (*ExemplarQueryResponse) MarshalTo 

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

func (*ExemplarQueryResponse) MarshalToSizedBuffer 

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

func (*ExemplarQueryResponse) ProtoMessage 

func (*ExemplarQueryResponse) ProtoMessage()

func (*ExemplarQueryResponse) Reset 

func (m *ExemplarQueryResponse) Reset()

func (*ExemplarQueryResponse) Size 

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

func (*ExemplarQueryResponse) String 

func (this *ExemplarQueryResponse) String() string

func (*ExemplarQueryResponse) Unmarshal 

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

func (*ExemplarQueryResponse) XXX_DiscardUnknown 

func (m *ExemplarQueryResponse) XXX_DiscardUnknown()

func (*ExemplarQueryResponse) XXX_Marshal 

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

func (*ExemplarQueryResponse) XXX_Merge 

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

func (*ExemplarQueryResponse) XXX_Size 

func (m *ExemplarQueryResponse) XXX_Size() int

func (*ExemplarQueryResponse) XXX_Unmarshal 

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

type HealthAndIngesterClient 

type HealthAndIngesterClient interface {
	IngesterClient
	grpc_health_v1.HealthClient
	Close() error
}

HealthAndIngesterClient is the union of IngesterClient and grpc_health_v1.HealthClient.

func MakeIngesterClient 

func MakeIngesterClient(inst ring.InstanceDesc, cfg Config, metrics *Metrics, logger log.Logger) (HealthAndIngesterClient, error)

MakeIngesterClient makes a new IngesterClient

type IngesterClient 

type IngesterClient interface {
	Push(ctx context.Context, in *mimirpb.WriteRequest, opts ...grpc.CallOption) (*mimirpb.WriteResponse, error)
	QueryStream(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (Ingester_QueryStreamClient, error)
	QueryExemplars(ctx context.Context, in *ExemplarQueryRequest, opts ...grpc.CallOption) (*ExemplarQueryResponse, error)
	LabelValues(ctx context.Context, in *LabelValuesRequest, opts ...grpc.CallOption) (*LabelValuesResponse, error)
	LabelNames(ctx context.Context, in *LabelNamesRequest, opts ...grpc.CallOption) (*LabelNamesResponse, error)
	UserStats(ctx context.Context, in *UserStatsRequest, opts ...grpc.CallOption) (*UserStatsResponse, error)
	AllUserStats(ctx context.Context, in *UserStatsRequest, opts ...grpc.CallOption) (*UsersStatsResponse, error)
	MetricsForLabelMatchers(ctx context.Context, in *MetricsForLabelMatchersRequest, opts ...grpc.CallOption) (*MetricsForLabelMatchersResponse, error)
	MetricsMetadata(ctx context.Context, in *MetricsMetadataRequest, opts ...grpc.CallOption) (*MetricsMetadataResponse, error)
	// LabelNamesAndValues provides all values for each label that matches the matchers.
	// The order of the labels and values is not guaranteed.
	LabelNamesAndValues(ctx context.Context, in *LabelNamesAndValuesRequest, opts ...grpc.CallOption) (Ingester_LabelNamesAndValuesClient, error)
	// LabelValuesCardinality returns all values and series total count for label_names labels
	// that match the matchers.
	// The listing order of the labels is not guaranteed.
	LabelValuesCardinality(ctx context.Context, in *LabelValuesCardinalityRequest, opts ...grpc.CallOption) (Ingester_LabelValuesCardinalityClient, error)
	ActiveSeries(ctx context.Context, in *ActiveSeriesRequest, opts ...grpc.CallOption) (Ingester_ActiveSeriesClient, error)
}

IngesterClient is the client API for Ingester service.

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

func NewIngesterClient 

func NewIngesterClient(cc *grpc.ClientConn) IngesterClient

type IngesterServer 

type IngesterServer interface {
	Push(context.Context, *mimirpb.WriteRequest) (*mimirpb.WriteResponse, error)
	QueryStream(*QueryRequest, Ingester_QueryStreamServer) error
	QueryExemplars(context.Context, *ExemplarQueryRequest) (*ExemplarQueryResponse, error)
	LabelValues(context.Context, *LabelValuesRequest) (*LabelValuesResponse, error)
	LabelNames(context.Context, *LabelNamesRequest) (*LabelNamesResponse, error)
	UserStats(context.Context, *UserStatsRequest) (*UserStatsResponse, error)
	AllUserStats(context.Context, *UserStatsRequest) (*UsersStatsResponse, error)
	MetricsForLabelMatchers(context.Context, *MetricsForLabelMatchersRequest) (*MetricsForLabelMatchersResponse, error)
	MetricsMetadata(context.Context, *MetricsMetadataRequest) (*MetricsMetadataResponse, error)
	// LabelNamesAndValues provides all values for each label that matches the matchers.
	// The order of the labels and values is not guaranteed.
	LabelNamesAndValues(*LabelNamesAndValuesRequest, Ingester_LabelNamesAndValuesServer) error
	// LabelValuesCardinality returns all values and series total count for label_names labels
	// that match the matchers.
	// The listing order of the labels is not guaranteed.
	LabelValuesCardinality(*LabelValuesCardinalityRequest, Ingester_LabelValuesCardinalityServer) error
	ActiveSeries(*ActiveSeriesRequest, Ingester_ActiveSeriesServer) error
}

IngesterServer is the server API for Ingester service.

type Ingester_ActiveSeriesClient 

type Ingester_ActiveSeriesClient interface {
	Recv() (*ActiveSeriesResponse, error)
	grpc.ClientStream
}

type Ingester_ActiveSeriesServer 

type Ingester_ActiveSeriesServer interface {
	Send(*ActiveSeriesResponse) error
	grpc.ServerStream
}

type Ingester_LabelNamesAndValuesClient 

type Ingester_LabelNamesAndValuesClient interface {
	Recv() (*LabelNamesAndValuesResponse, error)
	grpc.ClientStream
}

type Ingester_LabelNamesAndValuesServer 

type Ingester_LabelNamesAndValuesServer interface {
	Send(*LabelNamesAndValuesResponse) error
	grpc.ServerStream
}

type Ingester_LabelValuesCardinalityClient 

type Ingester_LabelValuesCardinalityClient interface {
	Recv() (*LabelValuesCardinalityResponse, error)
	grpc.ClientStream
}

type Ingester_LabelValuesCardinalityServer 

type Ingester_LabelValuesCardinalityServer interface {
	Send(*LabelValuesCardinalityResponse) error
	grpc.ServerStream
}

type Ingester_QueryStreamClient 

type Ingester_QueryStreamClient interface {
	Recv() (*QueryStreamResponse, error)
	grpc.ClientStream
}

type Ingester_QueryStreamServer 

type Ingester_QueryStreamServer interface {
	Send(*QueryStreamResponse) error
	grpc.ServerStream
}

type LabelMatcher 

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

func ToLabelMatchers 

func ToLabelMatchers(matchers []*labels.Matcher) ([]*LabelMatcher, error)

func (*LabelMatcher) Descriptor 

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

func (*LabelMatcher) Equal 

func (this *LabelMatcher) Equal(that interface{}) bool

func (*LabelMatcher) GetName 

func (m *LabelMatcher) GetName() string

func (*LabelMatcher) GetType 

func (m *LabelMatcher) GetType() MatchType

func (*LabelMatcher) GetValue 

func (m *LabelMatcher) GetValue() string

func (*LabelMatcher) GoString 

func (this *LabelMatcher) GoString() string

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 

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 (this *LabelMatcher) String() string

func (*LabelMatcher) Unmarshal 

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

func (*LabelMatcher) XXX_DiscardUnknown 

func (m *LabelMatcher) XXX_DiscardUnknown()

func (*LabelMatcher) XXX_Marshal 

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

func (*LabelMatcher) XXX_Merge 

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

func (*LabelMatcher) XXX_Size 

func (m *LabelMatcher) XXX_Size() int

func (*LabelMatcher) XXX_Unmarshal 

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

type LabelMatchers 

type LabelMatchers struct {
	Matchers []*LabelMatcher `protobuf:"bytes,1,rep,name=matchers,proto3" json:"matchers,omitempty"`
}

func (*LabelMatchers) Descriptor 

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

func (*LabelMatchers) Equal 

func (this *LabelMatchers) Equal(that interface{}) bool

func (*LabelMatchers) GetMatchers 

func (m *LabelMatchers) GetMatchers() []*LabelMatcher

func (*LabelMatchers) GoString 

func (this *LabelMatchers) GoString() string

func (*LabelMatchers) Marshal 

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

func (*LabelMatchers) MarshalTo 

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

func (*LabelMatchers) MarshalToSizedBuffer 

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

func (*LabelMatchers) ProtoMessage 

func (*LabelMatchers) ProtoMessage()

func (*LabelMatchers) Reset 

func (m *LabelMatchers) Reset()

func (*LabelMatchers) Size 

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

func (*LabelMatchers) String 

func (this *LabelMatchers) String() string

func (*LabelMatchers) Unmarshal 

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

func (*LabelMatchers) XXX_DiscardUnknown 

func (m *LabelMatchers) XXX_DiscardUnknown()

func (*LabelMatchers) XXX_Marshal 

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

func (*LabelMatchers) XXX_Merge 

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

func (*LabelMatchers) XXX_Size 

func (m *LabelMatchers) XXX_Size() int

func (*LabelMatchers) XXX_Unmarshal 

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

type LabelNamesAndValuesRequest 

type LabelNamesAndValuesRequest struct {
	Matchers    []*LabelMatcher `protobuf:"bytes,1,rep,name=matchers,proto3" json:"matchers,omitempty"`
	CountMethod CountMethod     `protobuf:"varint,2,opt,name=count_method,json=countMethod,proto3,enum=cortex.CountMethod" json:"count_method,omitempty"`
}

func (*LabelNamesAndValuesRequest) Descriptor 

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

func (*LabelNamesAndValuesRequest) Equal 

func (this *LabelNamesAndValuesRequest) Equal(that interface{}) bool

func (*LabelNamesAndValuesRequest) GetCountMethod 

func (m *LabelNamesAndValuesRequest) GetCountMethod() CountMethod

func (*LabelNamesAndValuesRequest) GetMatchers 

func (m *LabelNamesAndValuesRequest) GetMatchers() []*LabelMatcher

func (*LabelNamesAndValuesRequest) GoString 

func (this *LabelNamesAndValuesRequest) GoString() string

func (*LabelNamesAndValuesRequest) Marshal 

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

func (*LabelNamesAndValuesRequest) MarshalTo 

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

func (*LabelNamesAndValuesRequest) MarshalToSizedBuffer 

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

func (*LabelNamesAndValuesRequest) ProtoMessage 

func (*LabelNamesAndValuesRequest) ProtoMessage()

func (*LabelNamesAndValuesRequest) Reset 

func (m *LabelNamesAndValuesRequest) Reset()

func (*LabelNamesAndValuesRequest) Size 

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

func (*LabelNamesAndValuesRequest) String 

func (this *LabelNamesAndValuesRequest) String() string

func (*LabelNamesAndValuesRequest) Unmarshal 

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

func (*LabelNamesAndValuesRequest) XXX_DiscardUnknown 

func (m *LabelNamesAndValuesRequest) XXX_DiscardUnknown()

func (*LabelNamesAndValuesRequest) XXX_Marshal 

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

func (*LabelNamesAndValuesRequest) XXX_Merge 

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

func (*LabelNamesAndValuesRequest) XXX_Size 

func (m *LabelNamesAndValuesRequest) XXX_Size() int

func (*LabelNamesAndValuesRequest) XXX_Unmarshal 

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

type LabelNamesAndValuesResponse 

type LabelNamesAndValuesResponse struct {
	Items []*LabelValues `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
}

func (*LabelNamesAndValuesResponse) Descriptor 

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

func (*LabelNamesAndValuesResponse) Equal 

func (this *LabelNamesAndValuesResponse) Equal(that interface{}) bool

func (*LabelNamesAndValuesResponse) GetItems 

func (m *LabelNamesAndValuesResponse) GetItems() []*LabelValues

func (*LabelNamesAndValuesResponse) GoString 

func (this *LabelNamesAndValuesResponse) GoString() string

func (*LabelNamesAndValuesResponse) Marshal 

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

func (*LabelNamesAndValuesResponse) MarshalTo 

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

func (*LabelNamesAndValuesResponse) MarshalToSizedBuffer 

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

func (*LabelNamesAndValuesResponse) ProtoMessage 

func (*LabelNamesAndValuesResponse) ProtoMessage()

func (*LabelNamesAndValuesResponse) Reset 

func (m *LabelNamesAndValuesResponse) Reset()

func (*LabelNamesAndValuesResponse) Size 

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

func (*LabelNamesAndValuesResponse) String 

func (this *LabelNamesAndValuesResponse) String() string

func (*LabelNamesAndValuesResponse) Unmarshal 

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

func (*LabelNamesAndValuesResponse) XXX_DiscardUnknown 

func (m *LabelNamesAndValuesResponse) XXX_DiscardUnknown()

func (*LabelNamesAndValuesResponse) XXX_Marshal 

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

func (*LabelNamesAndValuesResponse) XXX_Merge 

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

func (*LabelNamesAndValuesResponse) XXX_Size 

func (m *LabelNamesAndValuesResponse) XXX_Size() int

func (*LabelNamesAndValuesResponse) XXX_Unmarshal 

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

type LabelNamesRequest 

type LabelNamesRequest struct {
	StartTimestampMs int64          `protobuf:"varint,1,opt,name=start_timestamp_ms,json=startTimestampMs,proto3" json:"start_timestamp_ms,omitempty"`
	EndTimestampMs   int64          `protobuf:"varint,2,opt,name=end_timestamp_ms,json=endTimestampMs,proto3" json:"end_timestamp_ms,omitempty"`
	Matchers         *LabelMatchers `protobuf:"bytes,3,opt,name=matchers,proto3" json:"matchers,omitempty"`
}

func ToLabelNamesRequest 

func ToLabelNamesRequest(from, to model.Time, matchers []*labels.Matcher) (*LabelNamesRequest, error)

ToLabelNamesRequest builds a LabelNamesRequest proto

func (*LabelNamesRequest) Descriptor 

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

func (*LabelNamesRequest) Equal 

func (this *LabelNamesRequest) Equal(that interface{}) bool

func (*LabelNamesRequest) GetEndTimestampMs 

func (m *LabelNamesRequest) GetEndTimestampMs() int64

func (*LabelNamesRequest) GetMatchers 

func (m *LabelNamesRequest) GetMatchers() *LabelMatchers

func (*LabelNamesRequest) GetStartTimestampMs 

func (m *LabelNamesRequest) GetStartTimestampMs() int64

func (*LabelNamesRequest) GoString 

func (this *LabelNamesRequest) GoString() string

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 

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 (this *LabelNamesRequest) String() string

func (*LabelNamesRequest) Unmarshal 

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

func (*LabelNamesRequest) XXX_DiscardUnknown 

func (m *LabelNamesRequest) XXX_DiscardUnknown()

func (*LabelNamesRequest) XXX_Marshal 

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

func (*LabelNamesRequest) XXX_Merge 

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

func (*LabelNamesRequest) XXX_Size 

func (m *LabelNamesRequest) XXX_Size() int

func (*LabelNamesRequest) XXX_Unmarshal 

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

type LabelNamesResponse 

type LabelNamesResponse struct {
	LabelNames []string `protobuf:"bytes,1,rep,name=label_names,json=labelNames,proto3" json:"label_names,omitempty"`
}

func (*LabelNamesResponse) Descriptor 

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

func (*LabelNamesResponse) Equal 

func (this *LabelNamesResponse) Equal(that interface{}) bool

func (*LabelNamesResponse) GetLabelNames 

func (m *LabelNamesResponse) GetLabelNames() []string

func (*LabelNamesResponse) GoString 

func (this *LabelNamesResponse) GoString() string

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 

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 (this *LabelNamesResponse) String() string

func (*LabelNamesResponse) Unmarshal 

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

func (*LabelNamesResponse) XXX_DiscardUnknown 

func (m *LabelNamesResponse) XXX_DiscardUnknown()

func (*LabelNamesResponse) XXX_Marshal 

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

func (*LabelNamesResponse) XXX_Merge 

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

func (*LabelNamesResponse) XXX_Size 

func (m *LabelNamesResponse) XXX_Size() int

func (*LabelNamesResponse) XXX_Unmarshal 

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

type LabelValueSeriesCount 

type LabelValueSeriesCount struct {
	LabelName        string            `protobuf:"bytes,1,opt,name=label_name,json=labelName,proto3" json:"label_name,omitempty"`
	LabelValueSeries map[string]uint64 `` /* 200-byte string literal not displayed */
}

func (*LabelValueSeriesCount) Descriptor 

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

func (*LabelValueSeriesCount) Equal 

func (this *LabelValueSeriesCount) Equal(that interface{}) bool

func (*LabelValueSeriesCount) GetLabelName 

func (m *LabelValueSeriesCount) GetLabelName() string

func (*LabelValueSeriesCount) GetLabelValueSeries 

func (m *LabelValueSeriesCount) GetLabelValueSeries() map[string]uint64

func (*LabelValueSeriesCount) GoString 

func (this *LabelValueSeriesCount) GoString() string

func (*LabelValueSeriesCount) Marshal 

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

func (*LabelValueSeriesCount) MarshalTo 

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

func (*LabelValueSeriesCount) MarshalToSizedBuffer 

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

func (*LabelValueSeriesCount) ProtoMessage 

func (*LabelValueSeriesCount) ProtoMessage()

func (*LabelValueSeriesCount) Reset 

func (m *LabelValueSeriesCount) Reset()

func (*LabelValueSeriesCount) Size 

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

func (*LabelValueSeriesCount) String 

func (this *LabelValueSeriesCount) String() string

func (*LabelValueSeriesCount) Unmarshal 

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

func (*LabelValueSeriesCount) XXX_DiscardUnknown 

func (m *LabelValueSeriesCount) XXX_DiscardUnknown()

func (*LabelValueSeriesCount) XXX_Marshal 

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

func (*LabelValueSeriesCount) XXX_Merge 

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

func (*LabelValueSeriesCount) XXX_Size 

func (m *LabelValueSeriesCount) XXX_Size() int

func (*LabelValueSeriesCount) XXX_Unmarshal 

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

type LabelValues 

type LabelValues struct {
	LabelName string   `protobuf:"bytes,1,opt,name=label_name,json=labelName,proto3" json:"label_name,omitempty"`
	Values    []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
}

func (*LabelValues) Descriptor 

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

func (*LabelValues) Equal 

func (this *LabelValues) Equal(that interface{}) bool

func (*LabelValues) GetLabelName 

func (m *LabelValues) GetLabelName() string

func (*LabelValues) GetValues 

func (m *LabelValues) GetValues() []string

func (*LabelValues) GoString 

func (this *LabelValues) GoString() string

func (*LabelValues) Marshal 

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

func (*LabelValues) MarshalTo 

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

func (*LabelValues) MarshalToSizedBuffer 

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

func (*LabelValues) ProtoMessage 

func (*LabelValues) ProtoMessage()

func (*LabelValues) Reset 

func (m *LabelValues) Reset()

func (*LabelValues) Size 

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

func (*LabelValues) String 

func (this *LabelValues) String() string

func (*LabelValues) Unmarshal 

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

func (*LabelValues) XXX_DiscardUnknown 

func (m *LabelValues) XXX_DiscardUnknown()

func (*LabelValues) XXX_Marshal 

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

func (*LabelValues) XXX_Merge 

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

func (*LabelValues) XXX_Size 

func (m *LabelValues) XXX_Size() int

func (*LabelValues) XXX_Unmarshal 

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

type LabelValuesCardinalityRequest 

type LabelValuesCardinalityRequest struct {
	LabelNames  []string        `protobuf:"bytes,1,rep,name=label_names,json=labelNames,proto3" json:"label_names,omitempty"`
	Matchers    []*LabelMatcher `protobuf:"bytes,2,rep,name=matchers,proto3" json:"matchers,omitempty"`
	CountMethod CountMethod     `protobuf:"varint,3,opt,name=count_method,json=countMethod,proto3,enum=cortex.CountMethod" json:"count_method,omitempty"`
}

func (*LabelValuesCardinalityRequest) Descriptor 

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

func (*LabelValuesCardinalityRequest) Equal 

func (this *LabelValuesCardinalityRequest) Equal(that interface{}) bool

func (*LabelValuesCardinalityRequest) GetCountMethod 

func (m *LabelValuesCardinalityRequest) GetCountMethod() CountMethod

func (*LabelValuesCardinalityRequest) GetLabelNames 

func (m *LabelValuesCardinalityRequest) GetLabelNames() []string

func (*LabelValuesCardinalityRequest) GetMatchers 

func (m *LabelValuesCardinalityRequest) GetMatchers() []*LabelMatcher

func (*LabelValuesCardinalityRequest) GoString 

func (this *LabelValuesCardinalityRequest) GoString() string

func (*LabelValuesCardinalityRequest) Marshal 

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

func (*LabelValuesCardinalityRequest) MarshalTo 

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

func (*LabelValuesCardinalityRequest) MarshalToSizedBuffer 

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

func (*LabelValuesCardinalityRequest) ProtoMessage 

func (*LabelValuesCardinalityRequest) ProtoMessage()

func (*LabelValuesCardinalityRequest) Reset 

func (m *LabelValuesCardinalityRequest) Reset()

func (*LabelValuesCardinalityRequest) Size 

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

func (*LabelValuesCardinalityRequest) String 

func (this *LabelValuesCardinalityRequest) String() string

func (*LabelValuesCardinalityRequest) Unmarshal 

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

func (*LabelValuesCardinalityRequest) XXX_DiscardUnknown 

func (m *LabelValuesCardinalityRequest) XXX_DiscardUnknown()

func (*LabelValuesCardinalityRequest) XXX_Marshal 

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

func (*LabelValuesCardinalityRequest) XXX_Merge 

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

func (*LabelValuesCardinalityRequest) XXX_Size 

func (m *LabelValuesCardinalityRequest) XXX_Size() int

func (*LabelValuesCardinalityRequest) XXX_Unmarshal 

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

type LabelValuesCardinalityResponse 

type LabelValuesCardinalityResponse struct {
	Items []*LabelValueSeriesCount `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
}

func (*LabelValuesCardinalityResponse) Descriptor 

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

func (*LabelValuesCardinalityResponse) Equal 

func (this *LabelValuesCardinalityResponse) Equal(that interface{}) bool

func (*LabelValuesCardinalityResponse) GetItems 

func (m *LabelValuesCardinalityResponse) GetItems() []*LabelValueSeriesCount

func (*LabelValuesCardinalityResponse) GoString 

func (this *LabelValuesCardinalityResponse) GoString() string

func (*LabelValuesCardinalityResponse) Marshal 

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

func (*LabelValuesCardinalityResponse) MarshalTo 

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

func (*LabelValuesCardinalityResponse) MarshalToSizedBuffer 

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

func (*LabelValuesCardinalityResponse) ProtoMessage 

func (*LabelValuesCardinalityResponse) ProtoMessage()

func (*LabelValuesCardinalityResponse) Reset 

func (m *LabelValuesCardinalityResponse) Reset()

func (*LabelValuesCardinalityResponse) Size 

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

func (*LabelValuesCardinalityResponse) String 

func (this *LabelValuesCardinalityResponse) String() string

func (*LabelValuesCardinalityResponse) Unmarshal 

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

func (*LabelValuesCardinalityResponse) XXX_DiscardUnknown 

func (m *LabelValuesCardinalityResponse) XXX_DiscardUnknown()

func (*LabelValuesCardinalityResponse) XXX_Marshal 

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

func (*LabelValuesCardinalityResponse) XXX_Merge 

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

func (*LabelValuesCardinalityResponse) XXX_Size 

func (m *LabelValuesCardinalityResponse) XXX_Size() int

func (*LabelValuesCardinalityResponse) XXX_Unmarshal 

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

type LabelValuesRequest 

type LabelValuesRequest struct {
	LabelName        string         `protobuf:"bytes,1,opt,name=label_name,json=labelName,proto3" json:"label_name,omitempty"`
	StartTimestampMs int64          `protobuf:"varint,2,opt,name=start_timestamp_ms,json=startTimestampMs,proto3" json:"start_timestamp_ms,omitempty"`
	EndTimestampMs   int64          `protobuf:"varint,3,opt,name=end_timestamp_ms,json=endTimestampMs,proto3" json:"end_timestamp_ms,omitempty"`
	Matchers         *LabelMatchers `protobuf:"bytes,4,opt,name=matchers,proto3" json:"matchers,omitempty"`
}

func ToLabelValuesRequest 

func ToLabelValuesRequest(labelName model.LabelName, from, to model.Time, matchers []*labels.Matcher) (*LabelValuesRequest, error)

ToLabelValuesRequest builds a LabelValuesRequest proto

func (*LabelValuesRequest) Descriptor 

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

func (*LabelValuesRequest) Equal 

func (this *LabelValuesRequest) Equal(that interface{}) bool

func (*LabelValuesRequest) GetEndTimestampMs 

func (m *LabelValuesRequest) GetEndTimestampMs() int64

func (*LabelValuesRequest) GetLabelName 

func (m *LabelValuesRequest) GetLabelName() string

func (*LabelValuesRequest) GetMatchers 

func (m *LabelValuesRequest) GetMatchers() *LabelMatchers

func (*LabelValuesRequest) GetStartTimestampMs 

func (m *LabelValuesRequest) GetStartTimestampMs() int64

func (*LabelValuesRequest) GoString 

func (this *LabelValuesRequest) GoString() string

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 

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 (this *LabelValuesRequest) String() string

func (*LabelValuesRequest) Unmarshal 

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

func (*LabelValuesRequest) XXX_DiscardUnknown 

func (m *LabelValuesRequest) XXX_DiscardUnknown()

func (*LabelValuesRequest) XXX_Marshal 

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

func (*LabelValuesRequest) XXX_Merge 

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

func (*LabelValuesRequest) XXX_Size 

func (m *LabelValuesRequest) XXX_Size() int

func (*LabelValuesRequest) XXX_Unmarshal 

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

type LabelValuesResponse 

type LabelValuesResponse struct {
	LabelValues []string `protobuf:"bytes,1,rep,name=label_values,json=labelValues,proto3" json:"label_values,omitempty"`
}

func (*LabelValuesResponse) Descriptor 

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

func (*LabelValuesResponse) Equal 

func (this *LabelValuesResponse) Equal(that interface{}) bool

func (*LabelValuesResponse) GetLabelValues 

func (m *LabelValuesResponse) GetLabelValues() []string

func (*LabelValuesResponse) GoString 

func (this *LabelValuesResponse) GoString() string

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 

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 (this *LabelValuesResponse) String() string

func (*LabelValuesResponse) Unmarshal 

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

func (*LabelValuesResponse) XXX_DiscardUnknown 

func (m *LabelValuesResponse) XXX_DiscardUnknown()

func (*LabelValuesResponse) XXX_Marshal 

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

func (*LabelValuesResponse) XXX_Merge 

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

func (*LabelValuesResponse) XXX_Size 

func (m *LabelValuesResponse) XXX_Size() int

func (*LabelValuesResponse) XXX_Unmarshal 

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

type MatchType 

type MatchType int32
const (
	EQUAL          MatchType = 0
	NOT_EQUAL      MatchType = 1
	REGEX_MATCH    MatchType = 2
	REGEX_NO_MATCH MatchType = 3
)

func (MatchType) EnumDescriptor 

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

func (MatchType) String 

func (x MatchType) String() string

type Metrics 

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

func NewMetrics 

func NewMetrics(reg prometheus.Registerer) *Metrics

type MetricsForLabelMatchersRequest 

type MetricsForLabelMatchersRequest struct {
	StartTimestampMs int64            `protobuf:"varint,1,opt,name=start_timestamp_ms,json=startTimestampMs,proto3" json:"start_timestamp_ms,omitempty"`
	EndTimestampMs   int64            `protobuf:"varint,2,opt,name=end_timestamp_ms,json=endTimestampMs,proto3" json:"end_timestamp_ms,omitempty"`
	MatchersSet      []*LabelMatchers `protobuf:"bytes,3,rep,name=matchers_set,json=matchersSet,proto3" json:"matchers_set,omitempty"`
}

func ToMetricsForLabelMatchersRequest 

func ToMetricsForLabelMatchersRequest(from, to model.Time, matchers []*labels.Matcher) (*MetricsForLabelMatchersRequest, error)

ToMetricsForLabelMatchersRequest builds a MetricsForLabelMatchersRequest proto

func (*MetricsForLabelMatchersRequest) Descriptor 

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

func (*MetricsForLabelMatchersRequest) Equal 

func (this *MetricsForLabelMatchersRequest) Equal(that interface{}) bool

func (*MetricsForLabelMatchersRequest) GetEndTimestampMs 

func (m *MetricsForLabelMatchersRequest) GetEndTimestampMs() int64

func (*MetricsForLabelMatchersRequest) GetMatchersSet 

func (m *MetricsForLabelMatchersRequest) GetMatchersSet() []*LabelMatchers

func (*MetricsForLabelMatchersRequest) GetStartTimestampMs 

func (m *MetricsForLabelMatchersRequest) GetStartTimestampMs() int64

func (*MetricsForLabelMatchersRequest) GoString 

func (this *MetricsForLabelMatchersRequest) GoString() string

func (*MetricsForLabelMatchersRequest) Marshal 

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

func (*MetricsForLabelMatchersRequest) MarshalTo 

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

func (*MetricsForLabelMatchersRequest) MarshalToSizedBuffer 

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

func (*MetricsForLabelMatchersRequest) ProtoMessage 

func (*MetricsForLabelMatchersRequest) ProtoMessage()

func (*MetricsForLabelMatchersRequest) Reset 

func (m *MetricsForLabelMatchersRequest) Reset()

func (*MetricsForLabelMatchersRequest) Size 

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

func (*MetricsForLabelMatchersRequest) String 

func (this *MetricsForLabelMatchersRequest) String() string

func (*MetricsForLabelMatchersRequest) Unmarshal 

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

func (*MetricsForLabelMatchersRequest) XXX_DiscardUnknown 

func (m *MetricsForLabelMatchersRequest) XXX_DiscardUnknown()

func (*MetricsForLabelMatchersRequest) XXX_Marshal 

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

func (*MetricsForLabelMatchersRequest) XXX_Merge 

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

func (*MetricsForLabelMatchersRequest) XXX_Size 

func (m *MetricsForLabelMatchersRequest) XXX_Size() int

func (*MetricsForLabelMatchersRequest) XXX_Unmarshal 

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

type MetricsForLabelMatchersResponse 

type MetricsForLabelMatchersResponse struct {
	Metric []*mimirpb.Metric `protobuf:"bytes,1,rep,name=metric,proto3" json:"metric,omitempty"`
}

func (*MetricsForLabelMatchersResponse) Descriptor 

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

func (*MetricsForLabelMatchersResponse) Equal 

func (this *MetricsForLabelMatchersResponse) Equal(that interface{}) bool

func (*MetricsForLabelMatchersResponse) GetMetric 

func (m *MetricsForLabelMatchersResponse) GetMetric() []*mimirpb.Metric

func (*MetricsForLabelMatchersResponse) GoString 

func (this *MetricsForLabelMatchersResponse) GoString() string

func (*MetricsForLabelMatchersResponse) Marshal 

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

func (*MetricsForLabelMatchersResponse) MarshalTo 

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

func (*MetricsForLabelMatchersResponse) MarshalToSizedBuffer 

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

func (*MetricsForLabelMatchersResponse) ProtoMessage 

func (*MetricsForLabelMatchersResponse) ProtoMessage()

func (*MetricsForLabelMatchersResponse) Reset 

func (m *MetricsForLabelMatchersResponse) Reset()

func (*MetricsForLabelMatchersResponse) Size 

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

func (*MetricsForLabelMatchersResponse) String 

func (this *MetricsForLabelMatchersResponse) String() string

func (*MetricsForLabelMatchersResponse) Unmarshal 

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

func (*MetricsForLabelMatchersResponse) XXX_DiscardUnknown 

func (m *MetricsForLabelMatchersResponse) XXX_DiscardUnknown()

func (*MetricsForLabelMatchersResponse) XXX_Marshal 

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

func (*MetricsForLabelMatchersResponse) XXX_Merge 

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

func (*MetricsForLabelMatchersResponse) XXX_Size 

func (m *MetricsForLabelMatchersResponse) XXX_Size() int

func (*MetricsForLabelMatchersResponse) XXX_Unmarshal 

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

type MetricsMetadataRequest 

type MetricsMetadataRequest struct {
	Limit          int32  `protobuf:"zigzag32,1,opt,name=limit,proto3" json:"limit,omitempty"`
	LimitPerMetric int32  `protobuf:"zigzag32,2,opt,name=limit_per_metric,json=limitPerMetric,proto3" json:"limit_per_metric,omitempty"`
	Metric         string `protobuf:"bytes,3,opt,name=metric,proto3" json:"metric,omitempty"`
}

func DefaultMetricsMetadataRequest 

func DefaultMetricsMetadataRequest() *MetricsMetadataRequest

DefaultMetricsMetadataRequest initialises MetricsMetadataRequest with default values equivalent to no limits and no filtering.

func (*MetricsMetadataRequest) Descriptor 

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

func (*MetricsMetadataRequest) Equal 

func (this *MetricsMetadataRequest) Equal(that interface{}) bool

func (*MetricsMetadataRequest) GetLimit 

func (m *MetricsMetadataRequest) GetLimit() int32

func (*MetricsMetadataRequest) GetLimitPerMetric 

func (m *MetricsMetadataRequest) GetLimitPerMetric() int32

func (*MetricsMetadataRequest) GetMetric 

func (m *MetricsMetadataRequest) GetMetric() string

func (*MetricsMetadataRequest) GoString 

func (this *MetricsMetadataRequest) GoString() string

func (*MetricsMetadataRequest) Marshal 

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

func (*MetricsMetadataRequest) MarshalTo 

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

func (*MetricsMetadataRequest) MarshalToSizedBuffer 

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

func (*MetricsMetadataRequest) ProtoMessage 

func (*MetricsMetadataRequest) ProtoMessage()

func (*MetricsMetadataRequest) Reset 

func (m *MetricsMetadataRequest) Reset()

func (*MetricsMetadataRequest) Size 

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

func (*MetricsMetadataRequest) String 

func (this *MetricsMetadataRequest) String() string

func (*MetricsMetadataRequest) Unmarshal 

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

func (*MetricsMetadataRequest) XXX_DiscardUnknown 

func (m *MetricsMetadataRequest) XXX_DiscardUnknown()

func (*MetricsMetadataRequest) XXX_Marshal 

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

func (*MetricsMetadataRequest) XXX_Merge 

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

func (*MetricsMetadataRequest) XXX_Size 

func (m *MetricsMetadataRequest) XXX_Size() int

func (*MetricsMetadataRequest) XXX_Unmarshal 

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

type MetricsMetadataResponse 

type MetricsMetadataResponse struct {
	Metadata []*mimirpb.MetricMetadata `protobuf:"bytes,1,rep,name=metadata,proto3" json:"metadata,omitempty"`
}

func (*MetricsMetadataResponse) Descriptor 

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

func (*MetricsMetadataResponse) Equal 

func (this *MetricsMetadataResponse) Equal(that interface{}) bool

func (*MetricsMetadataResponse) GetMetadata 

func (m *MetricsMetadataResponse) GetMetadata() []*mimirpb.MetricMetadata

func (*MetricsMetadataResponse) GoString 

func (this *MetricsMetadataResponse) GoString() string

func (*MetricsMetadataResponse) Marshal 

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

func (*MetricsMetadataResponse) MarshalTo 

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

func (*MetricsMetadataResponse) MarshalToSizedBuffer 

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

func (*MetricsMetadataResponse) ProtoMessage 

func (*MetricsMetadataResponse) ProtoMessage()

func (*MetricsMetadataResponse) Reset 

func (m *MetricsMetadataResponse) Reset()

func (*MetricsMetadataResponse) Size 

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

func (*MetricsMetadataResponse) String 

func (this *MetricsMetadataResponse) String() string

func (*MetricsMetadataResponse) Unmarshal 

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

func (*MetricsMetadataResponse) XXX_DiscardUnknown 

func (m *MetricsMetadataResponse) XXX_DiscardUnknown()

func (*MetricsMetadataResponse) XXX_Marshal 

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

func (*MetricsMetadataResponse) XXX_Merge 

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

func (*MetricsMetadataResponse) XXX_Size 

func (m *MetricsMetadataResponse) XXX_Size() int

func (*MetricsMetadataResponse) XXX_Unmarshal 

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

type QueryRequest 

type QueryRequest struct {
	StartTimestampMs int64           `protobuf:"varint,1,opt,name=start_timestamp_ms,json=startTimestampMs,proto3" json:"start_timestamp_ms,omitempty"`
	EndTimestampMs   int64           `protobuf:"varint,2,opt,name=end_timestamp_ms,json=endTimestampMs,proto3" json:"end_timestamp_ms,omitempty"`
	Matchers         []*LabelMatcher `protobuf:"bytes,3,rep,name=matchers,proto3" json:"matchers,omitempty"`
	// Why 100? This QueryRequest message is also used for remote read requests, so we need to avoid any field numbers added in the future.
	StreamingChunksBatchSize uint64 `` /* 140-byte string literal not displayed */
}

func ToQueryRequest 

func ToQueryRequest(from, to model.Time, matchers []*labels.Matcher) (*QueryRequest, error)

ToQueryRequest builds a QueryRequest proto.

func (*QueryRequest) Descriptor 

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

func (*QueryRequest) Equal 

func (this *QueryRequest) Equal(that interface{}) bool

func (*QueryRequest) GetEndTimestampMs 

func (m *QueryRequest) GetEndTimestampMs() int64

func (*QueryRequest) GetMatchers 

func (m *QueryRequest) GetMatchers() []*LabelMatcher

func (*QueryRequest) GetStartTimestampMs 

func (m *QueryRequest) GetStartTimestampMs() int64

func (*QueryRequest) GetStreamingChunksBatchSize 

func (m *QueryRequest) GetStreamingChunksBatchSize() uint64

func (*QueryRequest) GoString 

func (this *QueryRequest) GoString() string

func (*QueryRequest) Marshal 

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

func (*QueryRequest) MarshalTo 

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

func (*QueryRequest) MarshalToSizedBuffer 

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

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) Reset 

func (m *QueryRequest) Reset()

func (*QueryRequest) Size 

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

func (*QueryRequest) String 

func (this *QueryRequest) String() string

func (*QueryRequest) Unmarshal 

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

func (*QueryRequest) XXX_DiscardUnknown 

func (m *QueryRequest) XXX_DiscardUnknown()

func (*QueryRequest) XXX_Marshal 

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

func (*QueryRequest) XXX_Merge 

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

func (*QueryRequest) XXX_Size 

func (m *QueryRequest) XXX_Size() int

func (*QueryRequest) XXX_Unmarshal 

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

type QueryResponse 

type QueryResponse struct {
	Timeseries []mimirpb.TimeSeries `protobuf:"bytes,1,rep,name=timeseries,proto3" json:"timeseries"`
}

func (*QueryResponse) Descriptor 

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

func (*QueryResponse) Equal 

func (this *QueryResponse) Equal(that interface{}) bool

func (*QueryResponse) GetTimeseries 

func (m *QueryResponse) GetTimeseries() []mimirpb.TimeSeries

func (*QueryResponse) GoString 

func (this *QueryResponse) GoString() string

func (*QueryResponse) Marshal 

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

func (*QueryResponse) MarshalTo 

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

func (*QueryResponse) MarshalToSizedBuffer 

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

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) Reset 

func (m *QueryResponse) Reset()

func (*QueryResponse) Size 

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

func (*QueryResponse) String 

func (this *QueryResponse) String() string

func (*QueryResponse) Unmarshal 

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

func (*QueryResponse) XXX_DiscardUnknown 

func (m *QueryResponse) XXX_DiscardUnknown()

func (*QueryResponse) XXX_Marshal 

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

func (*QueryResponse) XXX_Merge 

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

func (*QueryResponse) XXX_Size 

func (m *QueryResponse) XXX_Size() int

func (*QueryResponse) XXX_Unmarshal 

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

type QueryStreamResponse 

type QueryStreamResponse struct {
	Chunkseries           []TimeSeriesChunk         `protobuf:"bytes,1,rep,name=chunkseries,proto3" json:"chunkseries"`
	Timeseries            []mimirpb.TimeSeries      `protobuf:"bytes,2,rep,name=timeseries,proto3" json:"timeseries"`
	StreamingSeries       []QueryStreamSeries       `protobuf:"bytes,3,rep,name=streaming_series,json=streamingSeries,proto3" json:"streaming_series"`
	IsEndOfSeriesStream   bool                      `protobuf:"varint,4,opt,name=is_end_of_series_stream,json=isEndOfSeriesStream,proto3" json:"is_end_of_series_stream,omitempty"`
	StreamingSeriesChunks []QueryStreamSeriesChunks `protobuf:"bytes,5,rep,name=streaming_series_chunks,json=streamingSeriesChunks,proto3" json:"streaming_series_chunks"`
}

If streaming chunks is not enabled with prefer_streaming_chunks: QueryStreamResponse contains a batch of timeseries chunks or timeseries. Only one of these fields will be populated.

If streaming chunks is enabled with prefer_streaming_chunks: QueryStreamResponse contains either: - a batch of series labels (sorted in series order), with is_end_of_series_stream=true for the last batch or - a batch of chunks (sorted in series order).

Only one of these two options will be populated.

func (*QueryStreamResponse) Descriptor 

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

func (*QueryStreamResponse) Equal 

func (this *QueryStreamResponse) Equal(that interface{}) bool

func (*QueryStreamResponse) GetChunkseries 

func (m *QueryStreamResponse) GetChunkseries() []TimeSeriesChunk

func (*QueryStreamResponse) GetIsEndOfSeriesStream 

func (m *QueryStreamResponse) GetIsEndOfSeriesStream() bool

func (*QueryStreamResponse) GetStreamingSeries 

func (m *QueryStreamResponse) GetStreamingSeries() []QueryStreamSeries

func (*QueryStreamResponse) GetStreamingSeriesChunks 

func (m *QueryStreamResponse) GetStreamingSeriesChunks() []QueryStreamSeriesChunks

func (*QueryStreamResponse) GetTimeseries 

func (m *QueryStreamResponse) GetTimeseries() []mimirpb.TimeSeries

func (*QueryStreamResponse) GoString 

func (this *QueryStreamResponse) GoString() string

func (*QueryStreamResponse) Marshal 

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

func (*QueryStreamResponse) MarshalTo 

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

func (*QueryStreamResponse) MarshalToSizedBuffer 

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

func (*QueryStreamResponse) ProtoMessage 

func (*QueryStreamResponse) ProtoMessage()

func (*QueryStreamResponse) Reset 

func (m *QueryStreamResponse) Reset()

func (*QueryStreamResponse) Size 

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

func (*QueryStreamResponse) String 

func (this *QueryStreamResponse) String() string

func (*QueryStreamResponse) Unmarshal 

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

func (*QueryStreamResponse) XXX_DiscardUnknown 

func (m *QueryStreamResponse) XXX_DiscardUnknown()

func (*QueryStreamResponse) XXX_Marshal 

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

func (*QueryStreamResponse) XXX_Merge 

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

func (*QueryStreamResponse) XXX_Size 

func (m *QueryStreamResponse) XXX_Size() int

func (*QueryStreamResponse) XXX_Unmarshal 

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

type QueryStreamSeries 

type QueryStreamSeries struct {
	Labels     []github_com_grafana_mimir_pkg_mimirpb.LabelAdapter `protobuf:"bytes,1,rep,name=labels,proto3,customtype=github.com/grafana/mimir/pkg/mimirpb.LabelAdapter" json:"labels"`
	ChunkCount int64                                               `protobuf:"varint,2,opt,name=chunk_count,json=chunkCount,proto3" json:"chunk_count,omitempty"`
}

func (*QueryStreamSeries) Descriptor 

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

func (*QueryStreamSeries) Equal 

func (this *QueryStreamSeries) Equal(that interface{}) bool

func (*QueryStreamSeries) GetChunkCount 

func (m *QueryStreamSeries) GetChunkCount() int64

func (*QueryStreamSeries) GoString 

func (this *QueryStreamSeries) GoString() string

func (*QueryStreamSeries) Marshal 

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

func (*QueryStreamSeries) MarshalTo 

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

func (*QueryStreamSeries) MarshalToSizedBuffer 

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

func (*QueryStreamSeries) ProtoMessage 

func (*QueryStreamSeries) ProtoMessage()

func (*QueryStreamSeries) Reset 

func (m *QueryStreamSeries) Reset()

func (*QueryStreamSeries) Size 

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

func (*QueryStreamSeries) String 

func (this *QueryStreamSeries) String() string

func (*QueryStreamSeries) Unmarshal 

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

func (*QueryStreamSeries) XXX_DiscardUnknown 

func (m *QueryStreamSeries) XXX_DiscardUnknown()

func (*QueryStreamSeries) XXX_Marshal 

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

func (*QueryStreamSeries) XXX_Merge 

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

func (*QueryStreamSeries) XXX_Size 

func (m *QueryStreamSeries) XXX_Size() int

func (*QueryStreamSeries) XXX_Unmarshal 

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

type QueryStreamSeriesChunks 

type QueryStreamSeriesChunks struct {
	SeriesIndex uint64  `protobuf:"varint,1,opt,name=series_index,json=seriesIndex,proto3" json:"series_index,omitempty"`
	Chunks      []Chunk `protobuf:"bytes,2,rep,name=chunks,proto3" json:"chunks"`
}

func (*QueryStreamSeriesChunks) Descriptor 

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

func (*QueryStreamSeriesChunks) Equal 

func (this *QueryStreamSeriesChunks) Equal(that interface{}) bool

func (*QueryStreamSeriesChunks) GetChunks 

func (m *QueryStreamSeriesChunks) GetChunks() []Chunk

func (*QueryStreamSeriesChunks) GetSeriesIndex 

func (m *QueryStreamSeriesChunks) GetSeriesIndex() uint64

func (*QueryStreamSeriesChunks) GoString 

func (this *QueryStreamSeriesChunks) GoString() string

func (*QueryStreamSeriesChunks) Marshal 

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

func (*QueryStreamSeriesChunks) MarshalTo 

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

func (*QueryStreamSeriesChunks) MarshalToSizedBuffer 

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

func (*QueryStreamSeriesChunks) ProtoMessage 

func (*QueryStreamSeriesChunks) ProtoMessage()

func (*QueryStreamSeriesChunks) Reset 

func (m *QueryStreamSeriesChunks) Reset()

func (*QueryStreamSeriesChunks) Size 

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

func (*QueryStreamSeriesChunks) String 

func (this *QueryStreamSeriesChunks) String() string

func (*QueryStreamSeriesChunks) Unmarshal 

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

func (*QueryStreamSeriesChunks) XXX_DiscardUnknown 

func (m *QueryStreamSeriesChunks) XXX_DiscardUnknown()

func (*QueryStreamSeriesChunks) XXX_Marshal 

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

func (*QueryStreamSeriesChunks) XXX_Merge 

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

func (*QueryStreamSeriesChunks) XXX_Size 

func (m *QueryStreamSeriesChunks) XXX_Size() int

func (*QueryStreamSeriesChunks) XXX_Unmarshal 

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

type ReadRequest 

type ReadRequest struct {
	Queries               []*QueryRequest            `protobuf:"bytes,1,rep,name=queries,proto3" json:"queries,omitempty"`
	AcceptedResponseTypes []ReadRequest_ResponseType `` /* 171-byte string literal not displayed */
}

func (*ReadRequest) Descriptor 

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

func (*ReadRequest) Equal 

func (this *ReadRequest) Equal(that interface{}) bool

func (*ReadRequest) GetAcceptedResponseTypes 

func (m *ReadRequest) GetAcceptedResponseTypes() []ReadRequest_ResponseType

func (*ReadRequest) GetQueries 

func (m *ReadRequest) GetQueries() []*QueryRequest

func (*ReadRequest) GoString 

func (this *ReadRequest) GoString() string

func (*ReadRequest) Marshal 

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

func (*ReadRequest) MarshalTo 

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

func (*ReadRequest) MarshalToSizedBuffer 

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

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) Reset 

func (m *ReadRequest) Reset()

func (*ReadRequest) Size 

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

func (*ReadRequest) String 

func (this *ReadRequest) String() string

func (*ReadRequest) Unmarshal 

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

func (*ReadRequest) XXX_DiscardUnknown 

func (m *ReadRequest) XXX_DiscardUnknown()

func (*ReadRequest) XXX_Marshal 

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

func (*ReadRequest) XXX_Merge 

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

func (*ReadRequest) XXX_Size 

func (m *ReadRequest) XXX_Size() int

func (*ReadRequest) XXX_Unmarshal 

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

type ReadRequest_ResponseType 

type ReadRequest_ResponseType int32
const (
	SAMPLES             ReadRequest_ResponseType = 0
	STREAMED_XOR_CHUNKS ReadRequest_ResponseType = 1
)

func (ReadRequest_ResponseType) EnumDescriptor 

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

func (ReadRequest_ResponseType) String 

func (x ReadRequest_ResponseType) String() string

type ReadResponse 

type ReadResponse struct {
	Results []*QueryResponse `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
}

func (*ReadResponse) Descriptor 

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

func (*ReadResponse) Equal 

func (this *ReadResponse) Equal(that interface{}) bool

func (*ReadResponse) GetResults 

func (m *ReadResponse) GetResults() []*QueryResponse

func (*ReadResponse) GoString 

func (this *ReadResponse) GoString() string

func (*ReadResponse) Marshal 

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

func (*ReadResponse) MarshalTo 

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

func (*ReadResponse) MarshalToSizedBuffer 

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

func (*ReadResponse) ProtoMessage 

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) Reset 

func (m *ReadResponse) Reset()

func (*ReadResponse) Size 

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

func (*ReadResponse) String 

func (this *ReadResponse) String() string

func (*ReadResponse) Unmarshal 

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

func (*ReadResponse) XXX_DiscardUnknown 

func (m *ReadResponse) XXX_DiscardUnknown()

func (*ReadResponse) XXX_Marshal 

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

func (*ReadResponse) XXX_Merge 

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

func (*ReadResponse) XXX_Size 

func (m *ReadResponse) XXX_Size() int

func (*ReadResponse) XXX_Unmarshal 

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

type SeriesChunksStreamReader 

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

SeriesChunksStreamReader is responsible for managing the streaming of chunks from an ingester and buffering chunks in memory until they are consumed by the PromQL engine.

func NewSeriesChunksStreamReader 

func NewSeriesChunksStreamReader(ctx context.Context, client Ingester_QueryStreamClient, expectedSeriesCount int, queryLimiter *limiter.QueryLimiter, cleanup func(), log log.Logger) *SeriesChunksStreamReader

func (*SeriesChunksStreamReader) Close 

func (s *SeriesChunksStreamReader) Close()

Close cleans up all resources associated with this SeriesChunksStreamReader. This method should only be directly called if StartBuffering is not called, otherwise StartBuffering will call it once done.

func (*SeriesChunksStreamReader) GetChunks 

func (s *SeriesChunksStreamReader) GetChunks(seriesIndex uint64) (_ []Chunk, err error)

GetChunks returns the chunks for the series with index seriesIndex. This method must be called with monotonically increasing values of seriesIndex.

func (*SeriesChunksStreamReader) StartBuffering 

func (s *SeriesChunksStreamReader) StartBuffering()

StartBuffering begins streaming series' chunks from the ingester associated with this SeriesChunksStreamReader. Once all series have been consumed with GetChunks, all resources associated with this SeriesChunksStreamReader are cleaned up. If an error occurs while streaming, a subsequent call to GetChunks will return an error. To cancel buffering, cancel the context associated with this SeriesChunksStreamReader's client.Ingester_QueryStreamClient.

type StreamChunk 

type StreamChunk struct {
	MinTimeMs int64                                                `protobuf:"varint,1,opt,name=min_time_ms,json=minTimeMs,proto3" json:"min_time_ms,omitempty"`
	MaxTimeMs int64                                                `protobuf:"varint,2,opt,name=max_time_ms,json=maxTimeMs,proto3" json:"max_time_ms,omitempty"`
	Type      StreamChunk_Encoding                                 `protobuf:"varint,3,opt,name=type,proto3,enum=cortex.StreamChunk_Encoding" json:"type,omitempty"`
	Data      github_com_grafana_mimir_pkg_mimirpb.UnsafeByteSlice `protobuf:"bytes,4,opt,name=data,proto3,customtype=github.com/grafana/mimir/pkg/mimirpb.UnsafeByteSlice" json:"data"`
}

func (*StreamChunk) Descriptor 

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

func (*StreamChunk) Equal 

func (this *StreamChunk) Equal(that interface{}) bool

func (*StreamChunk) GetMaxTimeMs 

func (m *StreamChunk) GetMaxTimeMs() int64

func (*StreamChunk) GetMinTimeMs 

func (m *StreamChunk) GetMinTimeMs() int64

func (*StreamChunk) GetType 

func (m *StreamChunk) GetType() StreamChunk_Encoding

func (*StreamChunk) GoString 

func (this *StreamChunk) GoString() string

func (*StreamChunk) Marshal 

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

func (*StreamChunk) MarshalTo 

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

func (*StreamChunk) MarshalToSizedBuffer 

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

func (*StreamChunk) ProtoMessage 

func (*StreamChunk) ProtoMessage()

func (*StreamChunk) Reset 

func (m *StreamChunk) Reset()

func (*StreamChunk) Size 

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

func (*StreamChunk) String 

func (this *StreamChunk) String() string

func (*StreamChunk) Unmarshal 

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

func (*StreamChunk) XXX_DiscardUnknown 

func (m *StreamChunk) XXX_DiscardUnknown()

func (*StreamChunk) XXX_Marshal 

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

func (*StreamChunk) XXX_Merge 

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

func (*StreamChunk) XXX_Size 

func (m *StreamChunk) XXX_Size() int

func (*StreamChunk) XXX_Unmarshal 

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

type StreamChunk_Encoding 

type StreamChunk_Encoding int32
const (
	UNKNOWN         StreamChunk_Encoding = 0
	XOR             StreamChunk_Encoding = 1
	HISTOGRAM       StreamChunk_Encoding = 2
	FLOAT_HISTOGRAM StreamChunk_Encoding = 3
)

func (StreamChunk_Encoding) EnumDescriptor 

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

func (StreamChunk_Encoding) String 

func (x StreamChunk_Encoding) String() string

type StreamChunkedSeries 

type StreamChunkedSeries struct {
	Labels []github_com_grafana_mimir_pkg_mimirpb.LabelAdapter `protobuf:"bytes,1,rep,name=labels,proto3,customtype=github.com/grafana/mimir/pkg/mimirpb.LabelAdapter" json:"labels"`
	Chunks []StreamChunk                                       `protobuf:"bytes,2,rep,name=chunks,proto3" json:"chunks"`
}

func (*StreamChunkedSeries) Descriptor 

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

func (*StreamChunkedSeries) Equal 

func (this *StreamChunkedSeries) Equal(that interface{}) bool

func (*StreamChunkedSeries) GetChunks 

func (m *StreamChunkedSeries) GetChunks() []StreamChunk

func (*StreamChunkedSeries) GoString 

func (this *StreamChunkedSeries) GoString() string

func (*StreamChunkedSeries) Marshal 

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

func (*StreamChunkedSeries) MarshalTo 

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

func (*StreamChunkedSeries) MarshalToSizedBuffer 

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

func (*StreamChunkedSeries) ProtoMessage 

func (*StreamChunkedSeries) ProtoMessage()

func (*StreamChunkedSeries) Reset 

func (m *StreamChunkedSeries) Reset()

func (*StreamChunkedSeries) Size 

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

func (*StreamChunkedSeries) String 

func (this *StreamChunkedSeries) String() string

func (*StreamChunkedSeries) Unmarshal 

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

func (*StreamChunkedSeries) XXX_DiscardUnknown 

func (m *StreamChunkedSeries) XXX_DiscardUnknown()

func (*StreamChunkedSeries) XXX_Marshal 

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

func (*StreamChunkedSeries) XXX_Merge 

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

func (*StreamChunkedSeries) XXX_Size 

func (m *StreamChunkedSeries) XXX_Size() int

func (*StreamChunkedSeries) XXX_Unmarshal 

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

type StreamReadResponse 

type StreamReadResponse struct {
	ChunkedSeries []*StreamChunkedSeries `protobuf:"bytes,1,rep,name=chunked_series,json=chunkedSeries,proto3" json:"chunked_series,omitempty"`
	QueryIndex    int64                  `protobuf:"varint,2,opt,name=query_index,json=queryIndex,proto3" json:"query_index,omitempty"`
}

func (*StreamReadResponse) Descriptor 

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

func (*StreamReadResponse) Equal 

func (this *StreamReadResponse) Equal(that interface{}) bool

func (*StreamReadResponse) GetChunkedSeries 

func (m *StreamReadResponse) GetChunkedSeries() []*StreamChunkedSeries

func (*StreamReadResponse) GetQueryIndex 

func (m *StreamReadResponse) GetQueryIndex() int64

func (*StreamReadResponse) GoString 

func (this *StreamReadResponse) GoString() string

func (*StreamReadResponse) Marshal 

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

func (*StreamReadResponse) MarshalTo 

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

func (*StreamReadResponse) MarshalToSizedBuffer 

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

func (*StreamReadResponse) ProtoMessage 

func (*StreamReadResponse) ProtoMessage()

func (*StreamReadResponse) Reset 

func (m *StreamReadResponse) Reset()

func (*StreamReadResponse) Size 

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

func (*StreamReadResponse) String 

func (this *StreamReadResponse) String() string

func (*StreamReadResponse) Unmarshal 

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

func (*StreamReadResponse) XXX_DiscardUnknown 

func (m *StreamReadResponse) XXX_DiscardUnknown()

func (*StreamReadResponse) XXX_Marshal 

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

func (*StreamReadResponse) XXX_Merge 

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

func (*StreamReadResponse) XXX_Size 

func (m *StreamReadResponse) XXX_Size() int

func (*StreamReadResponse) XXX_Unmarshal 

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

type StreamingSeries 

type StreamingSeries struct {
	Labels  labels.Labels
	Sources []StreamingSeriesSource
}

StreamingSeries represents a single series used in evaluation of a query where the chunks for the series are streamed from one or more ingesters.

type StreamingSeriesSource 

type StreamingSeriesSource struct {
	StreamReader *SeriesChunksStreamReader
	SeriesIndex  uint64
}

StreamingSeriesSource holds the relationship between a stream of chunks from a SeriesChunksStreamReader and the expected position of a series' chunks in that stream.

type TimeSeriesChunk 

type TimeSeriesChunk struct {
	FromIngesterId string                                              `protobuf:"bytes,1,opt,name=from_ingester_id,json=fromIngesterId,proto3" json:"from_ingester_id,omitempty"`
	UserId         string                                              `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Labels         []github_com_grafana_mimir_pkg_mimirpb.LabelAdapter `protobuf:"bytes,3,rep,name=labels,proto3,customtype=github.com/grafana/mimir/pkg/mimirpb.LabelAdapter" json:"labels"`
	Chunks         []Chunk                                             `protobuf:"bytes,4,rep,name=chunks,proto3" json:"chunks"`
}

func (*TimeSeriesChunk) Descriptor 

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

func (*TimeSeriesChunk) Equal 

func (this *TimeSeriesChunk) Equal(that interface{}) bool

func (*TimeSeriesChunk) GetChunks 

func (m *TimeSeriesChunk) GetChunks() []Chunk

func (*TimeSeriesChunk) GetFromIngesterId 

func (m *TimeSeriesChunk) GetFromIngesterId() string

func (*TimeSeriesChunk) GetUserId 

func (m *TimeSeriesChunk) GetUserId() string

func (*TimeSeriesChunk) GoString 

func (this *TimeSeriesChunk) GoString() string

func (*TimeSeriesChunk) Marshal 

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

func (*TimeSeriesChunk) MarshalTo 

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

func (*TimeSeriesChunk) MarshalToSizedBuffer 

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

func (*TimeSeriesChunk) ProtoMessage 

func (*TimeSeriesChunk) ProtoMessage()

func (*TimeSeriesChunk) Reset 

func (m *TimeSeriesChunk) Reset()

func (*TimeSeriesChunk) Size 

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

func (*TimeSeriesChunk) String 

func (this *TimeSeriesChunk) String() string

func (*TimeSeriesChunk) Unmarshal 

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

func (*TimeSeriesChunk) XXX_DiscardUnknown 

func (m *TimeSeriesChunk) XXX_DiscardUnknown()

func (*TimeSeriesChunk) XXX_Marshal 

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

func (*TimeSeriesChunk) XXX_Merge 

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

func (*TimeSeriesChunk) XXX_Size 

func (m *TimeSeriesChunk) XXX_Size() int

func (*TimeSeriesChunk) XXX_Unmarshal 

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

type TimeSeriesFile 

type TimeSeriesFile struct {
	FromIngesterId string `protobuf:"bytes,1,opt,name=from_ingester_id,json=fromIngesterId,proto3" json:"from_ingester_id,omitempty"`
	UserId         string `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Filename       string `protobuf:"bytes,3,opt,name=filename,proto3" json:"filename,omitempty"`
	Data           []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
}

func (*TimeSeriesFile) Descriptor 

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

func (*TimeSeriesFile) Equal 

func (this *TimeSeriesFile) Equal(that interface{}) bool

func (*TimeSeriesFile) GetData 

func (m *TimeSeriesFile) GetData() []byte

func (*TimeSeriesFile) GetFilename 

func (m *TimeSeriesFile) GetFilename() string

func (*TimeSeriesFile) GetFromIngesterId 

func (m *TimeSeriesFile) GetFromIngesterId() string

func (*TimeSeriesFile) GetUserId 

func (m *TimeSeriesFile) GetUserId() string

func (*TimeSeriesFile) GoString 

func (this *TimeSeriesFile) GoString() string

func (*TimeSeriesFile) Marshal 

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

func (*TimeSeriesFile) MarshalTo 

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

func (*TimeSeriesFile) MarshalToSizedBuffer 

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

func (*TimeSeriesFile) ProtoMessage 

func (*TimeSeriesFile) ProtoMessage()

func (*TimeSeriesFile) Reset 

func (m *TimeSeriesFile) Reset()

func (*TimeSeriesFile) Size 

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

func (*TimeSeriesFile) String 

func (this *TimeSeriesFile) String() string

func (*TimeSeriesFile) Unmarshal 

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

func (*TimeSeriesFile) XXX_DiscardUnknown 

func (m *TimeSeriesFile) XXX_DiscardUnknown()

func (*TimeSeriesFile) XXX_Marshal 

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

func (*TimeSeriesFile) XXX_Merge 

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

func (*TimeSeriesFile) XXX_Size 

func (m *TimeSeriesFile) XXX_Size() int

func (*TimeSeriesFile) XXX_Unmarshal 

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

type UnimplementedIngesterServer 

type UnimplementedIngesterServer struct {
}

UnimplementedIngesterServer can be embedded to have forward compatible implementations.

func (*UnimplementedIngesterServer) ActiveSeries 

func (*UnimplementedIngesterServer) ActiveSeries(req *ActiveSeriesRequest, srv Ingester_ActiveSeriesServer) error

func (*UnimplementedIngesterServer) AllUserStats 

func (*UnimplementedIngesterServer) AllUserStats(ctx context.Context, req *UserStatsRequest) (*UsersStatsResponse, error)

func (*UnimplementedIngesterServer) LabelNames 

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

func (*UnimplementedIngesterServer) LabelNamesAndValues 

func (*UnimplementedIngesterServer) LabelNamesAndValues(req *LabelNamesAndValuesRequest, srv Ingester_LabelNamesAndValuesServer) error

func (*UnimplementedIngesterServer) LabelValues 

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

func (*UnimplementedIngesterServer) LabelValuesCardinality 

func (*UnimplementedIngesterServer) LabelValuesCardinality(req *LabelValuesCardinalityRequest, srv Ingester_LabelValuesCardinalityServer) error

func (*UnimplementedIngesterServer) MetricsForLabelMatchers 

func (*UnimplementedIngesterServer) MetricsForLabelMatchers(ctx context.Context, req *MetricsForLabelMatchersRequest) (*MetricsForLabelMatchersResponse, error)

func (*UnimplementedIngesterServer) MetricsMetadata 

func (*UnimplementedIngesterServer) MetricsMetadata(ctx context.Context, req *MetricsMetadataRequest) (*MetricsMetadataResponse, error)

func (*UnimplementedIngesterServer) Push 

func (*UnimplementedIngesterServer) Push(ctx context.Context, req *mimirpb.WriteRequest) (*mimirpb.WriteResponse, error)

func (*UnimplementedIngesterServer) QueryExemplars 

func (*UnimplementedIngesterServer) QueryExemplars(ctx context.Context, req *ExemplarQueryRequest) (*ExemplarQueryResponse, error)

func (*UnimplementedIngesterServer) QueryStream 

func (*UnimplementedIngesterServer) QueryStream(req *QueryRequest, srv Ingester_QueryStreamServer) error

func (*UnimplementedIngesterServer) UserStats 

func (*UnimplementedIngesterServer) UserStats(ctx context.Context, req *UserStatsRequest) (*UserStatsResponse, error)

type UserIDStatsResponse 

type UserIDStatsResponse struct {
	UserId string             `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Data   *UserStatsResponse `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func (*UserIDStatsResponse) Descriptor 

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

func (*UserIDStatsResponse) Equal 

func (this *UserIDStatsResponse) Equal(that interface{}) bool

func (*UserIDStatsResponse) GetData 

func (m *UserIDStatsResponse) GetData() *UserStatsResponse

func (*UserIDStatsResponse) GetUserId 

func (m *UserIDStatsResponse) GetUserId() string

func (*UserIDStatsResponse) GoString 

func (this *UserIDStatsResponse) GoString() string

func (*UserIDStatsResponse) Marshal 

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

func (*UserIDStatsResponse) MarshalTo 

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

func (*UserIDStatsResponse) MarshalToSizedBuffer 

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

func (*UserIDStatsResponse) ProtoMessage 

func (*UserIDStatsResponse) ProtoMessage()

func (*UserIDStatsResponse) Reset 

func (m *UserIDStatsResponse) Reset()

func (*UserIDStatsResponse) Size 

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

func (*UserIDStatsResponse) String 

func (this *UserIDStatsResponse) String() string

func (*UserIDStatsResponse) Unmarshal 

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

func (*UserIDStatsResponse) XXX_DiscardUnknown 

func (m *UserIDStatsResponse) XXX_DiscardUnknown()

func (*UserIDStatsResponse) XXX_Marshal 

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

func (*UserIDStatsResponse) XXX_Merge 

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

func (*UserIDStatsResponse) XXX_Size 

func (m *UserIDStatsResponse) XXX_Size() int

func (*UserIDStatsResponse) XXX_Unmarshal 

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

type UserStatsRequest 

type UserStatsRequest struct {
	CountMethod CountMethod `protobuf:"varint,1,opt,name=count_method,json=countMethod,proto3,enum=cortex.CountMethod" json:"count_method,omitempty"`
}

func (*UserStatsRequest) Descriptor 

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

func (*UserStatsRequest) Equal 

func (this *UserStatsRequest) Equal(that interface{}) bool

func (*UserStatsRequest) GetCountMethod 

func (m *UserStatsRequest) GetCountMethod() CountMethod

func (*UserStatsRequest) GoString 

func (this *UserStatsRequest) GoString() string

func (*UserStatsRequest) Marshal 

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

func (*UserStatsRequest) MarshalTo 

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

func (*UserStatsRequest) MarshalToSizedBuffer 

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

func (*UserStatsRequest) ProtoMessage 

func (*UserStatsRequest) ProtoMessage()

func (*UserStatsRequest) Reset 

func (m *UserStatsRequest) Reset()

func (*UserStatsRequest) Size 

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

func (*UserStatsRequest) String 

func (this *UserStatsRequest) String() string

func (*UserStatsRequest) Unmarshal 

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

func (*UserStatsRequest) XXX_DiscardUnknown 

func (m *UserStatsRequest) XXX_DiscardUnknown()

func (*UserStatsRequest) XXX_Marshal 

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

func (*UserStatsRequest) XXX_Merge 

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

func (*UserStatsRequest) XXX_Size 

func (m *UserStatsRequest) XXX_Size() int

func (*UserStatsRequest) XXX_Unmarshal 

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

type UserStatsResponse 

type UserStatsResponse struct {
	IngestionRate     float64 `protobuf:"fixed64,1,opt,name=ingestion_rate,json=ingestionRate,proto3" json:"ingestion_rate,omitempty"`
	NumSeries         uint64  `protobuf:"varint,2,opt,name=num_series,json=numSeries,proto3" json:"num_series,omitempty"`
	ApiIngestionRate  float64 `protobuf:"fixed64,3,opt,name=api_ingestion_rate,json=apiIngestionRate,proto3" json:"api_ingestion_rate,omitempty"`
	RuleIngestionRate float64 `protobuf:"fixed64,4,opt,name=rule_ingestion_rate,json=ruleIngestionRate,proto3" json:"rule_ingestion_rate,omitempty"`
}

func (*UserStatsResponse) Descriptor 

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

func (*UserStatsResponse) Equal 

func (this *UserStatsResponse) Equal(that interface{}) bool

func (*UserStatsResponse) GetApiIngestionRate 

func (m *UserStatsResponse) GetApiIngestionRate() float64

func (*UserStatsResponse) GetIngestionRate 

func (m *UserStatsResponse) GetIngestionRate() float64

func (*UserStatsResponse) GetNumSeries 

func (m *UserStatsResponse) GetNumSeries() uint64

func (*UserStatsResponse) GetRuleIngestionRate 

func (m *UserStatsResponse) GetRuleIngestionRate() float64

func (*UserStatsResponse) GoString 

func (this *UserStatsResponse) GoString() string

func (*UserStatsResponse) Marshal 

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

func (*UserStatsResponse) MarshalTo 

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

func (*UserStatsResponse) MarshalToSizedBuffer 

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

func (*UserStatsResponse) ProtoMessage 

func (*UserStatsResponse) ProtoMessage()

func (*UserStatsResponse) Reset 

func (m *UserStatsResponse) Reset()

func (*UserStatsResponse) Size 

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

func (*UserStatsResponse) String 

func (this *UserStatsResponse) String() string

func (*UserStatsResponse) Unmarshal 

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

func (*UserStatsResponse) XXX_DiscardUnknown 

func (m *UserStatsResponse) XXX_DiscardUnknown()

func (*UserStatsResponse) XXX_Marshal 

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

func (*UserStatsResponse) XXX_Merge 

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

func (*UserStatsResponse) XXX_Size 

func (m *UserStatsResponse) XXX_Size() int

func (*UserStatsResponse) XXX_Unmarshal 

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

type UsersStatsResponse 

type UsersStatsResponse struct {
	Stats []*UserIDStatsResponse `protobuf:"bytes,1,rep,name=stats,proto3" json:"stats,omitempty"`
}

func (*UsersStatsResponse) Descriptor 

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

func (*UsersStatsResponse) Equal 

func (this *UsersStatsResponse) Equal(that interface{}) bool

func (*UsersStatsResponse) GetStats 

func (m *UsersStatsResponse) GetStats() []*UserIDStatsResponse

func (*UsersStatsResponse) GoString 

func (this *UsersStatsResponse) GoString() string

func (*UsersStatsResponse) Marshal 

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

func (*UsersStatsResponse) MarshalTo 

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

func (*UsersStatsResponse) MarshalToSizedBuffer 

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

func (*UsersStatsResponse) ProtoMessage 

func (*UsersStatsResponse) ProtoMessage()

func (*UsersStatsResponse) Reset 

func (m *UsersStatsResponse) Reset()

func (*UsersStatsResponse) Size 

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

func (*UsersStatsResponse) String 

func (this *UsersStatsResponse) String() string

func (*UsersStatsResponse) Unmarshal 

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

func (*UsersStatsResponse) XXX_DiscardUnknown 

func (m *UsersStatsResponse) XXX_DiscardUnknown()

func (*UsersStatsResponse) XXX_Marshal 

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

func (*UsersStatsResponse) XXX_Merge 

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

func (*UsersStatsResponse) XXX_Size 

func (m *UsersStatsResponse) XXX_Size() int

func (*UsersStatsResponse) XXX_Unmarshal 

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

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.