Struct ProfilingObserver 

pub struct ProfilingObserver { /* private fields */ }

Per-node timing aggregator. Pairs OnNodeStart / OnNodeEnd events keyed by (run_id, step, node) to compute durations.

Implementations

impl ProfilingObserver

pub fn new() -> Self

Empty profiler.

pub fn snapshot(&self) -> HashMap<String, NodeTiming>

Snapshot of per-node timings.

Trait Implementations

impl Default for ProfilingObserver

fn default() -> Self

Returns the “default value” for a type.

impl Observer for ProfilingObserver

fn on_event(&self, event: &Event)

Called for every event emitted during execution. Implementations should be cheap and non-blocking — a slow observer slows execution.