Struct actix_governor::GovernorMiddleware

pub struct GovernorMiddleware<S, K: KeyExtractor, M: RateLimitingMiddleware<QuantaInstant>> { /* private fields */ }

A middleware that implements rate limiting based on the governor crate.

Trait Implementations

impl<S, B, K> Service<ServiceRequest> for GovernorMiddleware<S, K, NoOpMiddleware>where K: KeyExtractor, S: Service<ServiceRequest, Response = ServiceResponse<B>, Error = Error>, B: MessageBody,

type Response = ServiceResponse<EitherBody<B>>

Responses given by the service.

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

Errors produced by the service when polling readiness or executing call.

type Future = Either<MapOk<<S as Service<ServiceRequest>>::Future, fn(_: ServiceResponse<B>) -> ServiceResponse<EitherBody<B>>>, Ready<Result<ServiceResponse<EitherBody<B>>, <GovernorMiddleware<S, K, NoOpMiddleware> as Service<ServiceRequest>>::Error>>>

The future response value.

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

Returns Ready when the service is able to process requests.

fn call(&self, req: ServiceRequest) -> Self::Future

Process the request and return the response asynchronously.

impl<S, B, K> Service<ServiceRequest> for GovernorMiddleware<S, K, StateInformationMiddleware>where K: KeyExtractor, S: Service<ServiceRequest, Response = ServiceResponse<B>, Error = Error>, B: MessageBody, S::Future: Unpin,

Implementation using rate limit headers

type Response = ServiceResponse<EitherBody<B>>

Responses given by the service.

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

Errors produced by the service when polling readiness or executing call.

type Future = Either<Either<Either<RateLimitHeaderFut<MapOk<<S as Service<ServiceRequest>>::Future, fn(_: ServiceResponse<B>) -> ServiceResponse<EitherBody<B>>>>, WhitelistedHeaderFut<MapOk<<S as Service<ServiceRequest>>::Future, fn(_: ServiceResponse<B>) -> ServiceResponse<EitherBody<B>>>>>, Ready<Result<ServiceResponse<EitherBody<B>>, Error>>>, MapOk<<S as Service<ServiceRequest>>::Future, fn(_: ServiceResponse<B>) -> ServiceResponse<EitherBody<B>>>>

The future response value.

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

Returns Ready when the service is able to process requests.

fn call(&self, req: ServiceRequest) -> Self::Future

Process the request and return the response asynchronously.