Struct RecoveryPermitter 

pub struct RecoveryPermitter { /* private fields */ }

Bounded in-flight recovery counter.

Implementations

impl RecoveryPermitter

pub fn new(max_concurrent: usize) -> Self

Create a permitter that allows up to max_concurrent parallel recoveries.

pub fn capacity(&self) -> usize

Maximum permits ever issued (i.e. construction-time capacity).

pub fn available(&self) -> usize

Permits currently available — i.e. how many more recoveries could begin right now without blocking.

pub fn in_flight(&self) -> usize

Permits currently held by callers (waiting on or driving a recovery).

pub async fn acquire(&self) -> Option<OwnedSemaphorePermit>

Block until a permit is available.

Returns None if the permitter has been closed, so callers can map the result onto EventsourcedError::PermitDenied cleanly.

pub fn try_acquire(&self) -> Result<OwnedSemaphorePermit, TryAcquireError>

Try to acquire a permit without waiting. Returns Err(_) if no permit is available right now.

pub fn close(&self)

Drain the permitter — pending and future acquires return None so shutdown can short-circuit.

Trait Implementations

impl Clone for RecoveryPermitter

fn clone(&self) -> RecoveryPermitter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.