Struct ExecutionTelemetry 

pub struct ExecutionTelemetry {
    pub nodes_executed: usize,
    pub cpu_segments: usize,
    pub gpu_segments: usize,
    pub gpu_fallbacks: usize,
    pub backpressure_events: usize,
    pub warnings: SmallVec<[String; 8]>,
    pub graph_duration: Duration,
    pub metrics_level: MetricsLevel,
    pub node_metrics: BTreeMap<usize, NodeMetrics>,
    pub group_metrics: BTreeMap<String, NodeMetrics>,
    pub edge_metrics: BTreeMap<usize, EdgeMetrics>,
    pub trace: Option<Vec<TraceEvent>>,
}

Aggregated timing + diagnostics for a run.

Fields

nodes_executed: usize

cpu_segments: usize

gpu_segments: usize

gpu_fallbacks: usize

backpressure_events: usize

warnings: SmallVec<[String; 8]>

graph_duration: Duration

metrics_level: MetricsLevel

node_metrics: BTreeMap<usize, NodeMetrics>

Per-node-instance metrics keyed by the planned node index (NodeRef.0).

group_metrics: BTreeMap<String, NodeMetrics>

Per-group aggregate metrics keyed by group id (e.g. embedded graphs).

edge_metrics: BTreeMap<usize, EdgeMetrics>

Per-edge queue wait metrics keyed by the planned edge index.

trace: Option<Vec<TraceEvent>>

Implementations

impl ExecutionTelemetry

pub fn with_level(level: MetricsLevel) -> Self

pub fn merge(&mut self, other: ExecutionTelemetry)

pub fn record_node_duration(&mut self, node_idx: usize, duration: Duration)

pub fn record_node_cpu_duration(&mut self, node_idx: usize, duration: Duration)

pub fn record_node_perf(&mut self, node_idx: usize, sample: PerfSample)

pub fn record_node_payload_in(&mut self, node_idx: usize, bytes: Option<u64>)

pub fn record_node_payload_out(&mut self, node_idx: usize, bytes: Option<u64>)

pub fn record_edge_wait(&mut self, edge_idx: usize, duration: Duration)

pub fn record_edge_depth(&mut self, edge_idx: usize, depth: usize)

pub fn record_edge_payload(&mut self, edge_idx: usize, bytes: Option<u64>)

pub fn record_edge_gpu_transfer(&mut self, edge_idx: usize, upload: bool)

pub fn record_trace_event( &mut self, node_idx: usize, start: Duration, duration: Duration, )

pub fn aggregate_groups(&mut self, nodes: &[RuntimeNode])

Trait Implementations

impl Clone for ExecutionTelemetry

fn clone(&self) -> ExecutionTelemetry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ExecutionTelemetry

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

Formats the value using the given formatter.

impl Default for ExecutionTelemetry

fn default() -> ExecutionTelemetry

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ExecutionTelemetry

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for ExecutionTelemetry

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for ExecutionTelemetry

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for ExecutionTelemetry

impl StructuralPartialEq for ExecutionTelemetry