Struct PostgresDovecote 

pub struct PostgresDovecote { /* private fields */ }

PostgreSQL adapter for Dovecote’s durable event and delivery schema.

Implementations

impl PostgresDovecote

pub fn new(pool: PgPool) -> Self

Creates an adapter using the supplied SQLx pool.

pub fn pool(&self) -> &PgPool

Borrows the pool used by this adapter.

pub async fn enqueue<'c>( &self, transaction: &mut Transaction<'c, Postgres>, event: NewEvent, ) -> Result<EnqueueOutcome, EnqueueError>

Enqueues an event in the caller-owned transaction.

pub async fn import_for_migration<'c>( &self, transaction: &mut Transaction<'c, Postgres>, event: NewEvent, state: ImportedDeliveryState, ) -> Result<ImportOutcome, ImportError>

Imports one already-validated event and its legacy delivery state in the caller-owned transaction. This is migration infrastructure, not a replacement for Self::enqueue.

pub async fn finalize_pending_delivery_for_migration<'c>( &self, transaction: &mut Transaction<'c, Postgres>, row_id: RowId, delivered_at: OffsetDateTime, ) -> Result<FinalizeOutcome, FinalizeError>

Records the legacy publisher’s authoritative delivery time for a canonical pending migration import. This operation is migration infrastructure, not an ordinary acknowledgement shortcut.

pub async fn check_schema(&self) -> Result<(), SchemaError>

Verifies that the pool’s current PostgreSQL schema satisfies Dovecote migration version 1.

pub async fn page( &self, after_row_id: Option<RowId>, limit: Limit, ) -> Result<Vec<PagedEvent>, PageError>

Reads a bounded live page after after_row_id.

pub async fn begin_snapshot(&self) -> Result<SnapshotPager, PageError>

Begins a finite, repeatable-read snapshot pager.

pub async fn claim( &self, worker: WorkerId, lease_for: Lease, limit: Limit, ) -> Result<Vec<ClaimedEvent>, ClaimError>

Claims eligible events under short PostgreSQL transactions.

pub async fn renew( &self, row_id: RowId, claim_token: &ClaimToken, lease_for: Lease, ) -> Result<(), MutationError>

Renews one current, unexpired claim using PostgreSQL time.

pub async fn ack( &self, row_id: RowId, claim_token: &ClaimToken, ) -> Result<(), MutationError>

Acknowledges one current, unexpired claim.

pub async fn retry( &self, row_id: RowId, claim_token: &ClaimToken, failure: &Failure, backoff: Delay, ) -> Result<(), MutationError>

Returns one current, unexpired claim to pending with a failure.

pub async fn release( &self, row_id: RowId, claim_token: &ClaimToken, delay: Delay, ) -> Result<(), MutationError>

Returns one current, unexpired claim to pending after a delay.

pub async fn quarantine( &self, row_id: RowId, claim_token: &ClaimToken, reason: &QuarantineReason, ) -> Result<(), MutationError>

Quarantines one current, unexpired claim with an operator reason.

Trait Implementations

impl Clone for PostgresDovecote

fn clone(&self) -> PostgresDovecote

Returns a duplicate of the value.

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

Performs copy-assignment from source.