Versions in this module Expand all Collapse all v2 v2.5.2 Apr 27, 2022 Changes in this version + type ChunkWriter interface + Put func(ctx context.Context, chunks []chunk.Chunk) error + PutOne func(ctx context.Context, from, through model.Time, chunk chunk.Chunk) error + type CompositeStore struct + func NewCompositeStore(limits StoreLimits) *CompositeStore + func (c *CompositeStore) AddStore(start model.Time, fetcher *fetcher.Fetcher, index Index, writer ChunkWriter, ...) + func (c *CompositeStore) Stores() []Store + func (c CompositeStore) GetChunkFetcher(tm model.Time) *fetcher.Fetcher + func (c CompositeStore) GetChunkRefs(ctx context.Context, userID string, from, through model.Time, ...) ([][]chunk.Chunk, []*fetcher.Fetcher, error) + func (c CompositeStore) GetSeries(ctx context.Context, userID string, from, through model.Time, ...) ([]labels.Labels, error) + func (c CompositeStore) LabelNamesForMetricName(ctx context.Context, userID string, from, through model.Time, ...) ([]string, error) + func (c CompositeStore) LabelValuesForMetricName(ctx context.Context, userID string, from, through model.Time, ...) ([]string, error) + func (c CompositeStore) Put(ctx context.Context, chunks []chunk.Chunk) error + func (c CompositeStore) PutOne(ctx context.Context, from, through model.Time, chunk chunk.Chunk) error + func (c CompositeStore) SetChunkFilterer(chunkFilter chunk.RequestChunkFilterer) + func (c CompositeStore) Stop() + type Index interface + GetChunkRefs func(ctx context.Context, userID string, from, through model.Time, ...) ([]logproto.ChunkRef, error) + GetSeries func(ctx context.Context, userID string, from, through model.Time, ...) ([]labels.Labels, error) + LabelNamesForMetricName func(ctx context.Context, userID string, from, through model.Time, ...) ([]string, error) + LabelValuesForMetricName func(ctx context.Context, userID string, from, through model.Time, ...) ([]string, error) + SetChunkFilterer func(chunkFilter chunk.RequestChunkFilterer) + type Store interface + GetChunkFetcher func(tm model.Time) *fetcher.Fetcher + GetChunkRefs func(ctx context.Context, userID string, from, through model.Time, ...) ([][]chunk.Chunk, []*fetcher.Fetcher, error) + GetSeries func(ctx context.Context, userID string, from, through model.Time, ...) ([]labels.Labels, error) + LabelNamesForMetricName func(ctx context.Context, userID string, from, through model.Time, ...) ([]string, error) + LabelValuesForMetricName func(ctx context.Context, userID string, from, through model.Time, ...) ([]string, error) + Put func(ctx context.Context, chunks []chunk.Chunk) error + PutOne func(ctx context.Context, from, through model.Time, chunk chunk.Chunk) error + SetChunkFilterer func(chunkFilter chunk.RequestChunkFilterer) + Stop func() + type StoreLimits interface + MaxChunksPerQueryFromStore func(userID string) int + MaxQueryLength func(userID string) time.Duration
Go to main page