Documentation ¶
Index ¶
- type BaseReader
- type Filterable
- type 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
- type ReaderWriter
- type StatsReader
- type Writer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BaseReader ¶
type BaseReader interface { GetSeries(ctx context.Context, userID string, from, through model.Time, matchers ...*labels.Matcher) ([]labels.Labels, error) LabelValuesForMetricName(ctx context.Context, userID string, from, through model.Time, metricName string, labelName string, matchers ...*labels.Matcher) ([]string, error) LabelNamesForMetricName(ctx context.Context, userID string, from, through model.Time, metricName string, matchers ...*labels.Matcher) ([]string, error) }
type Filterable ¶
type Filterable interface { // SetChunkFilterer sets a chunk filter to be used when retrieving chunks. SetChunkFilterer(chunkFilter chunk.RequestChunkFilterer) }
type MonitoredReaderWriter ¶
type MonitoredReaderWriter struct {
// contains filtered or unexported fields
}
func NewMonitoredReaderWriter ¶
func NewMonitoredReaderWriter(rw ReaderWriter, reg prometheus.Registerer) *MonitoredReaderWriter
func (MonitoredReaderWriter) GetChunkRefs ¶
func (MonitoredReaderWriter) HasForSeries ¶
func (MonitoredReaderWriter) IndexChunk ¶
func (MonitoredReaderWriter) LabelNamesForMetricName ¶
func (MonitoredReaderWriter) LabelValuesForMetricName ¶
func (MonitoredReaderWriter) SetChunkFilterer ¶
func (m MonitoredReaderWriter) SetChunkFilterer(chunkFilter chunk.RequestChunkFilterer)
type Reader ¶
type Reader interface { BaseReader StatsReader GetChunkRefs(ctx context.Context, userID string, from, through model.Time, predicate chunk.Predicate) ([]logproto.ChunkRef, error) Filterable }
type ReaderWriter ¶
type StatsReader ¶
type StatsReader interface { Stats(ctx context.Context, userID string, from, through model.Time, matchers ...*labels.Matcher) (*stats.Stats, error) Volume(ctx context.Context, userID string, from, through model.Time, limit int32, targetLabels []string, aggregateBy string, matchers ...*labels.Matcher) (*logproto.VolumeResponse, error) GetShards( ctx context.Context, userID string, from, through model.Time, targetBytesPerShard uint64, predicate chunk.Predicate, ) (*logproto.ShardsResponse, error) // If the underlying index supports it, this will return the ForSeries interface // which is used in bloom-filter accelerated sharding calculation optimization. HasForSeries(from, through model.Time) (sharding.ForSeries, bool) }
Click to show internal directories.
Click to hide internal directories.