Versions in this module Expand all Collapse all v2 v2.5.2 Apr 27, 2022 Changes in this version + func FindSetMatches(pattern string) []string + type IndexGatewayClient interface + GetChunkRef func(ctx context.Context, in *indexgatewaypb.GetChunkRefRequest, ...) (*indexgatewaypb.GetChunkRefResponse, error) + LabelNamesForMetricName func(ctx context.Context, in *indexgatewaypb.LabelNamesForMetricNameRequest, ...) (*indexgatewaypb.LabelResponse, error) + LabelValuesForMetricName func(ctx context.Context, in *indexgatewaypb.LabelValuesForMetricNameRequest, ...) (*indexgatewaypb.LabelResponse, error) + type IndexGatewayClientStore struct + func NewIndexGatewayClientStore(client IndexGatewayClient, index *IndexStore) *IndexGatewayClientStore + func (c *IndexGatewayClientStore) GetChunkRefs(ctx context.Context, userID string, from, through model.Time, ...) ([]logproto.ChunkRef, error) + func (c *IndexGatewayClientStore) GetSeries(ctx context.Context, userID string, from, through model.Time, ...) ([]labels.Labels, error) + func (c *IndexGatewayClientStore) LabelNamesForMetricName(ctx context.Context, userID string, from, through model.Time, ...) ([]string, error) + func (c *IndexGatewayClientStore) LabelValuesForMetricName(ctx context.Context, userID string, from, through model.Time, ...) ([]string, error) + type IndexStore struct + func NewIndexStore(schemaCfg config.SchemaConfig, schema index.SeriesStoreSchema, ...) *IndexStore + func (c *IndexStore) GetChunkRefs(ctx context.Context, userID string, from, through model.Time, ...) ([]logproto.ChunkRef, error) + func (c *IndexStore) GetSeries(ctx context.Context, userID string, from, through model.Time, ...) ([]labels.Labels, error) + func (c *IndexStore) LabelNamesForMetricName(ctx context.Context, userID string, from, through model.Time, ...) ([]string, error) + func (c *IndexStore) LabelValuesForMetricName(ctx context.Context, userID string, from, through model.Time, ...) ([]string, error) + func (c *IndexStore) SetChunkFilterer(f chunk.RequestChunkFilterer) + type IndexWriter interface + BatchWrite func(context.Context, index.WriteBatch) error + NewWriteBatch func() index.WriteBatch + type SchemaWrites interface + GetCacheKeysAndLabelWriteEntries func(from, through model.Time, userID string, metricName string, ...) ([]string, [][]index.Entry, error) + GetChunkWriteEntries func(from, through model.Time, userID string, metricName string, ...) ([]index.Entry, error) + type Writer struct + DisableIndexDeduplication bool + func NewWriter(fetcher *fetcher.Fetcher, schemaCfg config.SchemaConfig, ...) *Writer + func (c *Writer) Put(ctx context.Context, chunks []chunk.Chunk) error + func (c *Writer) PutOne(ctx context.Context, from, through model.Time, chk chunk.Chunk) error