Struct ConcurrentRateLimiter 

pub struct ConcurrentRateLimiter { /* private fields */ }

A concurrent rate limiter that enforces a global rate limit across multiple concurrent streams. Uses a semaphore for concurrency control and an atomic timestamp to ensure min_interval between ANY two requests globally. Lock-free: uses AtomicU64 CAS loop instead of a mutex for the timestamp.

Implementations

impl ConcurrentRateLimiter

pub fn new(requests_per_second: u32, max_concurrent: usize) -> Self

Create a new concurrent rate limiter.

Arguments

• requests_per_second - Target requests per second rate limit
• max_concurrent - Maximum concurrent requests allowed

pub async fn acquire(&self) -> OwnedSemaphorePermit

Acquire a rate limit permit. Waits for both:

1. A semaphore permit (concurrency limit)
2. The global rate limit interval since last request