compactv2

package

v0.26.0 Latest Latest Go to latest Published: Apr 9, 2022 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/heylongdacoder/thanos

Links

Open Source Insights

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)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL