Struct LoopMetrics 

pub struct LoopMetrics { /* private fields */ }

Standardized per-loop observations.

Implementations

impl LoopMetrics

pub fn new(name: &'static str) -> Arc<Self>

Construct a metrics handle for a loop named name (e.g. "rebalancer_loop"). The name appears as the prefix of every emitted metric; use snake_case and include the _loop suffix to match the checklist vocabulary.

pub fn name(&self) -> &'static str

pub fn observe(&self, duration: Duration)

Record a completed tick. Increments iterations_total and stores the duration for the last_iteration_duration_seconds gauge. Call regardless of success/failure — errors are tracked separately via record_error.

pub fn record_error(&self, kind: &'static str)

Increment the counter for an error kind. kind must be a short bounded label — never a formatted error string.

pub fn set_up(&self, up: bool)

Mark the loop up (driver task is running) or down (driver exited or not yet spawned).

pub fn iterations_total(&self) -> u64

pub fn last_iteration_duration(&self) -> Duration

pub fn is_up(&self) -> bool

pub fn errors_snapshot(&self) -> BTreeMap<&'static str, u64>

pub fn render_prom(&self, out: &mut String)

Append Prometheus-format exposition for this loop to out. Emits HELP/TYPE headers plus one sample per metric.

Trait Implementations

impl Debug for LoopMetrics

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

Formats the value using the given formatter.