Struct ConnectionSemaphore 

pub struct ConnectionSemaphore { /* private fields */ }

Wraps an optional global and an optional factor-specific semaphore.

Implementations

impl ConnectionSemaphore

pub fn new( global: Option<LimitedSemaphore>, factor_specific: Option<LimitedSemaphore>, factor: &'static str, app_id: Arc<str>, wait_timeout: Option<Duration>, ) -> Self

Creates a new ConnectionSemaphore.

global is an optional LimitedSemaphore shared across factors; factor_specific is an optional LimitedSemaphore for this specific factor. If either is None, that level of limiting is disabled. factor is a label used in emitted telemetry, app_id identifies the owning app for tenant-attribution in tracing events, and wait_timeout is an optional duration to wait for a permit before giving up and returning an error.

pub async fn acquire(&self) -> Result<ConnectionPermit>

Acquire both configured semaphore slots, returning a permit that holds them until dropped.

When both a global and a factor-specific semaphore are configured, this method acquires factor-specific first, then global, ensuring the global permit is never held while blocking on a factor-specific backlog.

If wait_timeout is configured and the permits cannot be acquired within that duration, an error is returned.

pub fn try_acquire(&self) -> Option<ConnectionPermit>

Attempt to acquire both configured slots without waiting. Returns None if either semaphore is exhausted.

If the global permit is acquired but the factor-specific permit is not available, the global permit is released before returning None.

Trait Implementations

impl Clone for ConnectionSemaphore

fn clone(&self) -> ConnectionSemaphore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectionSemaphore

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

Formats the value using the given formatter.