Struct CacheIoExecutionState 

pub struct CacheIoExecutionState { /* private fields */ }

Canonical admission and cancellation state for a bounded cache I/O worker.

Backends own task payloads, worker threads, files, buffers, and completion objects. This state owns exact-key coalescing, bounded admission, queued and in-flight cancellation, and peak queue accounting.

Implementations

impl CacheIoExecutionState

pub fn new(capacity: usize) -> Result<Self, CacheIoExecutionStateError>

Creates an empty state with finite nonzero queue capacity.

pub fn prepare(&mut self, key: CacheIoOperationKey) -> CacheIoPreparation

Registers an exact key or joins its existing completion owner.

pub fn admit( &mut self, key: &CacheIoOperationKey, ) -> Result<CacheIoAdmission, CacheIoExecutionStateError>

Attempts to admit one previously prepared operation.

pub fn rollback_admission( &mut self, key: &CacheIoOperationKey, ) -> Result<(), CacheIoExecutionStateError>

Rolls back physical enqueue failure without losing exact-key ownership.

pub fn begin( &mut self, key: &CacheIoOperationKey, ) -> Result<CacheIoStartDisposition, CacheIoExecutionStateError>

Begins one operation received by the physical executor.

pub fn cancel(&mut self, key: &CacheIoOperationKey) -> bool

Cancels prepared, queued, or physically executing work exactly once.

pub fn complete( &mut self, key: &CacheIoOperationKey, ) -> Result<CacheIoCompletionDisposition, CacheIoExecutionStateError>

Resolves one exact physically executed operation.

pub fn retire( &mut self, key: &CacheIoOperationKey, ) -> Result<bool, CacheIoExecutionStateError>

Releases exact-key ownership after task resources are safe to drop.

pub const fn queued(&self) -> usize

Current physically queued operation count.

pub const fn peak_queued(&self) -> usize

Largest physically queued operation count.

Trait Implementations

impl Debug for CacheIoExecutionState

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

Formats the value using the given formatter.