Struct EventEmitter 

pub struct EventEmitter { /* private fields */ }

Event emitter - collects and filters events during execution

Supports optional persistence to EventLog (INV-PERSIST-002: Event Immutability). When an EventLog is configured, events are persisted before being added to the in-memory buffer.

Implementations

impl EventEmitter

pub fn new() -> Self

Create a new EventEmitter

pub fn with_mode(mode: StreamMode) -> Self

Create a new EventEmitter with a specific mode

pub fn with_persistence( event_log: Arc<EventLog>, execution_id: ExecutionId, ) -> Self

Create an EventEmitter with persistence support

Events will be persisted to the EventLog before being added to the buffer. This ensures durability (INV-PERSIST-002).

pub fn set_mode(&mut self, mode: StreamMode)

Set the stream mode

pub fn set_event_log( &mut self, event_log: Arc<EventLog>, execution_id: ExecutionId, )

Enable persistence with an event log

pub fn emit(&self, event: StreamEvent)

Emit an event (filtered by mode)

If persistence is configured, the event is persisted to the EventLog BEFORE being added to the in-memory buffer. This ensures durability.

pub fn emit_force(&self, event: StreamEvent)

Emit an event unconditionally (ignores mode)

pub fn drain(&self) -> Vec<StreamEvent>

Get all collected events

pub fn mode(&self) -> StreamMode

Get the current stream mode

Trait Implementations

impl Clone for EventEmitter

fn clone(&self) -> EventEmitter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventEmitter

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

Formats the value using the given formatter.

impl Default for EventEmitter

fn default() -> Self

Returns the “default value” for a type.