Struct PostgresPendingStore 

pub struct PostgresPendingStore { /* private fields */ }

PostgreSQL-backed PendingAdjudicationPort implementation.

Uses the same r2d2 pool as PostgresPersistenceStore. Each method borrows a pooled connection for the duration of a single non-transactional statement (auto-commit). Serialization is provided by the per-agent write lock in EngineHandle.

Implementations

impl PostgresPendingStore

pub fn new(pool: Pool<PostgresConnectionManager<NoTls>>) -> Self

Create a pending store sharing the same connection pool.

Trait Implementations

impl PendingAdjudicationPort for PostgresPendingStore

fn list_queued_orphan_claims( &self, ) -> Result<Vec<OrphanedQueuedClaim>, PostgresStoreError>

Detect QueuedForAdjudication claims with no matching pending row (Postgres adapter).

Same approach as SQLite: cross-table query joining ledger_entries + claims + pending_adjudications.

type Error = PostgresStoreError

fn insert_pending( &self, row: &PendingAdjudicationRow, ) -> Result<(), PostgresStoreError>

Persist a new pending-adjudication row (status = ‘pending’, expires_at = NULL).

fn get_pending( &self, handle_id: Uuid, ) -> Result<Option<PendingAdjudicationRow>, PostgresStoreError>

Lookup a pending row by its handle_id. Returns None if not found.

fn list_pending( &self, agent_id: Option<&AgentId>, ) -> Result<Vec<PendingAdjudicationRow>, PostgresStoreError>

List all pending rows for an agent (or all agents if agent_id is None). Ordered by queued_at ASC.

fn list_expired( &self, now: DateTime<Utc>, ) -> Result<Vec<PendingAdjudicationRow>, PostgresStoreError>

List all rows whose expires_at is not NULL, expires_at <= now, and status = 'pending'. Used by the sweep use-case. Ordered by expires_at ASC.

fn mark_resolved(&self, handle_id: Uuid) -> Result<(), PostgresStoreError>

Mark a pending row as resolved (status = ‘resolved’). Used by the verdict-apply step.

fn mark_expired(&self, handle_id: Uuid) -> Result<(), PostgresStoreError>

Mark a pending row as expired (status = ‘expired’). Used by the sweep and lazy expiry path.