Struct RateLimiter 

pub struct RateLimiter { /* private fields */ }

Token-bucket rate limiter.

Refills at rate_pps tokens per second. Each consume() call blocks until a token is available, providing smooth rate control.

Implementations

impl RateLimiter

pub fn new(rate_pps: u64, burst: u64) -> Self

Create a new rate limiter.

• rate_pps: target packets per second (0 = unlimited)
• burst: maximum burst size in packets

pub fn unlimited() -> Self

Create an unlimited rate limiter (no throttling).

pub fn try_consume(&mut self) -> bool

Try to consume one token. Returns true if the token was available. Does NOT block.

pub fn try_consume_batch(&mut self, n: u64) -> u64

Try to consume n tokens. Returns the number actually consumed.

pub fn consume_blocking(&mut self)

Block until a token is available, then consume it.

Uses spin-wait for sub-microsecond precision when the wait is short, and thread::yield_now for longer waits.

pub fn rate_pps(&self) -> u64

Current target rate.

pub fn is_unlimited(&self) -> bool

Whether this limiter is unlimited.

pub fn set_rate_pps(&mut self, rate_pps: u64)

Re-target the rate at runtime. Used by AdaptiveLoop to react to TX drops / ICMP-unreachable bursts without rebuilding the limiter (which would lose the bucket fill state and stutter).