Struct RpsLimiter 

pub struct RpsLimiter { /* private fields */ }

Shared request-rate limiter used to cap aggregate throughput across all VUs.

Wraps a governor token-bucket so VUs can .acquire().await one permit per request. Permits refill smoothly at the configured rate, so callers see a steady drip rather than a once-per-second burst.

The limiter is intended to be shared across many VUs behind an Arc and is Send + Sync.

Implementations

impl RpsLimiter

pub fn new(rps: usize) -> Option<Arc<Self>>

Constructs a new limiter that permits at most rps requests per second.

Returns None if rps is zero or does not fit in u32. Callers should interpret None as “no rate limit configured” and skip wiring the limiter into VUs.

pub async fn acquire(&self)

Awaits until one permit is available, then claims it.

Callers should typically wrap this in a tokio::select! against a cancellation token so VUs do not block past the end of a run.