Struct RunnerMetricsDelta 

#[non_exhaustive]
pub struct RunnerMetricsDelta {

    pub time_events: u64,
    pub exec_events: u64,
    pub exec_commands: u64,
    pub data_events: u64,
    pub data_commands: u64,
    pub time_events_busy_ns: u64,
    pub exec_events_busy_ns: u64,
    pub exec_commands_busy_ns: u64,
    pub data_events_busy_ns: u64,
    pub data_commands_busy_ns: u64,
    pub dispatch_busy_ns: u64,
    pub maintenance_busy_ns: u64,
    pub external_msgbus_busy_ns: u64,
    pub elapsed_ns: u64,
}

Derived deltas between two LiveNode::run runner metrics snapshots.

Values are saturating differences between two RunnerMetricsSnapshot samples. Queue depths and last-dispatch timestamps remain snapshot-only point-in-time values.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

time_events: u64

Number of time events dispatched during the sample window.

exec_events: u64

Number of execution events dispatched during the sample window.

exec_commands: u64

Number of execution commands dispatched during the sample window.

data_events: u64

Number of data events dispatched during the sample window.

data_commands: u64

Number of data commands dispatched during the sample window.

time_events_busy_ns: u64

Nanoseconds spent dispatching time events during the sample window.

exec_events_busy_ns: u64

Nanoseconds spent dispatching execution events during the sample window.

exec_commands_busy_ns: u64

Nanoseconds spent dispatching execution commands during the sample window.

data_events_busy_ns: u64

Nanoseconds spent dispatching data events during the sample window.

data_commands_busy_ns: u64

Nanoseconds spent dispatching data commands during the sample window.

dispatch_busy_ns: u64

Nanoseconds spent in the five dispatch branches during the sample window.

maintenance_busy_ns: u64

Nanoseconds spent in maintenance and reconciliation processing during the sample window.

external_msgbus_busy_ns: u64

Nanoseconds spent handling external message bus ingress during the sample window.

elapsed_ns: u64

Monotonic nanoseconds elapsed during the sample window.

Implementations

impl RunnerMetricsDelta

pub fn from_snapshots( before: RunnerMetricsSnapshot, after: RunnerMetricsSnapshot, ) -> Self

Returns the saturating delta between two runner metrics snapshots.

pub const fn total_dispatched(&self) -> u64

Returns the total messages dispatched across all runner channels.

pub fn dispatch_utilization(&self) -> f64

Returns dispatch busy time divided by elapsed time for the sample window.

Returns 0.0 when the elapsed window is zero.

pub fn loop_utilization(&self) -> f64

Returns total timed runner-loop work divided by elapsed time for the sample window.

Total work includes dispatch, maintenance, reconciliation, and external message bus ingress handling. Returns 0.0 when the elapsed window is zero.

pub fn mean_dispatch_ns(&self) -> u64

Returns mean dispatch time in nanoseconds for the sample window.

Returns zero when no dispatches were recorded.

pub fn channel_mean_dispatch_ns(&self, channel: SystemChannel) -> u64

Returns mean dispatch time in nanoseconds for channel during the sample window.

Returns zero when the channel dispatched no messages.

pub const fn total_busy_ns(&self) -> u64

Returns the total nanoseconds spent in timed runner-loop work.

Trait Implementations

impl Clone for RunnerMetricsDelta

fn clone(&self) -> RunnerMetricsDelta

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for RunnerMetricsDelta

impl Debug for RunnerMetricsDelta

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

Formats the value using the given formatter.

impl Default for RunnerMetricsDelta

fn default() -> RunnerMetricsDelta

Returns the “default value” for a type.

impl Eq for RunnerMetricsDelta

impl PartialEq for RunnerMetricsDelta

fn eq(&self, other: &RunnerMetricsDelta) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for RunnerMetricsDelta