pub struct EngineStats {
pub frontier_len: usize,
pub bus_len: usize,
pub pending_async: usize,
pub slot_table_occupied: usize,
pub ingress_depth: usize,
pub outbound_queue_depth: usize,
pub event_subscriptions: usize,
pub registered_components: usize,
pub graph_slots: usize,
}Expand description
Point-in-time hot-path counters for dashboards + saturation detection. Not synchronized against an in-flight poll cycle.
Fields§
§frontier_len: usize(OpRef, ExecId) pairs on the frontier. Climbing → poll
loop falling behind ingress.
bus_len: usizeEvents queued on the typed bus awaiting routing.
pending_async: usizeSuspended async commands. Approaching
NodeConfig.max_pending_async → cap pressure.
slot_table_occupied: usize(NodeSiteId, ExecId) entries holding a value.
ingress_depth: usizeApproximate MPMC ingress depth.
outbound_queue_depth: usizeEnvelopes queued for next outbound drain.
event_subscriptions: usizeEvent kinds with at least one subscriber.
registered_components: usizeNumber of registered components.
graph_slots: usizeNumber of installed graphs.
Trait Implementations§
Source§impl Clone for EngineStats
impl Clone for EngineStats
Source§fn clone(&self) -> EngineStats
fn clone(&self) -> EngineStats
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreimpl Copy for EngineStats
Source§impl Debug for EngineStats
impl Debug for EngineStats
Source§impl Default for EngineStats
impl Default for EngineStats
Source§fn default() -> EngineStats
fn default() -> EngineStats
Returns the “default value” for a type. Read more
impl Eq for EngineStats
Source§impl PartialEq for EngineStats
impl PartialEq for EngineStats
Source§fn eq(&self, other: &EngineStats) -> bool
fn eq(&self, other: &EngineStats) -> bool
Tests for
self and other values to be equal, and is used by ==.impl StructuralPartialEq for EngineStats
Auto Trait Implementations§
impl Freeze for EngineStats
impl RefUnwindSafe for EngineStats
impl Send for EngineStats
impl Sync for EngineStats
impl Unpin for EngineStats
impl UnsafeUnpin for EngineStats
impl UnwindSafe for EngineStats
Blanket Implementations§
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
Mutably borrows from an owned value. Read more
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§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
Compare self to
key and return true if they are equal.impl<T> ErasedComponent for T
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request