Struct ConcurrentPolicy

pub struct ConcurrentPolicy<B> { /* private fields */ }

Available on crate feature limit only.

A policy that limits the number of concurrent requests.

Implementations

impl ConcurrentPolicy<()>

pub fn new(max: usize) -> Self

Create a new concurrent policy, which aborts the request if the limit is reached.

impl<B> ConcurrentPolicy<B>

pub fn with_backoff(max: usize, backoff: B) -> Self

Create a new concurrent policy, which backs off if the limit is reached, using the given backoff policy.

Trait Implementations

impl<B> Clone for ConcurrentPolicy<B>

where B: Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<B: Debug> Debug for ConcurrentPolicy<B>

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

Formats the value using the given formatter.

impl<Request> Policy<Request> for ConcurrentPolicy<()>

type Guard = ConcurrentGuard

The guard type that is returned when the request is allowed to proceed.

type Error = LimitReached

The error type that is returned when the request is not allowed to proceed, and should be aborted.

async fn check(&self, _: &mut Request) -> PolicyOutput<Self::Guard, Self::Error>

Check whether the request is allowed to proceed.

impl<B, Request> Policy<Request> for ConcurrentPolicy<B>

where B: Backoff,

type Guard = ConcurrentGuard

The guard type that is returned when the request is allowed to proceed.

type Error = Infallible

The error type that is returned when the request is not allowed to proceed, and should be aborted.

async fn check(&self, _: &mut Request) -> PolicyOutput<Self::Guard, Self::Error>

Check whether the request is allowed to proceed.