Struct tower::limit::concurrency::GlobalConcurrencyLimitLayer

pub struct GlobalConcurrencyLimitLayer { /* private fields */ }

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 copy 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.