Struct CompactionManager 

pub struct CompactionManager { /* private fields */ }

Compaction manager for a stripe

Implementations

impl CompactionManager

pub fn new(stripe_id: usize, dir: PathBuf) -> Self

Create a new compaction manager

pub fn needs_compaction(&self, sst_count: usize) -> bool

Check if compaction is needed for this stripe

pub fn compact( &self, ssts: &[SstReader], next_sst_id: u64, ) -> Result<(SstReader, Vec<PathBuf>)>

Compact multiple SST files into a single new SST

Algorithm:

1. Read all records from all input SSTs
2. Merge by key, keeping only the latest version (highest SeqNo)
3. Filter out tombstones (deleted records)
4. Write merged records to new SST
5. Return new SST reader and paths of old SSTs to delete

pub fn cleanup_old_ssts(&self, old_sst_paths: Vec<PathBuf>) -> Result<()>

Delete old SST files after successful compaction