Versions in this module Expand all Collapse all v3 v3.0.0 Apr 8, 2024 Changes in this version + var DedupedBytesTotal = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var DedupedChunksTotal = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var IndexEntriesPerChunk = promauto.NewHistogram(prometheus.HistogramOpts{ ... }) + type ChunkFetcher interface + GetChunks func(ctx context.Context, userID string, from, through model.Time, ...) ([][]chunk.Chunk, []*fetcher.Fetcher, error) + type ChunkFetcherProvider interface + GetChunkFetcher func(tm model.Time) *fetcher.Fetcher + 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 + func NewChunkWriter(fetcher *fetcher.Fetcher, schemaCfg config.SchemaConfig, ...) ChunkWriter + type CompositeStore struct + func NewCompositeStore(limits StoreLimits) *CompositeStore + func (c *CompositeStore) AddStore(start model.Time, fetcher *fetcher.Fetcher, index index.Reader, ...) + func (c *CompositeStore) Stores() []Store + func (c CompositeStore) GetChunkFetcher(tm model.Time) *fetcher.Fetcher + func (c CompositeStore) GetChunks(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) GetShards(ctx context.Context, userID string, from, through model.Time, ...) (*logproto.ShardsResponse, error) + func (c CompositeStore) HasForSeries(from, through model.Time) (sharding.ForSeries, bool) + 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) Stats(ctx context.Context, userID string, from, through model.Time, ...) (*stats.Stats, error) + func (c CompositeStore) Stop() + func (c CompositeStore) Volume(ctx context.Context, userID string, from, through model.Time, limit int32, ...) (*logproto.VolumeResponse, error) + type Store interface + Stop func() + type StoreLimits interface + MaxChunksPerQueryFromStore func(string) int + MaxQueryLength func(context.Context, string) time.Duration + type Writer struct + DisableIndexDeduplication bool + 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 Other modules containing this package github.com/grafana/loki