Struct TraceRecorder 

pub struct TraceRecorder { /* private fields */ }

Thread-safe in-memory recorder for workflow trace events.

Implementations

impl TraceRecorder

pub fn new(metadata: WorkflowTraceMetadata) -> Self

Creates a new recorder with empty event history.

pub fn append_event( &self, timestamp_unix_ms: u64, kind: TraceEventKind, ) -> Result<TraceEvent, TraceRecordError>

Appends an arbitrary event to the trace.

pub fn record_node_enter( &self, timestamp_unix_ms: u64, node_id: impl Into<String>, ) -> Result<TraceEvent, TraceRecordError>

Appends a node enter event.

pub fn record_node_exit( &self, timestamp_unix_ms: u64, node_id: impl Into<String>, ) -> Result<TraceEvent, TraceRecordError>

Appends a node exit event.

pub fn record_node_error( &self, timestamp_unix_ms: u64, node_id: impl Into<String>, message: impl Into<String>, ) -> Result<TraceEvent, TraceRecordError>

Appends a node error event.

pub fn record_terminal( &self, timestamp_unix_ms: u64, status: TraceTerminalStatus, ) -> Result<TraceEvent, TraceRecordError>

Appends a workflow terminal event.

pub fn snapshot(&self) -> WorkflowTrace

Returns a snapshot of the current trace.

pub fn finalize( &self, finished_at_unix_ms: u64, ) -> Result<WorkflowTrace, TraceRecordError>

Finalizes the recorder and returns the immutable trace.

Trait Implementations

impl Clone for TraceRecorder

fn clone(&self) -> TraceRecorder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TraceRecorder

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

Formats the value using the given formatter.