compaction

type Config struct {
	Enabled bool

	MergeTrigger    int
	MergeFanIn      int
	MergeFanOutSize uint64

	BucketLowerbound float64
	BucketUpperbound float64

	Workers      int
	TimeWindow   time.Duration
	TickInterval time.Duration
}

type DocBlockLocation = util.Pair[[]byte, uint64]

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

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

type Source interface {
	indexwriter.Source
	DocBlocks() iter.Seq2[DocBlockLocation, error]
}