Struct PostgresWriter 

pub struct PostgresWriter;

Stateless writer for the outbox_events table.

The writer carries no connection or pool. The actual database handle is passed per-call via OutboxWriter::insert_event’s executor argument — idiomatically &mut *tx from a held sqlx::Transaction, so the outbox row lands in the same commit as the caller’s business write.

Example

use outbox_core::prelude::*;
use outbox_postgres::PostgresWriter;
use std::sync::Arc;

let service = OutboxService::new(Arc::new(PostgresWriter), config);

let mut tx = pool.begin().await.map_err(|e| OutboxError::DatabaseError(e.to_string()))?;
// ... INSERT INTO orders ... .execute(&mut *tx).await? ...
service.add_event("OrderCreated", payload, None, &mut *tx).await?;
tx.commit().await.map_err(|e| OutboxError::DatabaseError(e.to_string()))?;

Trait Implementations

impl Clone for PostgresWriter

fn clone(&self) -> PostgresWriter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for PostgresWriter

impl Debug for PostgresWriter

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

Formats the value using the given formatter.

impl Default for PostgresWriter

fn default() -> PostgresWriter

Returns the “default value” for a type.

impl<P> OutboxWriter<P> for PostgresWriter

where P: Debug + Clone + Serialize + Send + Sync + 'static,

type Executor<'a> = &'a mut PgConnection

The executor handle accepted by insert_event.

fn insert_event<'a, 'life0, 'async_trait>( &'life0 self, event: Event<P>, executor: &'a mut PgConnection, ) -> Pin<Box<dyn Future<Output = Result<(), OutboxError>> + Send + 'async_trait>>

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

Persists a single Event row through executor.