compact

package
v0.0.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 27, 2025 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Compactor

type Compactor struct {
	Config Config
	*seq.Seq
	Index *index.Index
	// Level is the indication of the the exponential backoff level
	Level int
	// HeadChan is a channel for receiving files representing index.LogSegment's
	HeadChan chan string
	// contains filtered or unexported fields
}

func NewCompactor

func NewCompactor(cfg *Config, seq *seq.Seq, idx *index.Index) *Compactor

func (*Compactor) RunChase

func (c *Compactor) RunChase(ctx context.Context, process func(context.Context, int64) error)

RunChase runs a loop that chases a moving target via HeadChan. process performs the work up to the given head.

type Config

type Config struct {
	// Configuration
	Divisor int

	Log *slog.Logger
}

Jump to

Keyboard shortcuts

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