Versions in this module Expand all Collapse all v1 v1.8.2 Nov 4, 2017 Changes in this version + var MatchType_name = map[int32]string + var MatchType_value = map[string]int32 + func EncodeReadResponse(resp *ReadResponse, w http.ResponseWriter) error + func FromLabelPairs(labelPairs []*LabelPair) model.Metric + func FromQuery(req *Query) (model.Time, model.Time, []*metric.LabelMatcher, error) + func FromQueryResult(resp *QueryResult) model.Matrix + func IteratorsToMatrix(iters []local.SeriesIterator, interval metric.Interval) model.Matrix + func MatrixToIterators(m model.Matrix, err error) ([]local.SeriesIterator, error) + type Client struct + func NewClient(index int, conf *ClientConfig) (*Client, error) + func (c *Client) Read(ctx context.Context, from, through model.Time, matchers metric.LabelMatchers) (model.Matrix, error) + func (c *Client) Store(samples model.Samples) error + func (c Client) Name() string + type ClientConfig struct + HTTPClientConfig config.HTTPClientConfig + Timeout model.Duration + URL *config.URL + type LabelMatcher struct + Name string + Type MatchType + Value string + func (*LabelMatcher) Descriptor() ([]byte, []int) + func (*LabelMatcher) ProtoMessage() + func (m *LabelMatcher) GetName() string + func (m *LabelMatcher) GetType() MatchType + func (m *LabelMatcher) GetValue() string + func (m *LabelMatcher) Reset() + func (m *LabelMatcher) String() string + type LabelPair struct + Name string + Value string + func ToLabelPairs(metric model.Metric) []*LabelPair + func (*LabelPair) Descriptor() ([]byte, []int) + func (*LabelPair) ProtoMessage() + func (m *LabelPair) GetName() string + func (m *LabelPair) GetValue() string + func (m *LabelPair) Reset() + func (m *LabelPair) String() string + type MatchType int32 + const MatchType_EQUAL + const MatchType_NOT_EQUAL + const MatchType_REGEX_MATCH + const MatchType_REGEX_NO_MATCH + func (MatchType) EnumDescriptor() ([]byte, []int) + func (x MatchType) String() string + type Query struct + EndTimestampMs int64 + Matchers []*LabelMatcher + StartTimestampMs int64 + func ToQuery(from, to model.Time, matchers []*metric.LabelMatcher) (*Query, error) + func (*Query) Descriptor() ([]byte, []int) + func (*Query) ProtoMessage() + func (m *Query) GetEndTimestampMs() int64 + func (m *Query) GetMatchers() []*LabelMatcher + func (m *Query) GetStartTimestampMs() int64 + func (m *Query) Reset() + func (m *Query) String() string + type QueryResult struct + Timeseries []*TimeSeries + func ToQueryResult(matrix model.Matrix) *QueryResult + func (*QueryResult) Descriptor() ([]byte, []int) + func (*QueryResult) ProtoMessage() + func (m *QueryResult) GetTimeseries() []*TimeSeries + func (m *QueryResult) Reset() + func (m *QueryResult) String() string + type QueueManager struct + func NewQueueManager(cfg config.QueueConfig, externalLabels model.LabelSet, ...) *QueueManager + func (*QueueManager) NeedsThrottling() bool + func (t *QueueManager) Append(s *model.Sample) error + func (t *QueueManager) Start() + func (t *QueueManager) Stop() + type ReadRequest struct + Queries []*Query + func DecodeReadRequest(r *http.Request) (*ReadRequest, error) + func (*ReadRequest) Descriptor() ([]byte, []int) + func (*ReadRequest) ProtoMessage() + func (m *ReadRequest) GetQueries() []*Query + func (m *ReadRequest) Reset() + func (m *ReadRequest) String() string + type ReadResponse struct + Results []*QueryResult + func (*ReadResponse) Descriptor() ([]byte, []int) + func (*ReadResponse) ProtoMessage() + func (m *ReadResponse) GetResults() []*QueryResult + func (m *ReadResponse) Reset() + func (m *ReadResponse) String() string + type Reader struct + func (r *Reader) ApplyConfig(conf *config.Config) error + func (r *Reader) Queriers() []local.Querier + type Sample struct + TimestampMs int64 + Value float64 + func (*Sample) Descriptor() ([]byte, []int) + func (*Sample) ProtoMessage() + func (m *Sample) GetTimestampMs() int64 + func (m *Sample) GetValue() float64 + func (m *Sample) Reset() + func (m *Sample) String() string + type StorageClient interface + Name func() string + Store func(model.Samples) error + type TimeSeries struct + Labels []*LabelPair + Samples []*Sample + func (*TimeSeries) Descriptor() ([]byte, []int) + func (*TimeSeries) ProtoMessage() + func (m *TimeSeries) GetLabels() []*LabelPair + func (m *TimeSeries) GetSamples() []*Sample + func (m *TimeSeries) Reset() + func (m *TimeSeries) String() string + type WriteRequest struct + Timeseries []*TimeSeries + func ToWriteRequest(samples []*model.Sample) *WriteRequest + func (*WriteRequest) Descriptor() ([]byte, []int) + func (*WriteRequest) ProtoMessage() + func (m *WriteRequest) GetTimeseries() []*TimeSeries + func (m *WriteRequest) Reset() + func (m *WriteRequest) String() string + type Writer struct + func (w *Writer) Append(smpl *model.Sample) error + func (w *Writer) ApplyConfig(conf *config.Config) error + func (w *Writer) NeedsThrottling() bool + func (w *Writer) Stop()