Struct ConcurrentLimiter 

pub struct ConcurrentLimiter { /* private fields */ }

Concurrent request limiter.

Limits the number of simultaneous in-flight requests per key. Unlike rate limiting, this tracks active requests that haven’t completed yet.

Example

use oc_ratelimit_advanced::ConcurrentLimiter;

let limiter = ConcurrentLimiter::new(10); // Max 10 concurrent requests

// Acquire a permit
if let Some(permit) = limiter.try_acquire("user:123") {
    // Process request...
    // Permit is automatically released when dropped
}

Implementations

impl ConcurrentLimiter

pub fn new(max_concurrent: u32) -> Self

Create a new concurrent limiter.

pub fn try_acquire(&self, key: &str) -> Option<ConcurrentPermit>

Try to acquire a permit for the given key.

Returns Some(ConcurrentPermit) if successful, None if at limit. The permit automatically releases when dropped.

pub async fn acquire(&self, key: &str) -> ConcurrentPermit

Acquire a permit, waiting if necessary.

pub async fn acquire_timeout( &self, key: &str, timeout: Duration, ) -> Option<ConcurrentPermit>

Acquire a permit with a timeout.

pub fn current_count(&self, key: &str) -> u32

Get the current count of active requests for a key.

pub fn max_concurrent(&self) -> u32

Get the maximum concurrent requests allowed.

pub fn remaining(&self, key: &str) -> u32

Get remaining slots for a key.

Trait Implementations

impl Clone for ConcurrentLimiter

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ConcurrentLimiter

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

Formats the value using the given formatter.