Struct CachedRateLimits

pub struct CachedRateLimits(/* private fields */);

A thread-safe cache of rate limits with automatic expiration handling.

CachedRateLimits wraps a RateLimits collection with a mutex to allow safe concurrent access from multiple threads. It automatically removes expired rate limits when retrieving the current limits.

This is useful for maintaining a shared set of rate limits across multiple processing threads or tasks.

Implementations

impl CachedRateLimits

pub fn new() -> Self

Creates a new, empty instance without any rate limits.

pub fn add(&self, limit: RateLimit)

Adds a rate limit to this collection.

This is a thread-safe wrapper around RateLimits::add.

pub fn merge(&self, limits: RateLimits)

Merges rate limits from another collection into this one.

This is a thread-safe wrapper around RateLimits::merge.

pub fn current_limits(&self) -> Arc<RateLimits>

Returns a reference to the current rate limits.

This method automatically removes any expired rate limits before returning, ensuring that only active limits are included in the result.

Trait Implementations

impl Debug for CachedRateLimits

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for CachedRateLimits

fn default() -> CachedRateLimits

Returns the “default value” for a type.