client

package
v0.28.0-rc.0 Latest Latest
Warning

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

 Go to latest Published: Aug 23, 2022 License: Apache-2.0 Imports: 24 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 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,
}

Functions

func FastFingerprint 

func FastFingerprint(ls []cortexpb.LabelAdapter) model.Fingerprint

FastFingerprint runs the same algorithm as Prometheus labelSetToFastFingerprint()

func Fingerprint 

func Fingerprint(labels labels.Labels) model.Fingerprint

Fingerprint runs the same algorithm as Prometheus labelSetToFingerprint()

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 FromLabelValuesRequest 

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

FromLabelValuesRequest unpacks a LabelValuesRequest proto

func FromMetricsForLabelMatchersRequest 

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

FromMetricsForLabelMatchersRequest unpacks a MetricsForLabelMatchersRequest proto

func FromMetricsForLabelMatchersResponse 

func FromMetricsForLabelMatchersResponse(resp *MetricsForLabelMatchersResponse) []model.Metric

FromMetricsForLabelMatchersResponse unpacks a MetricsForLabelMatchersResponse proto

func FromQueryRequest 

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

FromQueryRequest unpacks a QueryRequest proto.

func FromQueryResponse 

func FromQueryResponse(resp *QueryResponse) model.Matrix

FromQueryResponse unpacks a QueryResponse proto.

func HashAdd32 

func HashAdd32(h uint32, s string) uint32

HashAdd32 adds a string to a fnv32 hash value, returning the updated hash. Note this is the same algorithm as Go stdlib `sum32.Write()`

func HashAdd32a 

func HashAdd32a(h uint32, s string) uint32

HashAdd32a adds a string to a fnv32a hash value, returning the updated hash. Note this is the same algorithm as Go stdlib `sum32.Write()`

func HashAddByte32 

func HashAddByte32(h uint32, b byte) uint32

HashAddByte32 adds a byte to a fnv32 hash value, returning the updated hash.

func HashAddByte32a 

func HashAddByte32a(h uint32, b byte) uint32

HashAddByte32a adds a byte to a fnv32a hash value, returning the updated hash.

func HashNew32 

func HashNew32() uint32

HashNew32 initializies a new fnv32 hash value.

func HashNew32a 

func HashNew32a() uint32

HashNew32a initializies a new fnv32a hash value.

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 RegisterIngesterServer 

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

func SendAsBatchToStream 

func SendAsBatchToStream(totalItems int, streamBatchSize int, fn func(start, end int) error) error

func SendLabelNamesStream 

func SendLabelNamesStream(s Ingester_LabelNamesStreamServer, l *LabelNamesStreamResponse) error

func SendLabelValuesStream 

func SendLabelValuesStream(s Ingester_LabelValuesStreamServer, l *LabelValuesStreamResponse) error

func SendMetricsForLabelMatchersStream 

func SendMetricsForLabelMatchersStream(s Ingester_MetricsForLabelMatchersStreamServer, m *MetricsForLabelMatchersStreamResponse) error

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 SendTimeSeriesChunk 

func SendTimeSeriesChunk(s Ingester_TransferChunksClient, m *TimeSeriesChunk) error

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

Types

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             []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Chunk) Descriptor 

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

func (*Chunk) Equal 

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

func (*Chunk) GetData 

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

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 Config 

type Config struct {
	GRPCClientConfig grpcclient.Config `yaml:"grpc_client_config"`
}

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(log log.Logger) 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 []cortexpb.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() []cortexpb.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(addr string, cfg Config) (HealthAndIngesterClient, error)

MakeIngesterClient makes a new IngesterClient

type IngesterClient 

type IngesterClient interface {
	Push(ctx context.Context, in *cortexpb.WriteRequest, opts ...grpc.CallOption) (*cortexpb.WriteResponse, error)
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, 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)
	LabelValuesStream(ctx context.Context, in *LabelValuesRequest, opts ...grpc.CallOption) (Ingester_LabelValuesStreamClient, error)
	LabelNames(ctx context.Context, in *LabelNamesRequest, opts ...grpc.CallOption) (*LabelNamesResponse, error)
	LabelNamesStream(ctx context.Context, in *LabelNamesRequest, opts ...grpc.CallOption) (Ingester_LabelNamesStreamClient, 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)
	MetricsForLabelMatchersStream(ctx context.Context, in *MetricsForLabelMatchersRequest, opts ...grpc.CallOption) (Ingester_MetricsForLabelMatchersStreamClient, error)
	MetricsMetadata(ctx context.Context, in *MetricsMetadataRequest, opts ...grpc.CallOption) (*MetricsMetadataResponse, error)
	// TransferChunks allows leaving ingester (client) to stream chunks directly to joining ingesters (server).
	TransferChunks(ctx context.Context, opts ...grpc.CallOption) (Ingester_TransferChunksClient, 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, *cortexpb.WriteRequest) (*cortexpb.WriteResponse, error)
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
	QueryStream(*QueryRequest, Ingester_QueryStreamServer) error
	QueryExemplars(context.Context, *ExemplarQueryRequest) (*ExemplarQueryResponse, error)
	LabelValues(context.Context, *LabelValuesRequest) (*LabelValuesResponse, error)
	LabelValuesStream(*LabelValuesRequest, Ingester_LabelValuesStreamServer) error
	LabelNames(context.Context, *LabelNamesRequest) (*LabelNamesResponse, error)
	LabelNamesStream(*LabelNamesRequest, Ingester_LabelNamesStreamServer) error
	UserStats(context.Context, *UserStatsRequest) (*UserStatsResponse, error)
	AllUserStats(context.Context, *UserStatsRequest) (*UsersStatsResponse, error)
	MetricsForLabelMatchers(context.Context, *MetricsForLabelMatchersRequest) (*MetricsForLabelMatchersResponse, error)
	MetricsForLabelMatchersStream(*MetricsForLabelMatchersRequest, Ingester_MetricsForLabelMatchersStreamServer) error
	MetricsMetadata(context.Context, *MetricsMetadataRequest) (*MetricsMetadataResponse, error)
	// TransferChunks allows leaving ingester (client) to stream chunks directly to joining ingesters (server).
	TransferChunks(Ingester_TransferChunksServer) error
}

IngesterServer is the server API for Ingester service.

type Ingester_LabelNamesStreamClient 

type Ingester_LabelNamesStreamClient interface {
	Recv() (*LabelNamesStreamResponse, error)
	grpc.ClientStream
}

type Ingester_LabelNamesStreamServer 

type Ingester_LabelNamesStreamServer interface {
	Send(*LabelNamesStreamResponse) error
	grpc.ServerStream
}

type Ingester_LabelValuesStreamClient 

type Ingester_LabelValuesStreamClient interface {
	Recv() (*LabelValuesStreamResponse, error)
	grpc.ClientStream
}

type Ingester_LabelValuesStreamServer 

type Ingester_LabelValuesStreamServer interface {
	Send(*LabelValuesStreamResponse) error
	grpc.ServerStream
}

type Ingester_MetricsForLabelMatchersStreamClient 

type Ingester_MetricsForLabelMatchersStreamClient interface {
	Recv() (*MetricsForLabelMatchersStreamResponse, error)
	grpc.ClientStream
}

type Ingester_MetricsForLabelMatchersStreamServer 

type Ingester_MetricsForLabelMatchersStreamServer interface {
	Send(*MetricsForLabelMatchersStreamResponse) 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 Ingester_TransferChunksClient 

type Ingester_TransferChunksClient interface {
	Send(*TimeSeriesChunk) error
	CloseAndRecv() (*TransferChunksResponse, error)
	grpc.ClientStream
}

type Ingester_TransferChunksServer 

type Ingester_TransferChunksServer interface {
	SendAndClose(*TransferChunksResponse) error
	Recv() (*TimeSeriesChunk, 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 (*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 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"`
}

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) 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 LabelNamesStreamResponse 

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

func (*LabelNamesStreamResponse) Descriptor 

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

func (*LabelNamesStreamResponse) Equal 

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

func (*LabelNamesStreamResponse) GetLabelNames 

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

func (*LabelNamesStreamResponse) GoString 

func (this *LabelNamesStreamResponse) GoString() string

func (*LabelNamesStreamResponse) Marshal 

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

func (*LabelNamesStreamResponse) MarshalTo 

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

func (*LabelNamesStreamResponse) MarshalToSizedBuffer 

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

func (*LabelNamesStreamResponse) ProtoMessage 

func (*LabelNamesStreamResponse) ProtoMessage()

func (*LabelNamesStreamResponse) Reset 

func (m *LabelNamesStreamResponse) Reset()

func (*LabelNamesStreamResponse) Size 

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

func (*LabelNamesStreamResponse) String 

func (this *LabelNamesStreamResponse) String() string

func (*LabelNamesStreamResponse) Unmarshal 

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

func (*LabelNamesStreamResponse) XXX_DiscardUnknown 

func (m *LabelNamesStreamResponse) XXX_DiscardUnknown()

func (*LabelNamesStreamResponse) XXX_Marshal 

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

func (*LabelNamesStreamResponse) XXX_Merge 

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

func (*LabelNamesStreamResponse) XXX_Size 

func (m *LabelNamesStreamResponse) XXX_Size() int

func (*LabelNamesStreamResponse) XXX_Unmarshal 

func (m *LabelNamesStreamResponse) 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 LabelValuesStreamResponse 

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

func (*LabelValuesStreamResponse) Descriptor 

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

func (*LabelValuesStreamResponse) Equal 

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

func (*LabelValuesStreamResponse) GetLabelValues 

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

func (*LabelValuesStreamResponse) GoString 

func (this *LabelValuesStreamResponse) GoString() string

func (*LabelValuesStreamResponse) Marshal 

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

func (*LabelValuesStreamResponse) MarshalTo 

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

func (*LabelValuesStreamResponse) MarshalToSizedBuffer 

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

func (*LabelValuesStreamResponse) ProtoMessage 

func (*LabelValuesStreamResponse) ProtoMessage()

func (*LabelValuesStreamResponse) Reset 

func (m *LabelValuesStreamResponse) Reset()

func (*LabelValuesStreamResponse) Size 

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

func (*LabelValuesStreamResponse) String 

func (this *LabelValuesStreamResponse) String() string

func (*LabelValuesStreamResponse) Unmarshal 

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

func (*LabelValuesStreamResponse) XXX_DiscardUnknown 

func (m *LabelValuesStreamResponse) XXX_DiscardUnknown()

func (*LabelValuesStreamResponse) XXX_Marshal 

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

func (*LabelValuesStreamResponse) XXX_Merge 

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

func (*LabelValuesStreamResponse) XXX_Size 

func (m *LabelValuesStreamResponse) XXX_Size() int

func (*LabelValuesStreamResponse) XXX_Unmarshal 

func (m *LabelValuesStreamResponse) 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 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 []*cortexpb.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() []*cortexpb.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 MetricsForLabelMatchersStreamResponse 

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

func (*MetricsForLabelMatchersStreamResponse) Descriptor 

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

func (*MetricsForLabelMatchersStreamResponse) Equal 

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

func (*MetricsForLabelMatchersStreamResponse) GetMetric 

func (m *MetricsForLabelMatchersStreamResponse) GetMetric() []*cortexpb.Metric

func (*MetricsForLabelMatchersStreamResponse) GoString 

func (this *MetricsForLabelMatchersStreamResponse) GoString() string

func (*MetricsForLabelMatchersStreamResponse) Marshal 

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

func (*MetricsForLabelMatchersStreamResponse) MarshalTo 

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

func (*MetricsForLabelMatchersStreamResponse) MarshalToSizedBuffer 

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

func (*MetricsForLabelMatchersStreamResponse) ProtoMessage 

func (*MetricsForLabelMatchersStreamResponse) ProtoMessage()

func (*MetricsForLabelMatchersStreamResponse) Reset 

func (m *MetricsForLabelMatchersStreamResponse) Reset()

func (*MetricsForLabelMatchersStreamResponse) Size 

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

func (*MetricsForLabelMatchersStreamResponse) String 

func (this *MetricsForLabelMatchersStreamResponse) String() string

func (*MetricsForLabelMatchersStreamResponse) Unmarshal 

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

func (*MetricsForLabelMatchersStreamResponse) XXX_DiscardUnknown 

func (m *MetricsForLabelMatchersStreamResponse) XXX_DiscardUnknown()

func (*MetricsForLabelMatchersStreamResponse) XXX_Marshal 

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

func (*MetricsForLabelMatchersStreamResponse) XXX_Merge 

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

func (*MetricsForLabelMatchersStreamResponse) XXX_Size 

func (m *MetricsForLabelMatchersStreamResponse) XXX_Size() int

func (*MetricsForLabelMatchersStreamResponse) XXX_Unmarshal 

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

type MetricsMetadataRequest 

type MetricsMetadataRequest struct {
}

func (*MetricsMetadataRequest) Descriptor 

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

func (*MetricsMetadataRequest) Equal 

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

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 []*cortexpb.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() []*cortexpb.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"`
}

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) 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 []cortexpb.TimeSeries `protobuf:"bytes,1,rep,name=timeseries,proto3" json:"timeseries"`
}

func ToQueryResponse 

func ToQueryResponse(matrix model.Matrix) *QueryResponse

ToQueryResponse builds a QueryResponse proto.

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() []cortexpb.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  []cortexpb.TimeSeries `protobuf:"bytes,2,rep,name=timeseries,proto3" json:"timeseries"`
}

QueryStreamResponse contains a batch of timeseries chunks or timeseries. Only one of these series will be populated.

func (*QueryStreamResponse) ChunksCount 

func (m *QueryStreamResponse) ChunksCount() int

ChunksCount returns the number of chunks in response.

func (*QueryStreamResponse) ChunksSize 

func (m *QueryStreamResponse) ChunksSize() int

ChunksSize returns the size of all chunks in the response.

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) GetTimeseries 

func (m *QueryStreamResponse) GetTimeseries() []cortexpb.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 ReadRequest 

type ReadRequest struct {
	Queries []*QueryRequest `protobuf:"bytes,1,rep,name=queries,proto3" json:"queries,omitempty"`
}

func (*ReadRequest) Descriptor 

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

func (*ReadRequest) Equal 

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

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 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 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_cortexproject_cortex_pkg_cortexpb.LabelAdapter `` /* 132-byte string literal not displayed */
	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 TransferChunksResponse 

type TransferChunksResponse struct {
}

func (*TransferChunksResponse) Descriptor 

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

func (*TransferChunksResponse) Equal 

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

func (*TransferChunksResponse) GoString 

func (this *TransferChunksResponse) GoString() string

func (*TransferChunksResponse) Marshal 

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

func (*TransferChunksResponse) MarshalTo 

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

func (*TransferChunksResponse) MarshalToSizedBuffer 

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

func (*TransferChunksResponse) ProtoMessage 

func (*TransferChunksResponse) ProtoMessage()

func (*TransferChunksResponse) Reset 

func (m *TransferChunksResponse) Reset()

func (*TransferChunksResponse) Size 

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

func (*TransferChunksResponse) String 

func (this *TransferChunksResponse) String() string

func (*TransferChunksResponse) Unmarshal 

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

func (*TransferChunksResponse) XXX_DiscardUnknown 

func (m *TransferChunksResponse) XXX_DiscardUnknown()

func (*TransferChunksResponse) XXX_Marshal 

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

func (*TransferChunksResponse) XXX_Merge 

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

func (*TransferChunksResponse) XXX_Size 

func (m *TransferChunksResponse) XXX_Size() int

func (*TransferChunksResponse) XXX_Unmarshal 

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

type UnimplementedIngesterServer 

type UnimplementedIngesterServer struct {
}

UnimplementedIngesterServer can be embedded to have forward compatible implementations.

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) LabelNamesStream 

func (*UnimplementedIngesterServer) LabelNamesStream(req *LabelNamesRequest, srv Ingester_LabelNamesStreamServer) error

func (*UnimplementedIngesterServer) LabelValues 

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

func (*UnimplementedIngesterServer) LabelValuesStream 

func (*UnimplementedIngesterServer) LabelValuesStream(req *LabelValuesRequest, srv Ingester_LabelValuesStreamServer) error

func (*UnimplementedIngesterServer) MetricsForLabelMatchers 

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

func (*UnimplementedIngesterServer) MetricsForLabelMatchersStream 

func (*UnimplementedIngesterServer) MetricsForLabelMatchersStream(req *MetricsForLabelMatchersRequest, srv Ingester_MetricsForLabelMatchersStreamServer) error

func (*UnimplementedIngesterServer) MetricsMetadata 

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

func (*UnimplementedIngesterServer) Push 

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

func (*UnimplementedIngesterServer) Query 

func (*UnimplementedIngesterServer) Query(ctx context.Context, req *QueryRequest) (*QueryResponse, 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) TransferChunks 

func (*UnimplementedIngesterServer) TransferChunks(srv Ingester_TransferChunksServer) 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 {
}

func (*UserStatsRequest) Descriptor 

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

func (*UserStatsRequest) Equal 

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

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.