Struct DistributedRateLimit 

pub struct DistributedRateLimit {
    pub name: &'static str,
    pub max: u32,
    pub window_secs: u32,
    pub policy: FailurePolicy,
}

Cluster-wide limiter. Build as a static and call from handlers:

static LOGIN_RATE: DistributedRateLimit =
    DistributedRateLimit::new("login", 10, 60).fail_closed();

// in the handler:
LOGIN_RATE.check(&ctx).await?;

Fields

name: &'static str

max: u32

window_secs: u32

policy: FailurePolicy

Implementations

impl DistributedRateLimit

pub const fn new(name: &'static str, max: u32, window_secs: u32) -> Self

pub const fn fail_closed(self) -> Self

Reject with 503 when the backend is down (instead of letting traffic through).

pub async fn check(&self, ctx: &RequestContext) -> Result<(), Error>