Struct ConcurrentPolicy

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

A Policy that limits the number of concurrent requests.

Implementations

impl<B, C> ConcurrentPolicy<B, C>

pub fn with_backoff(backoff: B, tracker: C) -> ConcurrentPolicy<B, C>

Create a new ConcurrentPolicy, using the given ConcurrentTracker, and the given Backoff policy.

The Backoff policy is used to backoff when the concurrent request limit is reached.

impl<C> ConcurrentPolicy<(), C>

pub const fn new(tracker: C) -> ConcurrentPolicy<(), C>

Create a new ConcurrentPolicy, using the given ConcurrentTracker.

impl ConcurrentPolicy<(), ConcurrentCounter>

pub fn max(max: usize) -> ConcurrentPolicy<(), ConcurrentCounter>

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

impl<B> ConcurrentPolicy<B, ConcurrentCounter>

pub fn max_with_backoff( max: usize, backoff: B, ) -> ConcurrentPolicy<B, ConcurrentCounter>

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

Trait Implementations

impl<B, C> Clone for ConcurrentPolicy<B, C>

where B: Clone, C: Clone,

fn clone(&self) -> ConcurrentPolicy<B, C>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<B, C> Debug for ConcurrentPolicy<B, C>

where B: Debug, C: Debug,

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

Formats the value using the given formatter.

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

where B: Backoff, Request: Send + 'static, C: ConcurrentTracker,

type Guard = <C as ConcurrentTracker>::Guard

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

type Error = <C as ConcurrentTracker>::Error

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

async fn check( &self, ctx: Context, request: Request, ) -> PolicyResult<Request, <ConcurrentPolicy<B, C> as Policy<Request>>::Guard, <ConcurrentPolicy<B, C> as Policy<Request>>::Error>

Check whether the request is allowed to proceed.