compactor

type BlockQueueStore interface {
	StoreEntry(*bbolt.Tx, compaction.BlockEntry) error
	DeleteEntry(tx *bbolt.Tx, index uint64, id string) error
	ListEntries(*bbolt.Tx) iter.Iterator[compaction.BlockEntry]
	CreateBuckets(*bbolt.Tx) error
}

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

type Config struct {
	Levels []LevelConfig

	CleanupBatchSize   int32
	CleanupDelay       time.Duration
	CleanupJobMinLevel int32
	CleanupJobMaxLevel int32
}

type LevelConfig struct {
	MaxBlocks uint
	MaxAge    int64
}

type Tombstones interface {
	ListTombstones(before time.Time) iter.Iterator[*metastorev1.Tombstones]
}