compactv2

Documentation

Index

• func NewChangeLog(w io.Writer) *changeLog
• func NewDelGenericSeriesIterator(chks chunks.Iterator, intervals tombstones.Intervals, ...) *delGenericSeriesIterator
• func NewProgressLogger(logger log.Logger, series int) *progressLogger
• type ChangeLogger
• type Compactor
  • func New(tmpDir string, logger log.Logger, changeLogger ChangeLogger, ...) *Compactor
  • func NewDryRun(tmpDir string, logger log.Logger, changeLogger ChangeLogger, ...) *Compactor
  • func (w *Compactor) WriteSeries(ctx context.Context, readers []block.Reader, sWriter block.Writer, ...) (err error)
• type DeletionModifier
  • func WithDeletionModifier(deletions ...metadata.DeletionRequest) *DeletionModifier
  • func (d *DeletionModifier) Modify(sym index.StringIter, set storage.ChunkSeriesSet, log ChangeLogger, ...) (index.StringIter, storage.ChunkSeriesSet)
• type Modifier
• type ProgressLogger
• type RelabelModifier
  • func WithRelabelModifier(relabels ...*relabel.Config) *RelabelModifier
  • func (d *RelabelModifier) Modify(_ index.StringIter, set storage.ChunkSeriesSet, log ChangeLogger, ...) (index.StringIter, storage.ChunkSeriesSet)

Functions

func NewChangeLog

func NewChangeLog(w io.Writer) *changeLog

func NewDelGenericSeriesIterator

func NewDelGenericSeriesIterator(
	chks chunks.Iterator,
	intervals tombstones.Intervals,
	logDelete func(intervals tombstones.Intervals),
) *delGenericSeriesIterator

func NewProgressLogger

func NewProgressLogger(logger log.Logger, series int) *progressLogger

Types

type ChangeLogger

type ChangeLogger interface {
	DeleteSeries(del labels.Labels, intervals tombstones.Intervals)
	ModifySeries(old labels.Labels, new labels.Labels)
}

type Compactor

type Compactor struct {
	// contains filtered or unexported fields
}

func New

func New(tmpDir string, logger log.Logger, changeLogger ChangeLogger, pool chunkenc.Pool) *Compactor

func NewDryRun

func NewDryRun(tmpDir string, logger log.Logger, changeLogger ChangeLogger, pool chunkenc.Pool) *Compactor

func (*Compactor) WriteSeries

func (w *Compactor) WriteSeries(ctx context.Context, readers []block.Reader, sWriter block.Writer, p ProgressLogger, modifiers ...Modifier) (err error)

TODO(bwplotka): Upstream this.

type DeletionModifier

type DeletionModifier struct {
	// contains filtered or unexported fields
}

func WithDeletionModifier

func WithDeletionModifier(deletions ...metadata.DeletionRequest) *DeletionModifier

func (*DeletionModifier) Modify

func (d *DeletionModifier) Modify(sym index.StringIter, set storage.ChunkSeriesSet, log ChangeLogger, p ProgressLogger) (index.StringIter, storage.ChunkSeriesSet)

type Modifier

type Modifier interface {
	Modify(sym index.StringIter, set storage.ChunkSeriesSet, log ChangeLogger, p ProgressLogger) (index.StringIter, storage.ChunkSeriesSet)
}

type ProgressLogger

type ProgressLogger interface {
	SeriesProcessed()
}

type RelabelModifier

type RelabelModifier struct {
	// contains filtered or unexported fields
}

func WithRelabelModifier

func WithRelabelModifier(relabels ...*relabel.Config) *RelabelModifier

func (*RelabelModifier) Modify

func (d *RelabelModifier) Modify(_ index.StringIter, set storage.ChunkSeriesSet, log ChangeLogger, p ProgressLogger) (index.StringIter, storage.ChunkSeriesSet)