Struct GraphEventRecorder 

pub struct GraphEventRecorder { /* private fields */ }

Captures the durable executor’s GraphEvent stream for inspection.

Wraps a CollectingSink; hand its sink to CompiledGraph::with_event_sink (or use run_recorded, which wires it for you) so a run’s events are recorded, then read them back as raw events, kind strings, or a StreamCollector of higher-level projections.

Implementations

impl GraphEventRecorder

pub fn new() -> Self

Creates an empty recorder.

pub fn sink(&self) -> Arc<dyn GraphEventSink>

An Arc-wrapped event sink to hand to CompiledGraph::with_event_sink.

pub fn events(&self) -> Vec<GraphEvent>

A snapshot of the recorded events, in emission order.

pub fn kinds(&self) -> Vec<String>

The kind() string of each recorded event, in emission order.

pub fn collector(&self) -> StreamCollector

A StreamCollector over the events recorded so far.

Trait Implementations

impl Clone for GraphEventRecorder

fn clone(&self) -> GraphEventRecorder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for GraphEventRecorder

fn default() -> GraphEventRecorder

Returns the “default value” for a type.