Struct PostgresEventStore 

pub struct PostgresEventStore { /* private fields */ }

A3S ORM-backed PostgreSQL event store for multi-process durable hosts.

The store keeps one row per FlowEventEnvelope. Appends take the same transaction-scoped advisory lock used by earlier Flow releases before checking the latest sequence and inserting the next event. That preserves per-run event order across rolling upgrades and concurrent workers.

Implementations

impl PostgresEventStore

pub async fn hold_history( &self, run_id: &str, hold_id: &str, reason: &str, ) -> Result<()>

Persist an audit hold that prevents a run history from being pruned.

Repeating the same (run_id, hold_id, reason) is idempotent. Reusing a hold ID with another reason returns a conflict so audit intent cannot be silently replaced.

pub async fn release_history_hold( &self, run_id: &str, hold_id: &str, ) -> Result<bool>

Release one audit hold. Returns false when the hold did not exist.

pub async fn history_holds(&self, run_id: &str) -> Result<Vec<FlowHistoryHold>>

List durable audit holds for one run in stable hold-ID order.

pub async fn history_tombstone( &self, run_id: &str, ) -> Result<Option<FlowHistoryTombstone>>

Read the minimal audit tombstone retained after history deletion.

pub async fn prune_terminal_history( &self, policy: FlowHistoryRetentionPolicy, ) -> Result<FlowHistoryRetentionReport>

Delete complete eligible terminal histories in one consistent scan.

The scan takes an exclusive retention guard, locks existing run streams in stable order, preserves durable holds and linked components, writes a checksum tombstone, and only then deletes event rows. It never performs partial stream compaction.

impl PostgresEventStore

pub async fn connect(database_url: impl AsRef<str>) -> Result<Self>

Connect with the ORM’s bounded non-TLS pool and run Flow migrations.

Production hosts that require TLS or custom pool controls should create a configured PostgresExecutor and call Self::from_executor.

pub async fn connect_verified(database_url: impl AsRef<str>) -> Result<Self>

Connect and verify that the complete Flow schema was applied by a separate migrator, without acquiring DDL authority.

pub async fn from_executor(executor: PostgresExecutor) -> Result<Self>

Create a store from a configured executor and run Flow migrations.

pub async fn from_executor_verified(executor: PostgresExecutor) -> Result<Self>

Create a store from a configured executor after read-only admission of the complete Flow schema.

pub fn executor(&self) -> &PostgresExecutor

Return the executor used by this store.

Trait Implementations

impl Clone for PostgresEventStore

fn clone(&self) -> PostgresEventStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresEventStore

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

Formats the value using the given formatter.

impl FlowEventStore for PostgresEventStore

fn append<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 str, event: FlowEvent, ) -> Pin<Box<dyn Future<Output = Result<FlowEventEnvelope>> + Send + 'async_trait>>

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

Append event to run_id and return its durable envelope.

fn append_if_sequence<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 str, expected_sequence: u64, event: FlowEvent, ) -> Pin<Box<dyn Future<Output = Result<FlowEventEnvelope>> + Send + 'async_trait>>

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

Append event only when the run’s latest sequence equals expected_sequence.

fn list<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<FlowEventEnvelope>>> + Send + 'async_trait>>

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

Load the complete event history for run_id in sequence order.

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

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

List all run IDs known to the store in stable order.

fn list_due_wakeups<'life0, 'async_trait>( &'life0 self, now: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<Vec<ScheduledWakeup>>> + Send + 'async_trait>>

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

List wait timers and delayed retries due at or before now.

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

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

Return the earliest wait timer or delayed retry across active runs.

fn find_active_hooks_by_token<'life0, 'life1, 'async_trait>( &'life0 self, token: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<ActiveHookSnapshot>>> + Send + 'async_trait>>

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

Find active hooks that own an external callback token.

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

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

List active external callback hooks in stable run/hook order.