Struct RpsController 

pub struct RpsController { /* private fields */ }

RPS (Requests Per Second) controller

Controls request rate to maintain a target RPS.

Implementations

impl RpsController

pub fn new(target_rps: f64) -> Self

Create a new RPS controller

pub async fn set_target_rps(&self, rps: f64)

Set target RPS

pub async fn get_target_rps(&self) -> f64

Get target RPS

pub async fn get_current_rps(&self) -> f64

Get current RPS (calculated over last second)

pub async fn wait_for_slot(&self)

Wait for next request slot (rate limiting)

This will sleep if necessary to maintain the target RPS.

pub async fn record_request(&self)

Record a request

Updates the current RPS calculation.

pub async fn get_request_count(&self) -> u64

Get request count since last reset

Trait Implementations

impl Clone for RpsController

fn clone(&self) -> RpsController

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RpsController

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

Formats the value using the given formatter.