Struct LocalCompaction 

pub(crate) struct LocalCompaction {
    coordinator: Arc<CompactionCoordinator>,
    region_id: RegionId,
    units: HashMap<u64, Arc<UnitExecution>>,
    unit_states: Arc<[Arc<UnitExecution>]>,
    pending: VecDeque<CompactionTask>,
    parallelism: usize,
    error: Option<Arc<Error>>,
    made_progress: bool,
    cancellation_requested: bool,
}

A request’s local units. All transitions run on the owning region worker.

Fields

coordinator: Arc<CompactionCoordinator>

region_id: RegionId

units: HashMap<u64, Arc<UnitExecution>>

All pending and submitted units, retained until task exit. Tasks own their input leases. Keyed by each unit’s execution plan ID, allocated from the scheduler’s next_plan_id; it equals CompactionExecution::plan_id() and the plan_id in unit notifications.

unit_states: Arc<[Arc<UnitExecution>]>

Built once after admission. No units are added after this set is published. Shared handles retain execution flags only, never tasks or SST leases.

pending: VecDeque<CompactionTask>

parallelism: usize

error: Option<Arc<Error>>

made_progress: bool

cancellation_requested: bool

Retains accepted cancellation while non-cancellable siblings finish committing.

Implementations

impl LocalCompaction

pub(crate) fn current_state(&self) -> LocalCompactionState

Clones progress and live task handles without retaining tasks or their SST leases.

pub(crate) fn request_cancel(&mut self) -> RequestCancelResult

Requests cancellation for all units that have not started committing.

fn num_running(&self) -> usize

Counts submitted units that have not exited, including queued jobs.

fn can_apply(&self, id: u64) -> bool

Checks this attempt’s phase without depending on any sibling’s apply status.

fn release_unit(&mut self, id: u64)

Removes an exited or rejected unit from scheduling and shared phase aggregation.

fn finish(&mut self, id: u64, result: Result<bool, Arc<Error>>)

Records a terminal result once, but still awaits task exit.

Trait Implementations

impl Debug for LocalCompaction

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

Formats the value using the given formatter.

impl Drop for LocalCompaction

fn drop(&mut self)

Stops cancellable work when its region or compaction cycle is removed.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.