Struct RpsRegistry 

pub struct RpsRegistry { /* private fields */ }

Per-service sliding-window request-rate counter.

Records one timestamp per successfully-routed request and reports the requests-per-second rate over a fixed [RPS_WINDOW]. Cheap to clone (it is an Arc-friendly wrapper around interior-mutable state) and safe to share across the proxy’s per-connection service clones.

This is the real per-service RPS signal the autoscaler consumes: the proxy records every routed request via RpsRegistry::record, and the scheduler reads RpsRegistry::rps for the same service key to drive request-rate scaling.

Implementations

impl RpsRegistry

pub fn new() -> Self

Create an empty registry.

pub async fn record(&self, service: &str)

Record a single request against service at the current instant, pruning timestamps older than the window.

pub async fn rps(&self, service: &str) -> f64

Current requests-per-second for service, averaged over the sliding window. Returns 0.0 for an unknown or idle service.

pub async fn snapshot(&self) -> HashMap<String, f64>

Snapshot of the current per-service RPS for every service seen within the window. Services whose window has fully drained report 0.0.

Trait Implementations

impl Debug for RpsRegistry

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

Formats the value using the given formatter.

impl Default for RpsRegistry

fn default() -> RpsRegistry

Returns the “default value” for a type.