client

package
v1.15.2 Latest Latest
Warning

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

Go to latest
Published: May 10, 2023 License: Apache-2.0 Imports: 25 Imported by: 53

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 FromExemplarQueryRequest added in v1.10.0

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

FromExemplarQueryRequest unpacks a ExemplarQueryRequest proto.

func FromLabelMatchers added in v1.10.0

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

func FromLabelValuesRequest added in v1.8.0

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 HashAddByte32 added in v1.1.0

func HashAddByte32(h uint32, b byte) uint32

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

func HashNew32

func HashNew32() uint32

HashNew32 initializies a new fnv32 hash value.

func LabelsToKeyString added in v1.4.0

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

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

func SendLabelNamesStream added in v1.13.0

func SendLabelValuesStream added in v1.13.0

func SendQueryStream added in v1.0.0

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

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

func (*Chunk) ProtoMessage

func (*Chunk) ProtoMessage()

func (*Chunk) Reset

func (m *Chunk) Reset()

func (*Chunk) Size

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

func (*Chunk) String

func (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 added in v1.3.0

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

type ExemplarQueryRequest added in v1.10.0

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 added in v1.10.0

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

ToExemplarQueryRequest builds an ExemplarQueryRequest proto.

func (*ExemplarQueryRequest) Descriptor added in v1.10.0

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

func (*ExemplarQueryRequest) Equal added in v1.10.0

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

func (*ExemplarQueryRequest) GetEndTimestampMs added in v1.10.0

func (m *ExemplarQueryRequest) GetEndTimestampMs() int64

func (*ExemplarQueryRequest) GetMatchers added in v1.10.0

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

func (*ExemplarQueryRequest) GetStartTimestampMs added in v1.10.0

func (m *ExemplarQueryRequest) GetStartTimestampMs() int64

func (*ExemplarQueryRequest) GoString added in v1.10.0

func (this *ExemplarQueryRequest) GoString() string

func (*ExemplarQueryRequest) Marshal added in v1.10.0

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

func (*ExemplarQueryRequest) MarshalTo added in v1.10.0

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

func (*ExemplarQueryRequest) MarshalToSizedBuffer added in v1.10.0

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

func (*ExemplarQueryRequest) ProtoMessage added in v1.10.0

func (*ExemplarQueryRequest) ProtoMessage()

func (*ExemplarQueryRequest) Reset added in v1.10.0

func (m *ExemplarQueryRequest) Reset()

func (*ExemplarQueryRequest) Size added in v1.10.0

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

func (*ExemplarQueryRequest) String added in v1.10.0

func (this *ExemplarQueryRequest) String() string

func (*ExemplarQueryRequest) Unmarshal added in v1.10.0

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

func (*ExemplarQueryRequest) XXX_DiscardUnknown added in v1.10.0

func (m *ExemplarQueryRequest) XXX_DiscardUnknown()

func (*ExemplarQueryRequest) XXX_Marshal added in v1.10.0

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

func (*ExemplarQueryRequest) XXX_Merge added in v1.10.0

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

func (*ExemplarQueryRequest) XXX_Size added in v1.10.0

func (m *ExemplarQueryRequest) XXX_Size() int

func (*ExemplarQueryRequest) XXX_Unmarshal added in v1.10.0

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

type ExemplarQueryResponse added in v1.10.0

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

func (*ExemplarQueryResponse) Descriptor added in v1.10.0

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

func (*ExemplarQueryResponse) Equal added in v1.10.0

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

func (*ExemplarQueryResponse) GetTimeseries added in v1.10.0

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

func (*ExemplarQueryResponse) GoString added in v1.10.0

func (this *ExemplarQueryResponse) GoString() string

func (*ExemplarQueryResponse) Marshal added in v1.10.0

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

func (*ExemplarQueryResponse) MarshalTo added in v1.10.0

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

func (*ExemplarQueryResponse) MarshalToSizedBuffer added in v1.10.0

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

func (*ExemplarQueryResponse) ProtoMessage added in v1.10.0

func (*ExemplarQueryResponse) ProtoMessage()

func (*ExemplarQueryResponse) Reset added in v1.10.0

func (m *ExemplarQueryResponse) Reset()

func (*ExemplarQueryResponse) Size added in v1.10.0

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

func (*ExemplarQueryResponse) String added in v1.10.0

func (this *ExemplarQueryResponse) String() string

func (*ExemplarQueryResponse) Unmarshal added in v1.10.0

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

func (*ExemplarQueryResponse) XXX_DiscardUnknown added in v1.10.0

func (m *ExemplarQueryResponse) XXX_DiscardUnknown()

func (*ExemplarQueryResponse) XXX_Marshal added in v1.10.0

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

func (*ExemplarQueryResponse) XXX_Merge added in v1.10.0

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

func (*ExemplarQueryResponse) XXX_Size added in v1.10.0

func (m *ExemplarQueryResponse) XXX_Size() int

func (*ExemplarQueryResponse) XXX_Unmarshal added in v1.10.0

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

type HealthAndIngesterClient

type HealthAndIngesterClient interface {
	IngesterClient
	grpc_health_v1.HealthClient
	Close() error
	PushPreAlloc(ctx context.Context, in *cortexpb.PreallocWriteRequest, opts ...grpc.CallOption) (*cortexpb.WriteResponse, 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)
}

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 Ingester_LabelNamesStreamClient added in v1.13.0

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

type Ingester_LabelNamesStreamServer added in v1.13.0

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

type Ingester_LabelValuesStreamClient added in v1.13.0

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

type Ingester_LabelValuesStreamServer added in v1.13.0

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

type Ingester_MetricsForLabelMatchersStreamClient added in v1.13.0

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

type Ingester_MetricsForLabelMatchersStreamServer added in v1.13.0

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

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

func (*LabelMatcher) ProtoMessage

func (*LabelMatcher) ProtoMessage()

func (*LabelMatcher) Reset

func (m *LabelMatcher) Reset()

func (*LabelMatcher) Size

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

func (*LabelMatcher) String

func (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 added in v0.7.0

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 added in v1.6.0

func (m *LabelNamesRequest) GetEndTimestampMs() int64

func (*LabelNamesRequest) GetStartTimestampMs added in v1.6.0

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

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

func (*LabelNamesRequest) ProtoMessage

func (*LabelNamesRequest) ProtoMessage()

func (*LabelNamesRequest) Reset

func (m *LabelNamesRequest) Reset()

func (*LabelNamesRequest) Size

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

func (*LabelNamesRequest) String

func (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 added in v0.7.0

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

func (*LabelNamesResponse) ProtoMessage

func (*LabelNamesResponse) ProtoMessage()

func (*LabelNamesResponse) Reset

func (m *LabelNamesResponse) Reset()

func (*LabelNamesResponse) Size

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

func (*LabelNamesResponse) String

func (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 added in v1.13.0

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

func (*LabelNamesStreamResponse) Descriptor added in v1.13.0

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

func (*LabelNamesStreamResponse) Equal added in v1.13.0

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

func (*LabelNamesStreamResponse) GetLabelNames added in v1.13.0

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

func (*LabelNamesStreamResponse) GoString added in v1.13.0

func (this *LabelNamesStreamResponse) GoString() string

func (*LabelNamesStreamResponse) Marshal added in v1.13.0

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

func (*LabelNamesStreamResponse) MarshalTo added in v1.13.0

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

func (*LabelNamesStreamResponse) MarshalToSizedBuffer added in v1.13.0

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

func (*LabelNamesStreamResponse) ProtoMessage added in v1.13.0

func (*LabelNamesStreamResponse) ProtoMessage()

func (*LabelNamesStreamResponse) Reset added in v1.13.0

func (m *LabelNamesStreamResponse) Reset()

func (*LabelNamesStreamResponse) Size added in v1.13.0

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

func (*LabelNamesStreamResponse) String added in v1.13.0

func (this *LabelNamesStreamResponse) String() string

func (*LabelNamesStreamResponse) Unmarshal added in v1.13.0

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

func (*LabelNamesStreamResponse) XXX_DiscardUnknown added in v1.13.0

func (m *LabelNamesStreamResponse) XXX_DiscardUnknown()

func (*LabelNamesStreamResponse) XXX_Marshal added in v1.13.0

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

func (*LabelNamesStreamResponse) XXX_Merge added in v1.13.0

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

func (*LabelNamesStreamResponse) XXX_Size added in v1.13.0

func (m *LabelNamesStreamResponse) XXX_Size() int

func (*LabelNamesStreamResponse) XXX_Unmarshal added in v1.13.0

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 added in v1.8.0

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 added in v1.6.0

func (m *LabelValuesRequest) GetEndTimestampMs() int64

func (*LabelValuesRequest) GetLabelName

func (m *LabelValuesRequest) GetLabelName() string

func (*LabelValuesRequest) GetMatchers added in v1.8.0

func (m *LabelValuesRequest) GetMatchers() *LabelMatchers

func (*LabelValuesRequest) GetStartTimestampMs added in v1.6.0

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

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

func (*LabelValuesRequest) ProtoMessage

func (*LabelValuesRequest) ProtoMessage()

func (*LabelValuesRequest) Reset

func (m *LabelValuesRequest) Reset()

func (*LabelValuesRequest) Size

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

func (*LabelValuesRequest) String

func (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 added in v0.7.0

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

func (*LabelValuesResponse) ProtoMessage

func (*LabelValuesResponse) ProtoMessage()

func (*LabelValuesResponse) Reset

func (m *LabelValuesResponse) Reset()

func (*LabelValuesResponse) Size

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

func (*LabelValuesResponse) String

func (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 added in v1.13.0

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

func (*LabelValuesStreamResponse) Descriptor added in v1.13.0

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

func (*LabelValuesStreamResponse) Equal added in v1.13.0

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

func (*LabelValuesStreamResponse) GetLabelValues added in v1.13.0

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

func (*LabelValuesStreamResponse) GoString added in v1.13.0

func (this *LabelValuesStreamResponse) GoString() string

func (*LabelValuesStreamResponse) Marshal added in v1.13.0

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

func (*LabelValuesStreamResponse) MarshalTo added in v1.13.0

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

func (*LabelValuesStreamResponse) MarshalToSizedBuffer added in v1.13.0

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

func (*LabelValuesStreamResponse) ProtoMessage added in v1.13.0

func (*LabelValuesStreamResponse) ProtoMessage()

func (*LabelValuesStreamResponse) Reset added in v1.13.0

func (m *LabelValuesStreamResponse) Reset()

func (*LabelValuesStreamResponse) Size added in v1.13.0

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

func (*LabelValuesStreamResponse) String added in v1.13.0

func (this *LabelValuesStreamResponse) String() string

func (*LabelValuesStreamResponse) Unmarshal added in v1.13.0

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

func (*LabelValuesStreamResponse) XXX_DiscardUnknown added in v1.13.0

func (m *LabelValuesStreamResponse) XXX_DiscardUnknown()

func (*LabelValuesStreamResponse) XXX_Marshal added in v1.13.0

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

func (*LabelValuesStreamResponse) XXX_Merge added in v1.13.0

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

func (*LabelValuesStreamResponse) XXX_Size added in v1.13.0

func (m *LabelValuesStreamResponse) XXX_Size() int

func (*LabelValuesStreamResponse) XXX_Unmarshal added in v1.13.0

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

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 (*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 added in v0.7.0

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

func (*MetricsForLabelMatchersResponse) ProtoMessage

func (*MetricsForLabelMatchersResponse) ProtoMessage()

func (*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 added in v1.13.0

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

func (*MetricsForLabelMatchersStreamResponse) Descriptor added in v1.13.0

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

func (*MetricsForLabelMatchersStreamResponse) Equal added in v1.13.0

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

func (*MetricsForLabelMatchersStreamResponse) GetMetric added in v1.13.0

func (*MetricsForLabelMatchersStreamResponse) GoString added in v1.13.0

func (*MetricsForLabelMatchersStreamResponse) Marshal added in v1.13.0

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

func (*MetricsForLabelMatchersStreamResponse) MarshalTo added in v1.13.0

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

func (*MetricsForLabelMatchersStreamResponse) MarshalToSizedBuffer added in v1.13.0

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

func (*MetricsForLabelMatchersStreamResponse) ProtoMessage added in v1.13.0

func (*MetricsForLabelMatchersStreamResponse) ProtoMessage()

func (*MetricsForLabelMatchersStreamResponse) Reset added in v1.13.0

func (*MetricsForLabelMatchersStreamResponse) Size added in v1.13.0

func (*MetricsForLabelMatchersStreamResponse) String added in v1.13.0

func (*MetricsForLabelMatchersStreamResponse) Unmarshal added in v1.13.0

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

func (*MetricsForLabelMatchersStreamResponse) XXX_DiscardUnknown added in v1.13.0

func (m *MetricsForLabelMatchersStreamResponse) XXX_DiscardUnknown()

func (*MetricsForLabelMatchersStreamResponse) XXX_Marshal added in v1.13.0

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

func (*MetricsForLabelMatchersStreamResponse) XXX_Merge added in v1.13.0

func (*MetricsForLabelMatchersStreamResponse) XXX_Size added in v1.13.0

func (*MetricsForLabelMatchersStreamResponse) XXX_Unmarshal added in v1.13.0

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

type MetricsMetadataRequest added in v1.1.0

type MetricsMetadataRequest struct {
}

func (*MetricsMetadataRequest) Descriptor added in v1.1.0

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

func (*MetricsMetadataRequest) Equal added in v1.1.0

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

func (*MetricsMetadataRequest) GoString added in v1.1.0

func (this *MetricsMetadataRequest) GoString() string

func (*MetricsMetadataRequest) Marshal added in v1.1.0

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

func (*MetricsMetadataRequest) MarshalTo added in v1.1.0

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

func (*MetricsMetadataRequest) MarshalToSizedBuffer added in v1.1.0

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

func (*MetricsMetadataRequest) ProtoMessage added in v1.1.0

func (*MetricsMetadataRequest) ProtoMessage()

func (*MetricsMetadataRequest) Reset added in v1.1.0

func (m *MetricsMetadataRequest) Reset()

func (*MetricsMetadataRequest) Size added in v1.1.0

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

func (*MetricsMetadataRequest) String added in v1.1.0

func (this *MetricsMetadataRequest) String() string

func (*MetricsMetadataRequest) Unmarshal added in v1.1.0

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

func (*MetricsMetadataRequest) XXX_DiscardUnknown added in v1.1.0

func (m *MetricsMetadataRequest) XXX_DiscardUnknown()

func (*MetricsMetadataRequest) XXX_Marshal added in v1.1.0

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

func (*MetricsMetadataRequest) XXX_Merge added in v1.1.0

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

func (*MetricsMetadataRequest) XXX_Size added in v1.1.0

func (m *MetricsMetadataRequest) XXX_Size() int

func (*MetricsMetadataRequest) XXX_Unmarshal added in v1.1.0

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

type MetricsMetadataResponse added in v1.1.0

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

func (*MetricsMetadataResponse) Descriptor added in v1.1.0

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

func (*MetricsMetadataResponse) Equal added in v1.1.0

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

func (*MetricsMetadataResponse) GetMetadata added in v1.1.0

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

func (*MetricsMetadataResponse) GoString added in v1.1.0

func (this *MetricsMetadataResponse) GoString() string

func (*MetricsMetadataResponse) Marshal added in v1.1.0

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

func (*MetricsMetadataResponse) MarshalTo added in v1.1.0

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

func (*MetricsMetadataResponse) MarshalToSizedBuffer added in v1.1.0

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

func (*MetricsMetadataResponse) ProtoMessage added in v1.1.0

func (*MetricsMetadataResponse) ProtoMessage()

func (*MetricsMetadataResponse) Reset added in v1.1.0

func (m *MetricsMetadataResponse) Reset()

func (*MetricsMetadataResponse) Size added in v1.1.0

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

func (*MetricsMetadataResponse) String added in v1.1.0

func (this *MetricsMetadataResponse) String() string

func (*MetricsMetadataResponse) Unmarshal added in v1.1.0

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

func (*MetricsMetadataResponse) XXX_DiscardUnknown added in v1.1.0

func (m *MetricsMetadataResponse) XXX_DiscardUnknown()

func (*MetricsMetadataResponse) XXX_Marshal added in v1.1.0

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

func (*MetricsMetadataResponse) XXX_Merge added in v1.1.0

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

func (*MetricsMetadataResponse) XXX_Size added in v1.1.0

func (m *MetricsMetadataResponse) XXX_Size() int

func (*MetricsMetadataResponse) XXX_Unmarshal added in v1.1.0

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

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

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 added in v1.10.0

func (m *QueryStreamResponse) ChunksCount() int

ChunksCount returns the number of chunks in response.

func (*QueryStreamResponse) ChunksSize added in v1.10.0

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

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

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

func (*QueryStreamResponse) ProtoMessage

func (*QueryStreamResponse) ProtoMessage()

func (*QueryStreamResponse) Reset

func (m *QueryStreamResponse) Reset()

func (*QueryStreamResponse) SamplesCount added in v1.15.0

func (m *QueryStreamResponse) SamplesCount() (count int)

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

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

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 `protobuf:"bytes,3,rep,name=labels,proto3,customtype=github.com/cortexproject/cortex/pkg/cortexpb.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 added in v0.7.0

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

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

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

func (*TimeSeriesFile) Equal added in v0.4.0

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

func (*TimeSeriesFile) GetData added in v0.4.0

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

func (*TimeSeriesFile) GetFilename added in v0.4.0

func (m *TimeSeriesFile) GetFilename() string

func (*TimeSeriesFile) GetFromIngesterId added in v0.4.0

func (m *TimeSeriesFile) GetFromIngesterId() string

func (*TimeSeriesFile) GetUserId added in v0.4.0

func (m *TimeSeriesFile) GetUserId() string

func (*TimeSeriesFile) GoString added in v0.4.0

func (this *TimeSeriesFile) GoString() string

func (*TimeSeriesFile) Marshal added in v0.4.0

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

func (*TimeSeriesFile) MarshalTo added in v0.4.0

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

func (*TimeSeriesFile) MarshalToSizedBuffer added in v0.7.0

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

func (*TimeSeriesFile) ProtoMessage added in v0.4.0

func (*TimeSeriesFile) ProtoMessage()

func (*TimeSeriesFile) Reset added in v0.4.0

func (m *TimeSeriesFile) Reset()

func (*TimeSeriesFile) Size added in v0.4.0

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

func (*TimeSeriesFile) String added in v0.4.0

func (this *TimeSeriesFile) String() string

func (*TimeSeriesFile) Unmarshal added in v0.4.0

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

func (*TimeSeriesFile) XXX_DiscardUnknown added in v0.4.0

func (m *TimeSeriesFile) XXX_DiscardUnknown()

func (*TimeSeriesFile) XXX_Marshal added in v0.4.0

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

func (*TimeSeriesFile) XXX_Merge added in v0.4.0

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

func (*TimeSeriesFile) XXX_Size added in v0.4.0

func (m *TimeSeriesFile) XXX_Size() int

func (*TimeSeriesFile) XXX_Unmarshal added in v0.4.0

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

type UnimplementedIngesterServer added in v0.7.0

type UnimplementedIngesterServer struct {
}

UnimplementedIngesterServer can be embedded to have forward compatible implementations.

func (*UnimplementedIngesterServer) AllUserStats added in v0.7.0

func (*UnimplementedIngesterServer) LabelNames added in v0.7.0

func (*UnimplementedIngesterServer) LabelNamesStream added in v1.13.0

func (*UnimplementedIngesterServer) LabelValues added in v0.7.0

func (*UnimplementedIngesterServer) LabelValuesStream added in v1.13.0

func (*UnimplementedIngesterServer) MetricsForLabelMatchers added in v0.7.0

func (*UnimplementedIngesterServer) MetricsForLabelMatchersStream added in v1.13.0

func (*UnimplementedIngesterServer) MetricsMetadata added in v1.1.0

func (*UnimplementedIngesterServer) Push added in v0.7.0

func (*UnimplementedIngesterServer) Query added in v0.7.0

func (*UnimplementedIngesterServer) QueryExemplars added in v1.10.0

func (*UnimplementedIngesterServer) QueryStream added in v0.7.0

func (*UnimplementedIngesterServer) UserStats added in v0.7.0

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

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

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"`
	ActiveSeries      uint64  `protobuf:"varint,5,opt,name=active_series,json=activeSeries,proto3" json:"active_series,omitempty"`
}

func (*UserStatsResponse) Descriptor

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

func (*UserStatsResponse) Equal

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

func (*UserStatsResponse) GetActiveSeries added in v1.15.0

func (m *UserStatsResponse) GetActiveSeries() uint64

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

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL