Versions in this module Expand all Collapse all v1 v1.7.2 Feb 15, 2018 Changes in this version + func DecodeReadRequest(r *http.Request) (*prompb.ReadRequest, error) + func EncodeReadResponse(resp *prompb.ReadResponse, w http.ResponseWriter) error + func ExternablLabelsHandler(next storage.Queryable, externalLabels model.LabelSet) storage.Queryable + func FromQuery(req *prompb.Query) (int64, int64, []*labels.Matcher, error) + func FromQueryResult(res *prompb.QueryResult) storage.SeriesSet + func LabelProtosToMetric(labelPairs []*prompb.Label) model.Metric + func MetricToLabelProtos(metric model.Metric) []*prompb.Label + func PreferLocalStorageFilter(next storage.Queryable, cb startTimeCallback) storage.Queryable + func QueryableClient(c *Client) storage.Queryable + func RequiredMatchersFilter(next storage.Queryable, required []*labels.Matcher) storage.Queryable + func ToQuery(from, to int64, matchers []*labels.Matcher) (*prompb.Query, error) + func ToQueryResult(ss storage.SeriesSet) (*prompb.QueryResult, error) + func ToWriteRequest(samples []*model.Sample) *prompb.WriteRequest + type Client struct + func NewClient(index int, conf *ClientConfig) (*Client, error) + func (c *Client) Read(ctx context.Context, query *prompb.Query) (*prompb.QueryResult, error) + func (c *Client) Store(req *prompb.WriteRequest) error + func (c Client) Name() string + type ClientConfig struct + HTTPClientConfig config_util.HTTPClientConfig + Timeout model.Duration + URL *config_util.URL + type QueueManager struct + func NewQueueManager(logger log.Logger, 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 Storage struct + func NewStorage(l log.Logger, stCallback startTimeCallback) *Storage + func (*Storage) Commit() error + func (*Storage) Rollback() error + func (s *Storage) Add(l labels.Labels, t int64, v float64) (uint64, error) + func (s *Storage) AddFast(l labels.Labels, _ uint64, t int64, v float64) error + func (s *Storage) Appender() (storage.Appender, error) + func (s *Storage) ApplyConfig(conf *config.Config) error + func (s *Storage) Close() error + func (s *Storage) Querier(ctx context.Context, mint, maxt int64) (storage.Querier, error) + func (s *Storage) StartTime() (int64, error) + type StorageClient interface + Name func() string + Store func(*prompb.WriteRequest) error