Struct RateLimiterRegistry 

pub struct RateLimiterRegistry { /* private fields */ }

Per-provider rate limiter registry

Implementations

impl RateLimiterRegistry

pub fn new() -> Self

Create a new rate limiter registry

pub fn register(&self, provider_id: &str, limiter: TokenBucketLimiter)

Register a rate limiter for a provider

pub fn get_or_create(&self, provider_id: &str) -> Arc<Mutex<TokenBucketLimiter>>

Get or create a rate limiter for a provider

pub fn try_acquire(&self, provider_id: &str, tokens: f64) -> bool

Try to acquire tokens for a provider

pub async fn acquire(&self, provider_id: &str, tokens: f64)

Wait until tokens are available for a provider

Trait Implementations

impl Default for RateLimiterRegistry

fn default() -> Self

Returns the “default value” for a type.