index

Documentation

Index

• type BaseReader
• type Filterable
• type MonitoredReaderWriter
  • 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
• type ReaderWriter
• type StatsReader
• type Writer

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) ([]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 (m MonitoredReaderWriter) GetChunkRefs(ctx context.Context, userID string, from, through model.Time, predicate chunk.Predicate) ([]logproto.ChunkRef, error)

func (MonitoredReaderWriter) GetSeries

func (m MonitoredReaderWriter) GetSeries(ctx context.Context, userID string, from, through model.Time, matchers ...*labels.Matcher) ([]labels.Labels, error)

func (MonitoredReaderWriter) GetShards

func (m MonitoredReaderWriter) GetShards(
	ctx context.Context,
	userID string,
	from, through model.Time,
	targetBytesPerShard uint64,
	predicate chunk.Predicate,
) (*logproto.ShardsResponse, error)

func (MonitoredReaderWriter) HasForSeries

func (m MonitoredReaderWriter) HasForSeries(from, through model.Time) (sharding.ForSeries, bool)

func (MonitoredReaderWriter) IndexChunk

func (m MonitoredReaderWriter) IndexChunk(ctx context.Context, from, through model.Time, chk chunk.Chunk) error

func (MonitoredReaderWriter) LabelNamesForMetricName

func (m MonitoredReaderWriter) LabelNamesForMetricName(ctx context.Context, userID string, from, through model.Time, metricName string) ([]string, error)

func (MonitoredReaderWriter) LabelValuesForMetricName

func (m MonitoredReaderWriter) LabelValuesForMetricName(ctx context.Context, userID string, from, through model.Time, metricName string, labelName string, matchers ...*labels.Matcher) ([]string, error)

func (MonitoredReaderWriter) SetChunkFilterer

func (m MonitoredReaderWriter) SetChunkFilterer(chunkFilter chunk.RequestChunkFilterer)

func (MonitoredReaderWriter) Stats

func (m MonitoredReaderWriter) Stats(ctx context.Context, userID string, from, through model.Time, matchers ...*labels.Matcher) (*stats.Stats, error)

func (MonitoredReaderWriter) Volume

func (m MonitoredReaderWriter) Volume(ctx context.Context, userID string, from, through model.Time, limit int32, targetLabels []string, aggregateBy string, matchers ...*labels.Matcher) (*logproto.VolumeResponse, error)

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 ReaderWriter interface {
	Reader
	Writer
}

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)
}

type Writer

type Writer interface {
	IndexChunk(ctx context.Context, from, through model.Time, chk chunk.Chunk) error
}