Struct LiveSketches 

pub struct LiveSketches { /* private fields */ }

Live in-process sketches (DW-092): sub-second-freshness per-route rolling window with counts, errors, and capped latency samples. Maintained inside EmbeddedAnalytics and updated synchronously on every record() call — never blocks the dataplane (atomics for counts, a short mutex over a capped vector for samples). When the window expires, the completed window’s aggregates are handed to the insights engine (if attached) for forecasting and anomaly detection.

Implementations

impl LiveSketches

pub fn new(window_size_ms: u64) -> Arc<Self>

Construct a new live-sketches store with the given window size.

pub fn set_insights(&self, engine: Arc<InsightsEngine>)

Attach the insights engine so window rotations feed it. Called once during EmbeddedAnalytics::open wiring.

pub fn window_start(&self) -> u64

The current window’s start time (wall-clock ms).

pub fn record(&self, route: &str, status: u16, duration_ms: f64, now_ms: u64)

Record one request completion into the current window. Rotates the window (handing the completed aggregates to the insights engine) when now_ms has passed the window boundary.

pub fn snapshot(&self, now_ms: u64) -> LiveSnapshot

Snapshot the current window’s per-route aggregates. Computes p50/p95/p99 from the retained latency samples (sort-and-pick, O(n log n) with n capped at 1000). This is an admin-path operation, never on the request hot path.