Struct PostgresHistory 

pub struct PostgresHistory { /* private fields */ }

Available on crate features serve-history-postgres and serve only.

SQL-backed RunHistory. See crate::serve::history::sql for the shared schema + semantics.

Implementations

impl PostgresHistory

pub fn from_parts( pool: PgPool, idem_retention: Duration, lease_ttl: Duration, instance_id: String, stmts: Stmts, ) -> Self

Assemble from an already-connected pool (used by connect).

pub fn pool(&self) -> &PgPool

Borrow the underlying pool (tests close it to exercise fallback).

impl PostgresHistory

pub async fn connect( url: &str, idem_retention: Duration, lease_ttl: Duration, instance_id: String, ) -> Result<Self, HistoryError>

Connect, create the schema if absent, and return the backend. lease_ttl and instance_id drive instance-fenced orphan recovery (#146 H7).

Trait Implementations

impl RunHistory for PostgresHistory

fn claim_idempotency<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, key: &'life1 str, fingerprint: &'life2 str, run_id: &'life3 str, window: Duration, ) -> Pin<Box<dyn Future<Output = Result<Claim, HistoryError>> + Send + 'async_trait>>

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

Atomically claim key for run_id (or report a replay/conflict). A prior claim older than window is treated as expired and re-claimable.

fn upsert<'life0, 'life1, 'async_trait>( &'life0 self, rec: &'life1 RunRecord, ) -> Pin<Box<dyn Future<Output = Result<(), HistoryError>> + Send + 'async_trait>>

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

Insert or replace a run record.

fn get<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<RunRecord>, HistoryError>> + Send + 'async_trait>>

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

fn list<'life0, 'life1, 'async_trait>( &'life0 self, filter: &'life1 ListFilter, ) -> Pin<Box<dyn Future<Output = Result<ListPage, HistoryError>> + Send + 'async_trait>>

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

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<DeleteOutcome, HistoryError>> + Send + 'async_trait>>

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

Delete a terminal run. Non-terminal → StillRunning (caller maps to 409).

fn purge_expired<'life0, 'async_trait>( &'life0 self, retain_for: Duration, ) -> Pin<Box<dyn Future<Output = Result<usize, HistoryError>> + Send + 'async_trait>>

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

Drop terminal records finished longer than retain_for ago. Returns the number removed.

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

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

Mark non-terminal records whose owning instance’s lease has expired as failed (instance-fenced orphan recovery — never touches a live peer’s heartbeated runs, #146 H7). Returns the number recovered. The memory backend has nothing to recover (returns 0).

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

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

Heartbeat: extend the lease of this instance’s own non-terminal runs so a peer’s recover_orphans won’t reclaim them. Returns the number of leases renewed. The memory backend (single-process, unshared) is a no-op returning 0.

fn degraded(&self) -> bool

True when the backend is in fallback mode (drives /readyz). Always false for memory.