Struct ConcurrencyLimit 

pub struct ConcurrencyLimit { /* private fields */ }

Bounded-concurrency configuration.

Implementations

impl ConcurrencyLimit

pub fn operations(n: usize) -> Self

Limit concurrent operations (one permit per top-level call).

pub fn attempts(n: usize) -> Self

Limit concurrent attempts (one permit per attempt, retries included).

pub fn max_queued(self, n: usize) -> Self

Cap the number of waiting callers (excess is rejected).

pub fn queue_timeout(self, d: Duration) -> Self

Maximum time a caller waits in the queue before being rejected.

pub fn reject(self) -> Self

Reject immediately when saturated instead of queueing.

Trait Implementations

impl Clone for ConcurrencyLimit

fn clone(&self) -> ConcurrencyLimit

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConcurrencyLimit

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

Formats the value using the given formatter.

impl From<u32> for ConcurrencyLimit

fn from(n: u32) -> Self

Converts to this type from the input type.

impl From<usize> for ConcurrencyLimit

fn from(n: usize) -> Self

n is shorthand for ConcurrencyLimit::operations(n).