Struct RateLimitLayer 

pub struct RateLimitLayer { /* private fields */ }

Token-bucket rate limiter.

Implementations

impl RateLimitLayer

pub fn new(capacity: f64, per_second: f64) -> Self

Create a rate limiter allowing capacity burst requests with a sustained rate of per_second requests/sec.

Trait Implementations

impl ProxyLayer for RateLimitLayer

fn on_request<'life0, 'async_trait>( &'life0 self, request: ProxyRequest, ) -> Pin<Box<dyn Future<Output = ProxyResult<LayerAction>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Process an incoming request. Return Forward to pass it on, or Respond to short-circuit with an immediate response.

fn name(&self) -> &str

Human-readable name for logging.

fn on_response<'life0, 'async_trait>( &'life0 self, response: ProxyResponse, ) -> Pin<Box<dyn Future<Output = ProxyResult<ProxyResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Process a response before it’s sent back to the client. Called in reverse layer order.