Struct solana_streamer::nonblocking::keyed_rate_limiter::KeyedRateLimiter

pub struct KeyedRateLimiter<K> { /* private fields */ }

Implementations

impl<K> KeyedRateLimiter<K>

where K: Eq + Hash,

pub fn new(limit: u64, interval: Duration) -> Self

Create a keyed rate limiter with limit count with a rate limit interval

pub fn check_and_update(&self, key: K) -> bool

Check if the connection from the said key is allowed to pass through the rate limiter. When it is allowed, the rate limiter state is updated to reflect it has been allowed. For a unique request, the caller should call it only once when it is allowed.

pub fn retain_recent(&self)

retain only keys whose throttle start date is within the throttle interval. Otherwise drop them as inactive

pub fn len(&self) -> usize

Returns the number of “live” keys in the rate limiter.

pub fn is_empty(&self) -> bool

Returns true if the rate limiter has no keys in it.