Struct WorkflowLog 

pub struct WorkflowLog { /* private fields */ }

An in-memory log that accumulates WorkflowEvents for one or more workflows and exposes query helpers.

Implementations

impl WorkflowLog

pub fn new() -> Self

Creates a new, empty log.

pub fn append( &mut self, event_type: WorkflowEventType, workflow_id: impl Into<String>, message: impl Into<String>, )

Appends an event to the log, assigning it the next sequence number.

pub fn append_task( &mut self, event_type: WorkflowEventType, workflow_id: impl Into<String>, task_id: impl Into<String>, message: impl Into<String>, )

Appends a task-scoped event to the log.

pub fn len(&self) -> usize

Total number of events in the log.

pub fn is_empty(&self) -> bool

Returns true when the log contains no events.

pub fn all(&self) -> &[WorkflowEvent]

Returns a slice of all events in insertion order.

pub fn recent_errors(&self, n: usize) -> Vec<&WorkflowEvent>

Returns the n most recently appended error events (TaskFailed or Error), newest first.

pub fn events_for_workflow<'a>( &'a self, workflow_id: &str, ) -> Vec<&'a WorkflowEvent>

Returns all events for the given workflow ID.

pub fn events_of_type( &self, event_type: WorkflowEventType, ) -> Vec<&WorkflowEvent>

Returns all events matching the given event type.

pub fn error_count(&self) -> usize

Returns the number of error-type events in the log.

pub fn clear(&mut self)

Clears all events from the log and resets the sequence counter.

Trait Implementations

impl Clone for WorkflowLog

fn clone(&self) -> WorkflowLog

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowLog

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

Formats the value using the given formatter.

impl Default for WorkflowLog

fn default() -> WorkflowLog

Returns the “default value” for a type.