Struct PostgresOutboxStore 

pub struct PostgresOutboxStore { /* private fields */ }

Implementations

impl PostgresOutboxStore

pub const fn new(pool: PgPool) -> Self

pub async fn enqueue_in( &self, transaction: &mut Transaction<'_, Postgres>, record: OutboxRecord, ) -> Result<(), EventError>

Inserts an outbox record into an application adapter’s existing transaction so the domain mutation and publication intent commit atomically.

Trait Implementations

impl Clone for PostgresOutboxStore

fn clone(&self) -> PostgresOutboxStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresOutboxStore

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

Formats the value using the given formatter.

impl OutboxStore for PostgresOutboxStore

fn enqueue<'life0, 'async_trait>( &'life0 self, record: OutboxRecord, ) -> Pin<Box<dyn Future<Output = Result<(), EventError>> + Send + 'async_trait>>

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

fn claim_pending<'life0, 'life1, 'async_trait>( &'life0 self, worker_id: &'life1 str, limit: usize, claim_expires_at: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<Vec<OutboxRecord>, EventError>> + Send + 'async_trait>>

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

fn claim_event<'life0, 'life1, 'async_trait>( &'life0 self, event_id: Uuid, worker_id: &'life1 str, claim_expires_at: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<Option<OutboxRecord>, EventError>> + Send + 'async_trait>>

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

Atomically claims one known event for request-assisted publication.

fn mark_published<'life0, 'life1, 'async_trait>( &'life0 self, event_id: Uuid, worker_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), EventError>> + Send + 'async_trait>>

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

fn mark_failed<'life0, 'life1, 'async_trait>( &'life0 self, event_id: Uuid, worker_id: &'life1 str, error: String, retry_at: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<(), EventError>> + Send + 'async_trait>>

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

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

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