Struct NodeMetrics 

#[non_exhaustive]
pub struct NodeMetrics { /* private fields */ }

Per node metrics aggregated by fixed and dynamic collectors.

These metrics are updated via the Telemetry trait and represent simple counters and latency aggregates.

Implementations

impl NodeMetrics

pub const fn new() -> Self

Create a new zero initialized metrics record.

pub const fn processed(&self) -> &u64

Returns the number of items successfully processed by the node.

pub const fn dropped(&self) -> &u64

Returns the number of items dropped by the node.

pub const fn ingress(&self) -> &u64

Returns the number of ingress messages observed by the node.

pub const fn egress(&self) -> &u64

Returns the number of egress messages emitted by the node.

pub const fn lat_sum(&self) -> &u64

Returns the sum of all recorded latencies in nanoseconds.

pub const fn lat_cnt(&self) -> &u64

Returns the number of latency samples recorded.

pub const fn lat_max(&self) -> &u64

Returns the maximum latency observed in nanoseconds.

pub const fn deadline_miss_count(&self) -> &u64

Returns the number of deadline misses observed for this node.

pub fn inc_processed(&mut self, delta: u64)

Increment processed by delta (saturating).

pub fn dec_processed(&mut self, delta: u64)

Subtract from processed (saturating at zero).

pub fn set_processed(&mut self, v: u64)

Set processed to v.

pub fn inc_dropped(&mut self, delta: u64)

Increment dropped by delta (saturating).

pub fn dec_dropped(&mut self, delta: u64)

Subtract from dropped (saturating at zero).

pub fn set_dropped(&mut self, v: u64)

Set dropped to v.

pub fn inc_ingress(&mut self, delta: u64)

Increment ingress by delta (saturating).

pub fn dec_ingress(&mut self, delta: u64)

Subtract from ingress (saturating at zero).

pub fn set_ingress(&mut self, v: u64)

Set ingress to v.

pub fn inc_egress(&mut self, delta: u64)

Increment egress by delta (saturating).

pub fn dec_egress(&mut self, delta: u64)

Subtract from egress (saturating at zero).

pub fn set_egress(&mut self, v: u64)

Set egress to v.

pub fn record_latency_ns(&mut self, value_ns: u64)

Record a latency sample in nanoseconds.

This updates lat_sum, lat_cnt, and lat_max. Uses saturating addition to avoid overflow on long running systems.

pub fn merge_from(&mut self, other: &Self)

Merge another NodeMetrics into self. This uses saturating addition for counters and takes the maximum for latency max.

pub fn inc_deadline_miss_count(&mut self, delta: u64)

Increment the deadline miss counter by delta (saturating).

pub fn reset(&mut self)

Reset all counters and aggregates to zero.

Trait Implementations

impl Clone for NodeMetrics

fn clone(&self) -> NodeMetrics

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodeMetrics

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

Formats the value using the given formatter.

impl Default for NodeMetrics

fn default() -> Self

Returns the “default value” for a type.

impl Copy for NodeMetrics