Struct BatchController 

pub struct BatchController { /* private fields */ }

Adaptive batch window controller based on M/G/1 queueing model.

Estimates arrival rate λ and service time E[S] from observations, then computes the optimal batch window τ to maintain stability (ρ < 1) while minimizing latency.

Implementations

impl BatchController

pub fn new() -> Self

Create a new controller with sensible defaults.

• alpha: EMA smoothing (default 0.2)
• tau_min: minimum batch window (default 1ms)
• tau_max: maximum batch window (default 50ms)
• headroom: stability margin (default 2.0, keeps ρ ≤ 0.5)

pub fn observe_arrival(&mut self, now: Instant)

Record an event arrival, updating the inter-arrival estimate.

pub fn observe_service(&mut self, duration: Duration)

Record a service (render) time observation.

pub fn lambda_est(&self) -> f64

Estimated arrival rate λ (events/second).

pub fn service_est_s(&self) -> f64

Estimated service time E[S] (seconds).

pub fn rho_est(&self) -> f64

Estimated utilization ρ = λ × E[S].

pub fn tau_s(&self) -> f64

Compute the optimal batch window τ (seconds).

τ = clamp(E[S] × headroom, τ_min, τ_max)

When ρ approaches 1, τ increases to maintain stability.

pub fn tau(&self) -> Duration

Compute the optimal batch window as a Duration.

pub fn is_stable(&self) -> bool

Check if the system is stable (ρ < 1).

pub fn observations(&self) -> u64

Number of observations recorded.

Trait Implementations

impl Clone for BatchController

fn clone(&self) -> BatchController

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BatchController

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

Formats the value using the given formatter.

impl Default for BatchController

fn default() -> Self

Returns the “default value” for a type.