Struct ThresholdProfiler 

pub struct ThresholdProfiler { /* private fields */ }

ProfilingObserver variant that also fires alerts on per-node duration thresholds. Same timing snapshot via snapshot(); thresholds are configured per node via with_threshold(node, max_ns). On an OnNodeEnd whose elapsed > the configured cap, every registered callback runs (synchronously, on the observer’s thread).

Callbacks should be cheap and non-blocking — they run inline on the graph engine’s thread.

Implementations

impl ThresholdProfiler

pub fn new() -> Self

Empty profiler with no thresholds and no callbacks.

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

Snapshot of per-node timings (same shape as ProfilingObserver).

pub fn with_threshold(self, node: impl Into<String>, max_ns: u128) -> Self

Register a duration cap (in nanoseconds) for node. Subsequent invocations that exceed max_ns will fire every registered callback. Replaces any prior threshold for the node.

pub fn on_threshold_breached<F>(self, cb: F) -> Self

where F: Fn(&str, u128) + Send + Sync + 'static,

Add an alert callback. Multiple callbacks are supported and all fire (in registration order) on each breach. Builder-style.

Trait Implementations

impl Default for ThresholdProfiler

fn default() -> Self

Returns the “default value” for a type.

impl Observer for ThresholdProfiler

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.