Struct EventLog 

pub struct EventLog { /* private fields */ }

Implementations

impl EventLog

pub fn new() -> EventLog

Create a new event log (call at workflow start)

pub fn new_with_broadcast() -> (EventLog, Receiver<Event>)

Create a new event log with broadcast channel for TUI

Returns (EventLog, Receiver) tuple. Pass the receiver to TUI App. P1 Fix: Increase channel capacity from 256 to 512 events (buffer for TUI lag + fast providers).

pub fn subscribe(&self) -> Option<Receiver<Event>>

Subscribe to event broadcasts (for additional TUI observers)

Returns None if this EventLog was not created with new_with_broadcast().

pub fn attach_trace_writer(&mut self, writer: TraceWriter)

Attach a trace writer for incremental crash-resilient output.

Once attached, every event emitted via emit() is immediately flushed to the trace file. If the process crashes, the partial trace survives on disk.

pub fn emit(&self, kind: EventKind) -> u64

Emit an event (thread-safe, returns event ID)

If broadcast channel is configured, also sends to subscribers. If a trace writer is attached, the event is immediately flushed to the NDJSON trace file for crash resilience.

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

Get all events (cloned - use with_events for zero-copy access)

pub fn with_events<T>(&self, f: impl FnOnce(&[Event]) -> T) -> T

Zero-copy access to events via callback

Holds read lock for duration of callback - keep it short. Use this instead of events() when you don’t need ownership.

pub fn filter_task(&self, task_id: &str) -> Vec<Event>

Filter events by task ID (zero-copy filtering)

pub fn workflow_events(&self) -> Vec<Event>

Filter workflow-level events only (zero-copy filtering)

pub fn count_task(&self, task_id: &str) -> usize

Count events for a specific task (no allocation)

pub fn to_json(&self) -> Value

Serialize to JSON for persistence/debugging

pub fn events_since(&self, since_id: Option<u64>) -> Vec<Event>

pub fn with_events_since<R>( &self, since_id: Option<u64>, f: impl FnOnce(&[Event]) -> R, ) -> R

Iterate over events since since_id without cloning.

The closure receives a slice of events that have not yet been rendered. Uses partition_point for O(log n) lookup since event IDs are monotonically increasing.

pub fn len(&self) -> usize

Number of events

pub fn is_empty(&self) -> bool

Check if empty

Trait Implementations

impl Clone for EventLog

fn clone(&self) -> EventLog

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventLog

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

Formats the value using the given formatter.

impl Default for EventLog

fn default() -> EventLog

Returns the “default value” for a type.

impl EventEmitter for EventLog

Implement EventEmitter for EventLog (the real implementation)

fn emit(&self, kind: EventKind) -> u64

Emit an event and return its ID