Struct LeakyBucket 

struct LeakyBucket {
    level: AtomicU64,
    capacity: u64,
    leak_rate: u64,
    last_leak: RwLock<Instant>,
}

Leaky bucket rate limiter state.

Fields

level: AtomicU64

Current water level (pending requests).

capacity: u64

Maximum capacity.

leak_rate: u64

Leak rate (requests per second).

last_leak: RwLock<Instant>

Last leak time.

Implementations

impl LeakyBucket

fn new(capacity: u64, leak_rate: u64) -> Self

fn try_acquire(&self) -> RateLimitResult<()>

fn leak(&self)

fn current_level(&self) -> u64

Trait Implementations

impl Debug for LeakyBucket

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

Formats the value using the given formatter.