Struct ActorMetrics 

pub struct ActorMetrics { /* private fields */ }

Live counters, shared between the actor and the handle.

Fixed size, no allocation, no lock. The actor updates; anyone may read.

Implementations

impl ActorMetrics

pub fn new() -> Self

pub fn record_turn(&self, high_depth: usize, low_depth: usize)

Sample both queue depths. Called before the turn, not after: after the turn the queue reflects what arrived during it, which is a different and much less useful quantity.

pub fn record_priority_choice(&self, took_high: bool, low_queued: usize)

Record which tier the select! chose, and what was waiting.

low_queued is the depth sampled before the select!, so it is the backlog the turn found on arrival. By the time a high-priority arm fires the low queue may have grown; using the pre-select reading keeps this consistent with every other depth figure in this module and makes the counter conservative — it never invents starvation from work that arrived after the choice was made.

A low-priority turn resets the run rather than decrementing it: the question is “how many turns did one low-priority command wait”, and that is a run length, not a balance.

pub fn record_hold(&self, kind: CommandKind, held: Duration)

pub fn snapshot(&self) -> MetricsSnapshot

A consistent-enough picture for a dashboard.

Not a torn-read-free snapshot, and it does not pretend to be: the actor keeps running while this walks the array, so two kinds may be read one turn apart. Locking the actor to produce a report would make the observer a source of the latency it is measuring.

Trait Implementations

impl Debug for ActorMetrics

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

Formats the value using the given formatter.

impl Default for ActorMetrics

fn default() -> ActorMetrics

Returns the “default value” for a type.