Struct EventLog 

pub struct EventLog { /* private fields */ }

Event log - wraps an event store with subscription support

Implementations

impl EventLog

pub fn new(store: Arc<dyn EventStore>) -> Self

Create a new event log with the given store

pub fn in_memory() -> Self

Create an in-memory event log (for testing)

pub async fn append(&self, event: ExecutionEvent) -> Result<EventLogEntry>

Append an event

pub async fn get_by_execution( &self, execution_id: &ExecutionId, ) -> Result<Vec<EventLogEntry>>

Get events for an execution

pub async fn get_after( &self, after_sequence: u64, limit: usize, ) -> Result<Vec<EventLogEntry>>

Get events after a sequence number (for polling/streaming)

pub async fn latest_sequence(&self) -> Result<u64>

Get the latest sequence number

pub fn store(&self) -> &Arc<dyn EventStore>

Get access to the underlying store