Struct CompactionScheduler 

pub struct CompactionScheduler { /* private fields */ }

Lock-free compaction scheduler for Sled block stores.

All mutable state is held in atomics so Arc<CompactionScheduler> is safely shared across threads and async tasks without a mutex.

Implementations

impl CompactionScheduler

pub fn new(config: CompactionConfig) -> Arc<Self>

Create a new scheduler wrapped in an Arc.

pub fn record_write(&self, bytes: usize)

Record a write of bytes bytes.

Updates the “last operation” timestamp and the byte counter that feeds the bytes-threshold trigger.

pub fn should_compact(&self) -> bool

Returns true when the scheduler recommends a compaction be triggered.

Specifically it returns true when all of the following hold:

• No compaction is already in-flight (!is_compacting).
• The bytes threshold is exceeded or (the store has been idle long enough and the minimum inter-compaction interval has been met).

pub fn mark_compaction_started(&self) -> bool

Attempt to claim the compaction lock.

Uses a compare-and-swap to atomically transition is_compacting from false to true. Returns true when the caller won the race (they should proceed with the compaction); returns false if another goroutine is already compacting.

pub fn mark_compaction_done(&self)

Release the compaction lock and update post-compaction bookkeeping.

Resets the bytes counter, updates the last-compaction timestamp, and increments the compaction count before clearing the in-flight flag.

pub fn compaction_count(&self) -> u64

Total number of completed compactions.

pub fn bytes_since_last_compaction(&self) -> u64

Bytes written to the store since the last compaction completed.

pub fn idle_duration(&self) -> Duration

Duration since the last recorded write operation.

pub fn time_since_last_compaction(&self) -> Duration

Duration since the last compaction completed.

Trait Implementations

impl Debug for CompactionScheduler

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.