Struct RateLimiter 

pub struct RateLimiter { /* private fields */ }

Implementations

impl RateLimiter

pub fn new(rps: f64) -> Self

pub fn set_default_rps(&self, rps: f64)

Replace the default per-service interval. Existing per-service entries created via Self::update_limit are left at their override; only the lazily-created defaults pick up the new pace. Non-finite or non-positive rps falls back to 1.0 — the same guard as new() so a caller can’t drive the limiter into a zero-interval (= infinite-rate) state by accident.

pub async fn wait(&self, service: &str)

pub fn record_error(&self)

pub fn record_success(&self)

pub async fn update_limit(&self, service: &str, rps: f64)