Struct BackpressureGate 

pub struct BackpressureGate { /* private fields */ }

Backpressure gate — tracks active sessions and enforces the limit.

Implementations

impl BackpressureGate

pub fn new(config: BackpressureConfig) -> Self

Create a new gate with the given configuration.

pub fn active_count(&self) -> usize

Current active session count.

pub fn max_sessions(&self) -> usize

Maximum allowed sessions.

pub fn try_acquire(&self) -> Result<ActiveSlot<'_>, BackpressureError>

Try to acquire a slot. Returns Ok(()) if a slot was acquired (active count incremented), or Err(AtCapacity) if the coordinator is full.

pub fn is_at_capacity(&self) -> bool

Is the coordinator at capacity?