Struct WindowController 

pub struct WindowController { /* private fields */ }

Shared admission gate for one band’s closed-loop workers.

Implementations

impl WindowController

pub fn new(config: &BandConfig) -> Self

Build the controller for config. The window opens at offset 0.0; callers pass offsets measured from the first sampled request’s origin.

pub fn with_bounds(min_samples: usize, min_wall_s: f64) -> Self

A controller with explicit bounds, for the warmup phase (§4.4.2: exactly 2 × c requests, no wall-clock floor) and for tests.

pub fn try_admit(&mut self, now_s: f64) -> Option<usize>

§4.4.2 — “termination is whichever bound is satisfied last”.

Returns the index reserved for a new request, or None once the window has closed. §4.4.7: no new request is issued at or after T, and T is stamped here, once, at the first refusal.

pub fn try_admit_with_in_flight(&mut self, now_s: f64) -> Option<(usize, usize)>

Self::try_admit, also returning the in-flight count including this request, read under the same lock that made the admission decision.

A caller that admits, unlocks, and then asks for in_flight() reads a number from a different instant. The per-request in-flight figure is the evidence that the client was concurrent, so it must not be a racy guess.

pub fn complete(&mut self, now_s: f64) -> bool

Record a completion at now_s. Returns true when this request completed during the drain, i.e. after the window closed.

pub fn peak_in_flight(&self) -> usize

Peak concurrent requests the client had in flight. This is the client’s number and is named as such: max_in_flight in §4.4.9 is what the server admitted, which only the server can report.

pub fn issued(&self) -> usize

Requests admitted so far.

pub fn in_flight(&self) -> usize

Requests currently outstanding.

pub fn is_closed(&self) -> bool

Whether the window has closed.

pub fn report(&self) -> WindowReport

Finalise the band. window_close_s defaults to the last completion when the window never closed (a run cut short), which yields drain_ms = 0 rather than a negative number.

Trait Implementations

impl Clone for WindowController

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WindowController

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

Formats the value using the given formatter.