#[non_exhaustive]pub struct RunnerMetricsSnapshot {
pub time_events: RunnerChannelMetricsSnapshot,
pub exec_events: RunnerChannelMetricsSnapshot,
pub exec_commands: RunnerChannelMetricsSnapshot,
pub data_events: RunnerChannelMetricsSnapshot,
pub data_commands: RunnerChannelMetricsSnapshot,
pub dispatch_busy_ns: u64,
pub maintenance_busy_ns: u64,
pub external_msgbus_busy_ns: u64,
pub elapsed_ns: u64,
}Expand description
Primitive metrics for LiveNode::run dispatch and loop work after startup.
Rates, mean dispatch time, backlog pressure, and utilization are derived by callers from
successive snapshots. Values reset each time LiveNode::run enters steady state.
Residual channel dispatch during shutdown grace is included, but the final post-loop
drain is not. Snapshots are lock-free and may not be a consistent cross-field view.
Fields (Non-exhaustive)§
This struct is marked as non-exhaustive
Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.time_events: RunnerChannelMetricsSnapshotTime event channel metrics.
exec_events: RunnerChannelMetricsSnapshotExecution event channel metrics.
exec_commands: RunnerChannelMetricsSnapshotExecution command channel metrics.
data_events: RunnerChannelMetricsSnapshotData event channel metrics.
data_commands: RunnerChannelMetricsSnapshotData command channel metrics.
dispatch_busy_ns: u64Cumulative nanoseconds spent in the five dispatch branches.
maintenance_busy_ns: u64Cumulative nanoseconds spent in maintenance and reconciliation report processing.
external_msgbus_busy_ns: u64Cumulative nanoseconds spent handling external message bus ingress.
elapsed_ns: u64Monotonic nanoseconds since the steady-state runner loop started.
Trait Implementations§
Source§impl Clone for RunnerMetricsSnapshot
impl Clone for RunnerMetricsSnapshot
Source§fn clone(&self) -> RunnerMetricsSnapshot
fn clone(&self) -> RunnerMetricsSnapshot
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreimpl Copy for RunnerMetricsSnapshot
Source§impl Debug for RunnerMetricsSnapshot
impl Debug for RunnerMetricsSnapshot
Source§impl Default for RunnerMetricsSnapshot
impl Default for RunnerMetricsSnapshot
Source§fn default() -> RunnerMetricsSnapshot
fn default() -> RunnerMetricsSnapshot
impl Eq for RunnerMetricsSnapshot
Source§impl PartialEq for RunnerMetricsSnapshot
impl PartialEq for RunnerMetricsSnapshot
impl StructuralPartialEq for RunnerMetricsSnapshot
Auto Trait Implementations§
impl Freeze for RunnerMetricsSnapshot
impl RefUnwindSafe for RunnerMetricsSnapshot
impl Send for RunnerMetricsSnapshot
impl Sync for RunnerMetricsSnapshot
impl Unpin for RunnerMetricsSnapshot
impl UnsafeUnpin for RunnerMetricsSnapshot
impl UnwindSafe for RunnerMetricsSnapshot
Blanket Implementations§
impl<T> Allocation for T
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key and return true if they are equal.