client

package
v0.5.0-rc1 Latest Latest
Warning

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

Go to latest
Published: Jan 15, 2020 License: Apache-2.0 Imports: 35 Imported by: 53

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

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 HashNew32

func HashNew32() uint32

HashNew32 initializies a new fnv32 hash value.

func RegisterIngesterServer

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

func ReuseSlice added in v0.2.0

func ReuseSlice(slice []PreallocTimeseries)

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

func ReuseTimeseries added in v0.2.0

func ReuseTimeseries(ts *TimeSeries)

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

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

type Factory

type Factory func(addr string) (grpc_health_v1.HealthClient, error)

Factory defines the signature for an ingester client factory.

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

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

type Ingester_TransferTSDBServer added in v0.4.0

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

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(buf []byte) (n int, err error)

MarshalTo implements proto.Marshaller.

func (*LabelAdapter) Size

func (bs *LabelAdapter) Size() int

Size implements proto.Sizer.

func (*LabelAdapter) Unmarshal

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

Unmarshal a LabelAdapater, 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) 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) 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) 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) 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) 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) 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) 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) 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 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) 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) 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 Pool

type Pool struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Pool holds a cache of grpc_health_v1 clients.

func NewPool

func NewPool(cfg PoolConfig, ring ring.ReadRing, factory Factory, logger log.Logger) *Pool

NewPool creates a new Pool.

func (*Pool) Count

func (p *Pool) Count() int

Count returns how many clients are in the cache

func (*Pool) GetClientFor

func (p *Pool) GetClientFor(addr string) (grpc_health_v1.HealthClient, error)

GetClientFor gets the client for the specified address. If it does not exist it will make a new client at that address

func (*Pool) RegisteredAddresses

func (p *Pool) RegisteredAddresses() []string

RegisteredAddresses returns all the addresses that a client is cached for

func (*Pool) RemoveClientFor

func (p *Pool) RemoveClientFor(addr string)

RemoveClientFor removes the client with the specified address

func (*Pool) Stop

func (p *Pool) Stop()

Stop the pool's background cleanup goroutine.

type PoolConfig

type PoolConfig struct {
	ClientCleanupPeriod  time.Duration `yaml:"client_cleanup_period,omitempty"`
	HealthCheckIngesters bool          `yaml:"health_check_ingesters,omitempty"`
	RemoteTimeout        time.Duration
}

PoolConfig is config for creating a Pool.

func (*PoolConfig) RegisterFlags

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

RegisterFlags adds the flags required to config this to the given FlagSet.

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

QueryStreamResponse contains a batch of timeseries chunks.

func (*QueryStreamResponse) Descriptor

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

func (*QueryStreamResponse) Equal

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

func (*QueryStreamResponse) GetTimeseries

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

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

type TransferTSDBResponse struct {
}

func (*TransferTSDBResponse) Descriptor added in v0.4.0

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

func (*TransferTSDBResponse) Equal added in v0.4.0

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

func (*TransferTSDBResponse) GoString added in v0.4.0

func (this *TransferTSDBResponse) GoString() string

func (*TransferTSDBResponse) Marshal added in v0.4.0

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

func (*TransferTSDBResponse) MarshalTo added in v0.4.0

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

func (*TransferTSDBResponse) ProtoMessage added in v0.4.0

func (*TransferTSDBResponse) ProtoMessage()

func (*TransferTSDBResponse) Reset added in v0.4.0

func (m *TransferTSDBResponse) Reset()

func (*TransferTSDBResponse) Size added in v0.4.0

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

func (*TransferTSDBResponse) String added in v0.4.0

func (this *TransferTSDBResponse) String() string

func (*TransferTSDBResponse) Unmarshal added in v0.4.0

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

func (*TransferTSDBResponse) XXX_DiscardUnknown added in v0.4.0

func (m *TransferTSDBResponse) XXX_DiscardUnknown()

func (*TransferTSDBResponse) XXX_Marshal added in v0.4.0

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

func (*TransferTSDBResponse) XXX_Merge added in v0.4.0

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

func (*TransferTSDBResponse) XXX_Size added in v0.4.0

func (m *TransferTSDBResponse) XXX_Size() int

func (*TransferTSDBResponse) XXX_Unmarshal added in v0.4.0

func (m *TransferTSDBResponse) XXX_Unmarshal(b []byte) 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) 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) 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) 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) 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"`
}

func ToWriteRequest

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

ToWriteRequest converts matched slices of Labels and Samples 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) 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) 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

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

Jump to

Keyboard shortcuts

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