Struct RateLimit 

pub struct RateLimit<S, PR, ReqTy, RespTy, IntoRespTy, C> { /* private fields */ }

Implementations

impl<S, PR, ReqTy, RespTy, IntoRespTy, C> RateLimit<S, PR, ReqTy, RespTy, IntoRespTy, C>

pub fn new<RLC>(inner: S, config: RLC, connection: C) -> Self

where RLC: Into<Arc<RateLimitConfig<PR, ReqTy, RespTy, IntoRespTy>>>,

Trait Implementations

impl<S, PR, ReqTy, RespTy, IntoRespTy, C> Clone for RateLimit<S, PR, ReqTy, RespTy, IntoRespTy, C>

where S: Clone, C: Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S, PR, ReqTy, RespTy, IntoRespTy, C> Service<ReqTy> for RateLimit<S, PR, ReqTy, RespTy, IntoRespTy, C>

where S: Service<ReqTy, Response = RespTy> + Clone + Send + 'static, S::Future: Send + 'static, S::Error: Send, S::Response: Send, PR: ProvideRule<ReqTy> + Clone + Send + Sync + 'static, ReqTy: Send + 'static, IntoRespTy: Into<RespTy> + 'static, RespTy: 'static, C: ConnectionLike + Clone + Send + 'static,

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

Responses given by the service.

type Error = <S as Service<ReqTy>>::Error

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<S as Service<ReqTy>>::Response, <S as Service<ReqTy>>::Error>> + Send>>

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, req: ReqTy) -> Self::Future

Process the request and return the response asynchronously.