client

package
v0.0.0-...-cae4bf4 Latest Latest
Warning

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

 Go to latest Published: Oct 24, 2020 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCortex = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCortex   = 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,
}
View Source 
var MetricMetadata_MetricType_name = map[int32]string{
	0: "UNKNOWN",
	1: "COUNTER",
	2: "GAUGE",
	3: "HISTOGRAM",
	4: "GAUGEHISTOGRAM",
	5: "SUMMARY",
	6: "INFO",
	7: "STATESET",
}
View Source 
var MetricMetadata_MetricType_value = map[string]int32{
	"UNKNOWN":        0,
	"COUNTER":        1,
	"GAUGE":          2,
	"HISTOGRAM":      3,
	"GAUGEHISTOGRAM": 4,
	"SUMMARY":        5,
	"INFO":           6,
	"STATESET":       7,
}
View Source 
var WriteRequest_SourceEnum_name = map[int32]string{
	0: "API",
	1: "RULE",
}
View Source 
var WriteRequest_SourceEnum_value = map[string]int32{
	"API":  0,
	"RULE": 1,
}

Functions

func FastFingerprint 

func FastFingerprint(ls []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 FromLabelAdaptersToLabels 

func FromLabelAdaptersToLabels(ls []LabelAdapter) labels.Labels

FromLabelAdaptersToLabels casts []LabelAdapter to labels.Labels. It uses unsafe, but as LabelAdapter == labels.Label this should be safe. This allows us to use labels.Labels directly in protos.

Note: while resulting labels.Labels is supposedly sorted, this function doesn't enforce that. If input is not sorted, output will be wrong.

func FromLabelAdaptersToLabelsWithCopy 

func FromLabelAdaptersToLabelsWithCopy(input []LabelAdapter) labels.Labels

FromLabelAdaptersToLabelsWithCopy converts []LabelAdapter to labels.Labels. Do NOT use unsafe to convert between data types because this function may get in input labels whose data structure is reused.

func FromLabelAdaptersToMetric 

func FromLabelAdaptersToMetric(ls []LabelAdapter) model.Metric

FromLabelAdaptersToMetric converts []LabelAdapter to a model.Metric. Don't do this on any performance sensitive paths.

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 MetricMetadataMetricTypeToMetricType 

func MetricMetadataMetricTypeToMetricType(mt MetricMetadata_MetricType) textparse.MetricType

MetricMetadataMetricTypeToMetricType converts a metric type from our internal client to a Prometheus one.

func RegisterIngesterServer 

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

func ReuseSlice 

func ReuseSlice(ts []PreallocTimeseries)

ReuseSlice puts the slice back into a sync.Pool for reuse.

func ReuseTimeseries 

func ReuseTimeseries(ts *TimeSeries)

ReuseTimeseries puts the timeseries back into a sync.Pool for reuse.

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().

func SendTimeSeriesFile 

func SendTimeSeriesFile(s Ingester_TransferTSDBClient, m *TimeSeriesFile) error

SendTimeSeriesFile 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.ConfigWithTLS `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 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 *WriteRequest, opts ...grpc.CallOption) (*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)
	LabelValues(ctx context.Context, in *LabelValuesRequest, opts ...grpc.CallOption) (*LabelValuesResponse, error)
	LabelNames(ctx context.Context, in *LabelNamesRequest, opts ...grpc.CallOption) (*LabelNamesResponse, error)
	UserStats(ctx context.Context, in *UserStatsRequest, opts ...grpc.CallOption) (*UserStatsResponse, error)
	AllUserStats(ctx context.Context, in *UserStatsRequest, opts ...grpc.CallOption) (*UsersStatsResponse, error)
	MetricsForLabelMatchers(ctx context.Context, in *MetricsForLabelMatchersRequest, opts ...grpc.CallOption) (*MetricsForLabelMatchersResponse, error)
	MetricsMetadata(ctx context.Context, in *MetricsMetadataRequest, opts ...grpc.CallOption) (*MetricsMetadataResponse, error)
	// TransferChunks allows leaving ingester (client) to stream chunks directly to joining ingesters (server).
	TransferChunks(ctx context.Context, opts ...grpc.CallOption) (Ingester_TransferChunksClient, error)
	// TransferTSDB transfers all files of a tsdb to a joining ingester
	TransferTSDB(ctx context.Context, opts ...grpc.CallOption) (Ingester_TransferTSDBClient, 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, *WriteRequest) (*WriteResponse, error)
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
	QueryStream(*QueryRequest, Ingester_QueryStreamServer) error
	LabelValues(context.Context, *LabelValuesRequest) (*LabelValuesResponse, error)
	LabelNames(context.Context, *LabelNamesRequest) (*LabelNamesResponse, error)
	UserStats(context.Context, *UserStatsRequest) (*UserStatsResponse, error)
	AllUserStats(context.Context, *UserStatsRequest) (*UsersStatsResponse, error)
	MetricsForLabelMatchers(context.Context, *MetricsForLabelMatchersRequest) (*MetricsForLabelMatchersResponse, error)
	MetricsMetadata(context.Context, *MetricsMetadataRequest) (*MetricsMetadataResponse, error)
	// TransferChunks allows leaving ingester (client) to stream chunks directly to joining ingesters (server).
	TransferChunks(Ingester_TransferChunksServer) error
	// TransferTSDB transfers all files of a tsdb to a joining ingester
	TransferTSDB(Ingester_TransferTSDBServer) error
}

IngesterServer is the server API for Ingester service.

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 Ingester_TransferTSDBClient 

type Ingester_TransferTSDBClient interface {
	Send(*TimeSeriesFile) error
	CloseAndRecv() (*TransferTSDBResponse, error)
	grpc.ClientStream
}

type Ingester_TransferTSDBServer 

type Ingester_TransferTSDBServer interface {
	SendAndClose(*TransferTSDBResponse) error
	Recv() (*TimeSeriesFile, error)
	grpc.ServerStream
}

type LabelAdapter 

type LabelAdapter labels.Label

LabelAdapter is a labels.Label that can be marshalled to/from protos.

func FromLabelsToLabelAdapters 

func FromLabelsToLabelAdapters(ls labels.Labels) []LabelAdapter

FromLabelsToLabelAdapters casts labels.Labels to []LabelAdapter. It uses unsafe, but as LabelAdapter == labels.Label this should be safe. This allows us to use labels.Labels directly in protos.

func FromMetricsToLabelAdapters 

func FromMetricsToLabelAdapters(metric model.Metric) []LabelAdapter

FromMetricsToLabelAdapters converts model.Metric to []LabelAdapter. Don't do this on any performance sensitive paths. The result is sorted.

func (*LabelAdapter) Compare 

func (bs *LabelAdapter) Compare(other LabelAdapter) int

Compare implements proto.Comparer.

func (*LabelAdapter) Equal 

func (bs *LabelAdapter) Equal(other LabelAdapter) bool

Equal implements proto.Equaler.

func (*LabelAdapter) Marshal 

func (bs *LabelAdapter) Marshal() ([]byte, error)

Marshal implements proto.Marshaller.

func (*LabelAdapter) MarshalTo 

func (bs *LabelAdapter) MarshalTo(dAtA []byte) (int, error)

func (*LabelAdapter) MarshalToSizedBuffer 

func (bs *LabelAdapter) MarshalToSizedBuffer(buf []byte) (n int, err error)

MarshalTo implements proto.Marshaller.

func (*LabelAdapter) Size 

func (bs *LabelAdapter) Size() (n int)

Size implements proto.Sizer.

func (*LabelAdapter) Unmarshal 

func (bs *LabelAdapter) Unmarshal(dAtA []byte) error

Unmarshal a LabelAdapter, implements proto.Unmarshaller. NB this is a copy of the autogenerated code to unmarshal a LabelPair, with the byte copying replaced with a yoloString.

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 {
}

func (*LabelNamesRequest) Descriptor 

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

func (*LabelNamesRequest) Equal 

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

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 LabelPair 

type LabelPair struct {
	Name  []byte `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*LabelPair) Descriptor 

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

func (*LabelPair) Equal 

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

func (*LabelPair) GetName 

func (m *LabelPair) GetName() []byte

func (*LabelPair) GetValue 

func (m *LabelPair) GetValue() []byte

func (*LabelPair) GoString 

func (this *LabelPair) GoString() string

func (*LabelPair) Marshal 

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

func (*LabelPair) MarshalTo 

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

func (*LabelPair) MarshalToSizedBuffer 

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

func (*LabelPair) ProtoMessage 

func (*LabelPair) ProtoMessage()

func (*LabelPair) Reset 

func (m *LabelPair) Reset()

func (*LabelPair) Size 

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

func (*LabelPair) String 

func (this *LabelPair) String() string

func (*LabelPair) Unmarshal 

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

func (*LabelPair) XXX_DiscardUnknown 

func (m *LabelPair) XXX_DiscardUnknown()

func (*LabelPair) XXX_Marshal 

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

func (*LabelPair) XXX_Merge 

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

func (*LabelPair) XXX_Size 

func (m *LabelPair) XXX_Size() int

func (*LabelPair) XXX_Unmarshal 

func (m *LabelPair) 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"`
}

func (*LabelValuesRequest) Descriptor 

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

func (*LabelValuesRequest) Equal 

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

func (*LabelValuesRequest) GetLabelName 

func (m *LabelValuesRequest) GetLabelName() string

func (*LabelValuesRequest) GoString 

func (this *LabelValuesRequest) GoString() string

func (*LabelValuesRequest) Marshal 

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

func (*LabelValuesRequest) MarshalTo 

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

func (*LabelValuesRequest) MarshalToSizedBuffer 

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

func (*LabelValuesRequest) ProtoMessage 

func (*LabelValuesRequest) ProtoMessage()

func (*LabelValuesRequest) Reset 

func (m *LabelValuesRequest) Reset()

func (*LabelValuesRequest) Size 

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

func (*LabelValuesRequest) String 

func (this *LabelValuesRequest) String() string

func (*LabelValuesRequest) Unmarshal 

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

func (*LabelValuesRequest) XXX_DiscardUnknown 

func (m *LabelValuesRequest) XXX_DiscardUnknown()

func (*LabelValuesRequest) XXX_Marshal 

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

func (*LabelValuesRequest) XXX_Merge 

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

func (*LabelValuesRequest) XXX_Size 

func (m *LabelValuesRequest) XXX_Size() int

func (*LabelValuesRequest) XXX_Unmarshal 

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

type LabelValuesResponse 

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

func (*LabelValuesResponse) Descriptor 

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

func (*LabelValuesResponse) Equal 

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

func (*LabelValuesResponse) GetLabelValues 

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

func (*LabelValuesResponse) GoString 

func (this *LabelValuesResponse) GoString() string

func (*LabelValuesResponse) Marshal 

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

func (*LabelValuesResponse) MarshalTo 

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

func (*LabelValuesResponse) MarshalToSizedBuffer 

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

func (*LabelValuesResponse) ProtoMessage 

func (*LabelValuesResponse) ProtoMessage()

func (*LabelValuesResponse) Reset 

func (m *LabelValuesResponse) Reset()

func (*LabelValuesResponse) Size 

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

func (*LabelValuesResponse) String 

func (this *LabelValuesResponse) String() string

func (*LabelValuesResponse) Unmarshal 

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

func (*LabelValuesResponse) XXX_DiscardUnknown 

func (m *LabelValuesResponse) XXX_DiscardUnknown()

func (*LabelValuesResponse) XXX_Marshal 

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

func (*LabelValuesResponse) XXX_Merge 

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

func (*LabelValuesResponse) XXX_Size 

func (m *LabelValuesResponse) XXX_Size() int

func (*LabelValuesResponse) XXX_Unmarshal 

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

type MatchType 

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

func (MatchType) EnumDescriptor 

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

func (MatchType) String 

func (x MatchType) String() string

type Metric 

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

func (*Metric) Descriptor 

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

func (*Metric) Equal 

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

func (*Metric) GoString 

func (this *Metric) GoString() string

func (*Metric) Marshal 

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

func (*Metric) MarshalTo 

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

func (*Metric) MarshalToSizedBuffer 

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

func (*Metric) ProtoMessage 

func (*Metric) ProtoMessage()

func (*Metric) Reset 

func (m *Metric) Reset()

func (*Metric) Size 

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

func (*Metric) String 

func (this *Metric) String() string

func (*Metric) Unmarshal 

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

func (*Metric) XXX_DiscardUnknown 

func (m *Metric) XXX_DiscardUnknown()

func (*Metric) XXX_Marshal 

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

func (*Metric) XXX_Merge 

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

func (*Metric) XXX_Size 

func (m *Metric) XXX_Size() int

func (*Metric) XXX_Unmarshal 

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

type MetricMetadata 

type MetricMetadata struct {
	Type       MetricMetadata_MetricType `protobuf:"varint,1,opt,name=type,proto3,enum=cortex.MetricMetadata_MetricType" json:"type,omitempty"`
	MetricName string                    `protobuf:"bytes,2,opt,name=metric_name,json=metricName,proto3" json:"metric_name,omitempty"`
	Help       string                    `protobuf:"bytes,4,opt,name=help,proto3" json:"help,omitempty"`
	Unit       string                    `protobuf:"bytes,5,opt,name=unit,proto3" json:"unit,omitempty"`
}

func (*MetricMetadata) Descriptor 

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

func (*MetricMetadata) Equal 

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

func (*MetricMetadata) GetHelp 

func (m *MetricMetadata) GetHelp() string

func (*MetricMetadata) GetMetricName 

func (m *MetricMetadata) GetMetricName() string

func (*MetricMetadata) GetType 

func (m *MetricMetadata) GetType() MetricMetadata_MetricType

func (*MetricMetadata) GetUnit 

func (m *MetricMetadata) GetUnit() string

func (*MetricMetadata) GoString 

func (this *MetricMetadata) GoString() string

func (*MetricMetadata) Marshal 

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

func (*MetricMetadata) MarshalTo 

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

func (*MetricMetadata) MarshalToSizedBuffer 

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

func (*MetricMetadata) ProtoMessage 

func (*MetricMetadata) ProtoMessage()

func (*MetricMetadata) Reset 

func (m *MetricMetadata) Reset()

func (*MetricMetadata) Size 

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

func (*MetricMetadata) String 

func (this *MetricMetadata) String() string

func (*MetricMetadata) Unmarshal 

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

func (*MetricMetadata) XXX_DiscardUnknown 

func (m *MetricMetadata) XXX_DiscardUnknown()

func (*MetricMetadata) XXX_Marshal 

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

func (*MetricMetadata) XXX_Merge 

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

func (*MetricMetadata) XXX_Size 

func (m *MetricMetadata) XXX_Size() int

func (*MetricMetadata) XXX_Unmarshal 

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

type MetricMetadata_MetricType 

type MetricMetadata_MetricType int32
const (
	UNKNOWN        MetricMetadata_MetricType = 0
	COUNTER        MetricMetadata_MetricType = 1
	GAUGE          MetricMetadata_MetricType = 2
	HISTOGRAM      MetricMetadata_MetricType = 3
	GAUGEHISTOGRAM MetricMetadata_MetricType = 4
	SUMMARY        MetricMetadata_MetricType = 5
	INFO           MetricMetadata_MetricType = 6
	STATESET       MetricMetadata_MetricType = 7
)

func (MetricMetadata_MetricType) EnumDescriptor 

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

func (MetricMetadata_MetricType) String 

func (x MetricMetadata_MetricType) 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 []*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() []*Metric

func (*MetricsForLabelMatchersResponse) GoString 

func (this *MetricsForLabelMatchersResponse) GoString() string

func (*MetricsForLabelMatchersResponse) Marshal 

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

func (*MetricsForLabelMatchersResponse) MarshalTo 

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

func (*MetricsForLabelMatchersResponse) MarshalToSizedBuffer 

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

func (*MetricsForLabelMatchersResponse) ProtoMessage 

func (*MetricsForLabelMatchersResponse) ProtoMessage()

func (*MetricsForLabelMatchersResponse) Reset 

func (m *MetricsForLabelMatchersResponse) Reset()

func (*MetricsForLabelMatchersResponse) Size 

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

func (*MetricsForLabelMatchersResponse) String 

func (this *MetricsForLabelMatchersResponse) String() string

func (*MetricsForLabelMatchersResponse) Unmarshal 

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

func (*MetricsForLabelMatchersResponse) XXX_DiscardUnknown 

func (m *MetricsForLabelMatchersResponse) XXX_DiscardUnknown()

func (*MetricsForLabelMatchersResponse) XXX_Marshal 

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

func (*MetricsForLabelMatchersResponse) XXX_Merge 

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

func (*MetricsForLabelMatchersResponse) XXX_Size 

func (m *MetricsForLabelMatchersResponse) XXX_Size() int

func (*MetricsForLabelMatchersResponse) XXX_Unmarshal 

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

type MetricsMetadataRequest 

type MetricsMetadataRequest struct {
}

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 []*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() []*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 PreallocConfig 

type PreallocConfig struct{}

PreallocConfig configures how structures will be preallocated to optimise proto unmarshalling.

func (PreallocConfig) RegisterFlags 

func (PreallocConfig) RegisterFlags(f *flag.FlagSet)

RegisterFlags registers configuration settings.

type PreallocTimeseries 

type PreallocTimeseries struct {
	*TimeSeries
}

PreallocTimeseries is a TimeSeries which preallocs slices on Unmarshal.

func (*PreallocTimeseries) Unmarshal 

func (p *PreallocTimeseries) Unmarshal(dAtA []byte) error

Unmarshal implements proto.Message.

type PreallocWriteRequest 

type PreallocWriteRequest struct {
	WriteRequest
}

PreallocWriteRequest is a WriteRequest which preallocs slices on Unmarshal.

func (*PreallocWriteRequest) Unmarshal 

func (p *PreallocWriteRequest) Unmarshal(dAtA []byte) error

Unmarshal implements proto.Message.

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 []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() []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  []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) 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() []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 Sample 

type Sample struct {
	Value       float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	TimestampMs int64   `protobuf:"varint,2,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"`
}

func (*Sample) Descriptor 

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

func (*Sample) Equal 

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

func (*Sample) GetTimestampMs 

func (m *Sample) GetTimestampMs() int64

func (*Sample) GetValue 

func (m *Sample) GetValue() float64

func (*Sample) GoString 

func (this *Sample) GoString() string

func (*Sample) Marshal 

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

func (Sample) MarshalJSON 

func (s Sample) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler.

func (*Sample) MarshalTo 

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

func (*Sample) MarshalToSizedBuffer 

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

func (*Sample) ProtoMessage 

func (*Sample) ProtoMessage()

func (*Sample) Reset 

func (m *Sample) Reset()

func (*Sample) Size 

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

func (*Sample) String 

func (this *Sample) String() string

func (*Sample) Unmarshal 

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

func (*Sample) UnmarshalJSON 

func (s *Sample) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler.

func (*Sample) XXX_DiscardUnknown 

func (m *Sample) XXX_DiscardUnknown()

func (*Sample) XXX_Marshal 

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

func (*Sample) XXX_Merge 

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

func (*Sample) XXX_Size 

func (m *Sample) XXX_Size() int

func (*Sample) XXX_Unmarshal 

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

type TimeSeries 

type TimeSeries struct {
	Labels []LabelAdapter `protobuf:"bytes,1,rep,name=labels,proto3,customtype=LabelAdapter" json:"labels"`
	// Sorted by time, oldest sample first.
	Samples []Sample `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples"`
}

func (*TimeSeries) Descriptor 

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

func (*TimeSeries) Equal 

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

func (*TimeSeries) GetSamples 

func (m *TimeSeries) GetSamples() []Sample

func (*TimeSeries) GoString 

func (this *TimeSeries) GoString() string

func (*TimeSeries) Marshal 

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

func (*TimeSeries) MarshalTo 

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

func (*TimeSeries) MarshalToSizedBuffer 

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

func (*TimeSeries) ProtoMessage 

func (*TimeSeries) ProtoMessage()

func (*TimeSeries) Reset 

func (m *TimeSeries) Reset()

func (*TimeSeries) Size 

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

func (*TimeSeries) String 

func (this *TimeSeries) String() string

func (*TimeSeries) Unmarshal 

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

func (*TimeSeries) XXX_DiscardUnknown 

func (m *TimeSeries) XXX_DiscardUnknown()

func (*TimeSeries) XXX_Marshal 

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

func (*TimeSeries) XXX_Merge 

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

func (*TimeSeries) XXX_Size 

func (m *TimeSeries) XXX_Size() int

func (*TimeSeries) XXX_Unmarshal 

func (m *TimeSeries) 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         []LabelAdapter `protobuf:"bytes,3,rep,name=labels,proto3,customtype=LabelAdapter" json:"labels"`
	Chunks         []Chunk        `protobuf:"bytes,4,rep,name=chunks,proto3" json:"chunks"`
}

func (*TimeSeriesChunk) Descriptor 

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

func (*TimeSeriesChunk) Equal 

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

func (*TimeSeriesChunk) GetChunks 

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

func (*TimeSeriesChunk) GetFromIngesterId 

func (m *TimeSeriesChunk) GetFromIngesterId() string

func (*TimeSeriesChunk) GetUserId 

func (m *TimeSeriesChunk) GetUserId() string

func (*TimeSeriesChunk) GoString 

func (this *TimeSeriesChunk) GoString() string

func (*TimeSeriesChunk) Marshal 

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

func (*TimeSeriesChunk) MarshalTo 

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

func (*TimeSeriesChunk) MarshalToSizedBuffer 

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

func (*TimeSeriesChunk) ProtoMessage 

func (*TimeSeriesChunk) ProtoMessage()

func (*TimeSeriesChunk) Reset 

func (m *TimeSeriesChunk) Reset()

func (*TimeSeriesChunk) Size 

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

func (*TimeSeriesChunk) String 

func (this *TimeSeriesChunk) String() string

func (*TimeSeriesChunk) Unmarshal 

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

func (*TimeSeriesChunk) XXX_DiscardUnknown 

func (m *TimeSeriesChunk) XXX_DiscardUnknown()

func (*TimeSeriesChunk) XXX_Marshal 

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

func (*TimeSeriesChunk) XXX_Merge 

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

func (*TimeSeriesChunk) XXX_Size 

func (m *TimeSeriesChunk) XXX_Size() int

func (*TimeSeriesChunk) XXX_Unmarshal 

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

type TimeSeriesFile 

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

func (*TimeSeriesFile) Descriptor 

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

func (*TimeSeriesFile) Equal 

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

func (*TimeSeriesFile) GetData 

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

func (*TimeSeriesFile) GetFilename 

func (m *TimeSeriesFile) GetFilename() string

func (*TimeSeriesFile) GetFromIngesterId 

func (m *TimeSeriesFile) GetFromIngesterId() string

func (*TimeSeriesFile) GetUserId 

func (m *TimeSeriesFile) GetUserId() string

func (*TimeSeriesFile) GoString 

func (this *TimeSeriesFile) GoString() string

func (*TimeSeriesFile) Marshal 

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

func (*TimeSeriesFile) MarshalTo 

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

func (*TimeSeriesFile) MarshalToSizedBuffer 

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

func (*TimeSeriesFile) ProtoMessage 

func (*TimeSeriesFile) ProtoMessage()

func (*TimeSeriesFile) Reset 

func (m *TimeSeriesFile) Reset()

func (*TimeSeriesFile) Size 

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

func (*TimeSeriesFile) String 

func (this *TimeSeriesFile) String() string

func (*TimeSeriesFile) Unmarshal 

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

func (*TimeSeriesFile) XXX_DiscardUnknown 

func (m *TimeSeriesFile) XXX_DiscardUnknown()

func (*TimeSeriesFile) XXX_Marshal 

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

func (*TimeSeriesFile) XXX_Merge 

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

func (*TimeSeriesFile) XXX_Size 

func (m *TimeSeriesFile) XXX_Size() int

func (*TimeSeriesFile) XXX_Unmarshal 

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

type 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 TransferTSDBResponse 

type TransferTSDBResponse struct {
}

func (*TransferTSDBResponse) Descriptor 

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

func (*TransferTSDBResponse) Equal 

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

func (*TransferTSDBResponse) GoString 

func (this *TransferTSDBResponse) GoString() string

func (*TransferTSDBResponse) Marshal 

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

func (*TransferTSDBResponse) MarshalTo 

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

func (*TransferTSDBResponse) MarshalToSizedBuffer 

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

func (*TransferTSDBResponse) ProtoMessage 

func (*TransferTSDBResponse) ProtoMessage()

func (*TransferTSDBResponse) Reset 

func (m *TransferTSDBResponse) Reset()

func (*TransferTSDBResponse) Size 

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

func (*TransferTSDBResponse) String 

func (this *TransferTSDBResponse) String() string

func (*TransferTSDBResponse) Unmarshal 

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

func (*TransferTSDBResponse) XXX_DiscardUnknown 

func (m *TransferTSDBResponse) XXX_DiscardUnknown()

func (*TransferTSDBResponse) XXX_Marshal 

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

func (*TransferTSDBResponse) XXX_Merge 

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

func (*TransferTSDBResponse) XXX_Size 

func (m *TransferTSDBResponse) XXX_Size() int

func (*TransferTSDBResponse) XXX_Unmarshal 

func (m *TransferTSDBResponse) 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) LabelValues 

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

func (*UnimplementedIngesterServer) MetricsForLabelMatchers 

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

func (*UnimplementedIngesterServer) MetricsMetadata 

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

func (*UnimplementedIngesterServer) Push 

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

func (*UnimplementedIngesterServer) Query 

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

func (*UnimplementedIngesterServer) TransferTSDB(srv Ingester_TransferTSDBServer) 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

type WriteRequest 

type WriteRequest struct {
	Timeseries []PreallocTimeseries    `protobuf:"bytes,1,rep,name=timeseries,proto3,customtype=PreallocTimeseries" json:"timeseries"`
	Source     WriteRequest_SourceEnum `protobuf:"varint,2,opt,name=Source,json=source,proto3,enum=cortex.WriteRequest_SourceEnum" json:"Source,omitempty"`
	Metadata   []*MetricMetadata       `protobuf:"bytes,3,rep,name=metadata,proto3" json:"metadata,omitempty"`
}

func ToWriteRequest 

func ToWriteRequest(lbls []labels.Labels, samples []Sample, metadata []*MetricMetadata, source WriteRequest_SourceEnum) *WriteRequest

ToWriteRequest converts matched slices of Labels, Samples and Metadata into a WriteRequest proto. It gets timeseries from the pool, so ReuseSlice() should be called when done.

func (*WriteRequest) Descriptor 

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

func (*WriteRequest) Equal 

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

func (*WriteRequest) GetMetadata 

func (m *WriteRequest) GetMetadata() []*MetricMetadata

func (*WriteRequest) GetSource 

func (m *WriteRequest) GetSource() WriteRequest_SourceEnum

func (*WriteRequest) GoString 

func (this *WriteRequest) GoString() string

func (*WriteRequest) Marshal 

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

func (*WriteRequest) MarshalTo 

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

func (*WriteRequest) MarshalToSizedBuffer 

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

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) Size 

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

func (*WriteRequest) String 

func (this *WriteRequest) String() string

func (*WriteRequest) Unmarshal 

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

func (*WriteRequest) XXX_DiscardUnknown 

func (m *WriteRequest) XXX_DiscardUnknown()

func (*WriteRequest) XXX_Marshal 

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

func (*WriteRequest) XXX_Merge 

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

func (*WriteRequest) XXX_Size 

func (m *WriteRequest) XXX_Size() int

func (*WriteRequest) XXX_Unmarshal 

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

type WriteRequest_SourceEnum 

type WriteRequest_SourceEnum int32
const (
	API  WriteRequest_SourceEnum = 0
	RULE WriteRequest_SourceEnum = 1
)

func (WriteRequest_SourceEnum) EnumDescriptor 

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

func (WriteRequest_SourceEnum) String 

func (x WriteRequest_SourceEnum) String() string

type WriteResponse 

type WriteResponse struct {
}

func (*WriteResponse) Descriptor 

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

func (*WriteResponse) Equal 

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

func (*WriteResponse) GoString 

func (this *WriteResponse) GoString() string

func (*WriteResponse) Marshal 

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

func (*WriteResponse) MarshalTo 

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

func (*WriteResponse) MarshalToSizedBuffer 

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

func (*WriteResponse) ProtoMessage 

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) Reset 

func (m *WriteResponse) Reset()

func (*WriteResponse) Size 

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

func (*WriteResponse) String 

func (this *WriteResponse) String() string

func (*WriteResponse) Unmarshal 

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

func (*WriteResponse) XXX_DiscardUnknown 

func (m *WriteResponse) XXX_DiscardUnknown()

func (*WriteResponse) XXX_Marshal 

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

func (*WriteResponse) XXX_Merge 

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

func (*WriteResponse) XXX_Size 

func (m *WriteResponse) XXX_Size() int

func (*WriteResponse) XXX_Unmarshal 

func (m *WriteResponse) 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.