Struct SlidingWindowRateLimiter 

pub struct SlidingWindowRateLimiter { /* private fields */ }

Rate limiter using sliding window algorithm.

Examples

use chie_shared::SlidingWindowRateLimiter;

// Allow 10 requests per second
let mut limiter = SlidingWindowRateLimiter::new(1000, 10);

// First 10 requests should be allowed
for i in 0..10 {
    assert!(limiter.try_acquire(1000 + i));
}

// 11th request should be denied
assert!(!limiter.try_acquire(1010));

// After window passes, new requests allowed
assert!(limiter.try_acquire(2100));

// Check remaining capacity
let mut limiter2 = SlidingWindowRateLimiter::new(1000, 5);
limiter2.try_acquire(1000);
limiter2.try_acquire(1001);
assert_eq!(limiter2.remaining_capacity(1002), 3);

Implementations

impl SlidingWindowRateLimiter

pub fn new(window_ms: u64, max_requests: usize) -> Self

Create a new rate limiter.

Arguments

• window_ms - Window size in milliseconds
• max_requests - Maximum requests allowed in the window

pub fn is_allowed(&mut self, now_ms: i64) -> bool

Check if a request is allowed at the given time.

pub fn try_acquire(&mut self, now_ms: i64) -> bool

Try to consume a token (record a request). Returns true if the request is allowed, false if rate limit is exceeded.

pub fn current_count(&mut self, now_ms: i64) -> usize

Get the current request count in the window.

pub fn remaining_capacity(&mut self, now_ms: i64) -> usize

Get remaining capacity.

pub fn reset(&mut self)

Reset the rate limiter.

Trait Implementations

impl Clone for SlidingWindowRateLimiter

fn clone(&self) -> SlidingWindowRateLimiter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SlidingWindowRateLimiter

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

Formats the value using the given formatter.