Struct Bulkhead 

pub struct Bulkhead { /* private fields */ }

Non-blocking bulkhead admission gate.

Implementations

impl Bulkhead

pub fn new(config: BulkheadConfig) -> Self

pub const fn config(&self) -> BulkheadConfig

pub fn in_flight(&self) -> usize

pub fn peak_in_flight(&self) -> usize

pub fn busy_rejections(&self) -> usize

pub fn try_acquire(&self) -> Result<BulkheadPermit<'_>>

Try to admit one work item.

Never blocks. If the admission budget is exhausted, this returns FrankenError::Busy.

pub fn run<T>(&self, work: impl FnOnce() -> T) -> Result<T>

Run work within a bulkhead permit.

Trait Implementations

impl Debug for Bulkhead

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

Formats the value using the given formatter.