Struct CompactionWorker 

pub struct CompactionWorker { /* private fields */ }

Compaction worker

Implementations

impl CompactionWorker

pub fn new(dir: impl AsRef<Path>, config: CompactionConfig) -> Self

Create a new compaction worker

pub fn stop_flag(&self) -> Arc<AtomicBool>

Get the stop flag for external control

pub fn needs_compaction(&self, manifest: &Manifest) -> bool

Check if compaction is needed for level 0

pub fn pick_compaction_level(&self, manifest: &Manifest) -> Option<u32>

Check which level needs compaction

pub fn compact_level0(&mut self, manifest: &mut Manifest) -> Result<()>

Compact level 0 to level 1

pub fn stats(&self) -> &CompactionStats

Get compaction statistics

pub fn run_once(&mut self, manifest: &mut Manifest) -> Result<bool>

Run a single compaction pass