Struct BackpressureGuard 

pub struct BackpressureGuard { /* private fields */ }

Tracks in-flight work count and enforces a capacity limit.

Guarantees

• Thread-safe via Arc<Mutex<_>>
• try_acquire is non-blocking
• release decrements the counter; no-op if counter is already 0
• Optional soft limit emits a warning when depth reaches the threshold

Implementations

impl BackpressureGuard

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

Create a new guard with the given capacity.

Returns

• Ok(BackpressureGuard) — on success
• Err(AgentRuntimeError::Orchestration) — if capacity == 0

pub fn with_soft_limit(self, soft: usize) -> Result<Self, AgentRuntimeError>

Set a soft capacity threshold. When depth reaches this level, a warning is logged but the request is still accepted (up to hard capacity).

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

Try to acquire a slot.

Emits a warning when the soft limit is reached (if configured), but still accepts the request until hard capacity is exceeded.

Returns

• Ok(()) — slot acquired
• Err(AgentRuntimeError::BackpressureShed) — hard capacity exceeded

pub fn release(&self) -> Result<(), AgentRuntimeError>

Release a previously acquired slot.

pub fn hard_capacity(&self) -> usize

Return the hard capacity (maximum concurrent slots) configured for this guard.

pub fn depth(&self) -> Result<usize, AgentRuntimeError>

Return the current depth.

pub fn soft_depth_ratio(&self) -> f32

Return the ratio of current depth to soft capacity as a value in [0.0, ∞).

Returns 0.0 if no soft limit has been configured. Values above 1.0 mean the soft limit has been exceeded.

Trait Implementations

impl Clone for BackpressureGuard

fn clone(&self) -> BackpressureGuard

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BackpressureGuard

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

Formats the value using the given formatter.