Struct Status 

pub struct Status { /* private fields */ }

Shared, mutable operational state. Cheap to update concurrently from the observer; snapshotted to JSON for the /status endpoint.

Implementations

impl Status

pub fn new(indexes: impl IntoIterator<Item = IndexName>, now: Instant) -> Self

A fresh status with every configured index Pending. now is the start instant uptime is measured from.

pub fn in_flight(&self) -> u64

Changes captured but not yet committed — the queue/back-pressure signal. A cheap two-atomic read, safe to call from a metrics collection thread (e.g. an observable-gauge callback in the binary).

pub fn snapshot(&self) -> StatusSnapshot

A point-in-time, serializable view of the status for the HTTP endpoint.

Trait Implementations

impl Debug for Status

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

Formats the value using the given formatter.