Struct MultiKeyRateLimiter 

pub struct MultiKeyRateLimiter { /* private fields */ }

Rate limiter that tracks limits per key (topic, node, etc.)

Example

use mecha10::rate_limit::{MultiKeyRateLimiter, RateLimit};

let limiter = MultiKeyRateLimiter::new();

// Set limits per topic
limiter.set_limit("/camera/rgb", RateLimit::per_second(30.0)).await;
limiter.set_limit("/camera/depth", RateLimit::per_second(30.0)).await;

// Check limits
if limiter.check_and_consume("/camera/rgb").await {
    println!("Allowed");
}

Implementations

impl MultiKeyRateLimiter

pub fn new() -> Self

Create a new multi-key rate limiter with default unlimited

pub fn with_default(default: RateLimit) -> Self

Create with a default limit for all keys

pub async fn set_limit(&self, key: impl Into<String>, limit: RateLimit)

Set rate limit for a specific key

pub async fn remove_limit(&self, key: &str)

Remove rate limit for a key

pub async fn check(&self, key: &str) -> bool

Check if request for key is allowed

pub async fn check_and_consume(&self, key: &str) -> bool

Check and consume token for key

pub async fn available_tokens(&self, key: &str) -> Option<f64>

Get available tokens for a key

pub async fn get_limits(&self) -> HashMap<String, RateLimit>

Get all configured limits

pub async fn clear(&self)

Clear all limiters

Trait Implementations

impl Default for MultiKeyRateLimiter

fn default() -> Self

Returns the “default value” for a type.