Struct GlobalConcurrencyLimitLayer 

pub struct GlobalConcurrencyLimitLayer { /* private fields */ }

Available on crate feature limit only.

Enforces a limit on the concurrent number of requests the underlying service can handle.

Unlike ConcurrencyLimitLayer, which enforces a per-service concurrency limit, this layer accepts a owned semaphore (Arc<Semaphore>) which can be shared across multiple services.

Cloning this layer will not create a new semaphore.

Implementations

impl GlobalConcurrencyLimitLayer

pub fn new(max: usize) -> Self

Create a new GlobalConcurrencyLimitLayer.

pub fn with_semaphore(semaphore: Arc<Semaphore>) -> Self

Create a new GlobalConcurrencyLimitLayer from a Arc<Semaphore>

Trait Implementations

impl Clone for GlobalConcurrencyLimitLayer

fn clone(&self) -> GlobalConcurrencyLimitLayer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GlobalConcurrencyLimitLayer

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

Formats the value using the given formatter.

impl<S> Layer<S> for GlobalConcurrencyLimitLayer

type Service = ConcurrencyLimit<S>

The wrapped service

fn layer(&self, service: S) -> Self::Service

Wrap the given service with the middleware, returning a new service that has been decorated with the middleware.

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 8 bytes