Versions in this module Expand all Collapse all v3 v3.0.0 Apr 8, 2024 Changes in this version + type BaseReader interface + 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) + type Filterable interface + SetChunkFilterer func(chunkFilter chunk.RequestChunkFilterer) + type MonitoredReaderWriter struct + func NewMonitoredReaderWriter(rw ReaderWriter, reg prometheus.Registerer) *MonitoredReaderWriter + func (m MonitoredReaderWriter) GetChunkRefs(ctx context.Context, userID string, from, through model.Time, ...) ([]logproto.ChunkRef, error) + func (m MonitoredReaderWriter) GetSeries(ctx context.Context, userID string, from, through model.Time, ...) ([]labels.Labels, error) + func (m MonitoredReaderWriter) GetShards(ctx context.Context, userID string, from, through model.Time, ...) (*logproto.ShardsResponse, error) + func (m MonitoredReaderWriter) HasForSeries(from, through model.Time) (sharding.ForSeries, bool) + func (m MonitoredReaderWriter) IndexChunk(ctx context.Context, from, through model.Time, chk chunk.Chunk) error + func (m MonitoredReaderWriter) LabelNamesForMetricName(ctx context.Context, userID string, from, through model.Time, ...) ([]string, error) + func (m MonitoredReaderWriter) LabelValuesForMetricName(ctx context.Context, userID string, from, through model.Time, ...) ([]string, error) + func (m MonitoredReaderWriter) SetChunkFilterer(chunkFilter chunk.RequestChunkFilterer) + func (m MonitoredReaderWriter) Stats(ctx context.Context, userID string, from, through model.Time, ...) (*stats.Stats, error) + func (m MonitoredReaderWriter) Volume(ctx context.Context, userID string, from, through model.Time, limit int32, ...) (*logproto.VolumeResponse, error) + type Reader interface + GetChunkRefs func(ctx context.Context, userID string, from, through model.Time, ...) ([]logproto.ChunkRef, error) + type ReaderWriter interface + type StatsReader interface + GetShards func(ctx context.Context, userID string, from, through model.Time, ...) (*logproto.ShardsResponse, error) + HasForSeries func(from, through model.Time) (sharding.ForSeries, bool) + Stats func(ctx context.Context, userID string, from, through model.Time, ...) (*stats.Stats, error) + Volume func(ctx context.Context, userID string, from, through model.Time, limit int32, ...) (*logproto.VolumeResponse, error) + type Writer interface + IndexChunk func(ctx context.Context, from, through model.Time, chk chunk.Chunk) error