Struct CompactionQueue 

pub struct CompactionQueue { /* private fields */ }

Compaction queue manager for multiple shards.

Implementations

impl CompactionQueue

pub fn new(num_shards: usize, config: CompactionConfig) -> Self

Create a new compaction queue.

pub fn shard(&self, shard_id: ShardId) -> Option<&Arc<ShardCompactionState>>

Get shard state.

pub fn schedule(&self, shard_id: ShardId, priority: CompactionPriority) -> bool

Schedule compaction for a shard.

pub fn next_task(&self) -> Option<(ShardId, CompactionTask)>

Get next task to process (from any shard).

pub fn active_compactions(&self) -> usize

Count active compactions.

pub fn can_start_compaction(&self) -> bool

Check if more compactions can start.

pub fn total_pending(&self) -> usize

Total pending tasks across all shards.

pub fn shutdown(&self)

Signal shutdown.

pub fn is_shutdown(&self) -> bool

Check if shutdown requested.

pub fn num_shards(&self) -> usize

Number of shards.