Struct PostgresStore 

pub struct PostgresStore { /* private fields */ }

PostgreSQL store for Seesaw.

Provides InsightStore implementation for observability and the ES event store (via the event_store module).

Implementations

impl PostgresStore

pub fn new(pool: PgPool) -> Self

pub fn pool(&self) -> &PgPool

pub async fn is_processed(&self, event_id: Uuid) -> Result<bool>

Check if an event has already been processed (for idempotency).

Trait Implementations

impl Clone for PostgresStore

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl InsightStore for PostgresStore

fn subscribe_events<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Stream<Item = InsightEvent> + Send + Unpin>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Subscribe to live events for all workflows

fn get_workflow_tree<'life0, 'async_trait>( &'life0 self, correlation_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<WorkflowTree>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get workflow tree for visualization

fn get_stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<InsightStats>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get aggregate statistics

fn get_recent_events<'life0, 'async_trait>( &'life0 self, cursor: Option<i64>, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<InsightEvent>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get recent events with cursor-based pagination

fn get_effect_logs<'life0, 'async_trait>( &'life0 self, correlation_id: Option<Uuid>, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<EffectExecutionLog>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get effect execution logs for operational debugging.

fn get_dead_letters<'life0, 'async_trait>( &'life0 self, unresolved_only: bool, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<DeadLetterEntry>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get dead letter queue entries.

fn get_failed_workflows<'life0, 'async_trait>( &'life0 self, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<FailedWorkflow>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get workflows that currently have failures or dead letters.