Struct MemoryLimit

pub struct MemoryLimit<T, M>
where
    M: AvailableMemory,
{ /* private fields */ }

Enforces a limit on the underlying service when a memory threshold is met.

Implementations

impl<T, M> MemoryLimit<T, M>

where M: AvailableMemory,

pub fn new( inner: T, threshold: Threshold, mem_checker: M, retry_interval: Duration, ) -> Self

Create a new memory limiter.

pub fn get_ref(&self) -> &T

Get a reference to the inner service

pub fn get_mut(&mut self) -> &mut T

Get a mutable reference to the inner service

pub fn into_inner(self) -> T

Consume self, returning the inner service

Trait Implementations

impl<S: Clone, M> Clone for MemoryLimit<S, M>

where M: AvailableMemory,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug, M> Debug for MemoryLimit<T, M>

where M: AvailableMemory + Debug,

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

Formats the value using the given formatter.

impl<S, Request, M> Service<Request> for MemoryLimit<S, M>

where S: Service<Request>, M: AvailableMemory, S::Error: Into<BoxError>,

type Response = <S as Service<Request>>::Response

Responses given by the service.

type Error = Box<dyn Error + Sync + Send>

Errors produced by the service.

type Future = ResponseFuture<<S as Service<Request>>::Future>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, request: Request) -> Self::Future

Process the request and return the response asynchronously.