Struct EventStore 

pub struct EventStore { /* private fields */ }

Event store for durable workflow events.

Implementations

impl EventStore

pub fn new(pool: PgPool) -> Self

Create a new event store.

pub async fn send_event( &self, event_name: &str, correlation_id: &str, payload: Option<Value>, ) -> Result<Uuid>

Send an event to a workflow.

pub async fn consume_event( &self, event_name: &str, correlation_id: &str, workflow_run_id: Uuid, ) -> Result<Option<WorkflowEvent>>

Consume an event for a workflow.

pub async fn has_event( &self, event_name: &str, correlation_id: &str, ) -> Result<bool>

Check if an event exists for a workflow (without consuming).

pub async fn list_pending_events( &self, correlation_id: &str, ) -> Result<Vec<WorkflowEvent>>

List pending events for a workflow.

pub async fn cleanup_consumed_events( &self, older_than: DateTime<Utc>, ) -> Result<u64>

Clean up old consumed events.

Trait Implementations

impl WorkflowEventSender for EventStore

async fn send_event( &self, event_name: &str, correlation_id: &str, payload: Option<Value>, ) -> Result<Uuid>

Send an event to a workflow.