Struct PgOutboxPublisher 

pub struct PgOutboxPublisher { /* private fields */ }

PostgreSQL implementation of OutboxPublisher backed by sqlx::PgPool.

Cheap to clone (the pool and the cached insert statement are reference-counted).

Implementations

impl PgOutboxPublisher

pub fn new( pool: PgPool, table_name: impl Into<String>, ) -> Result<Self, OutboxError>

Create a new publisher for the given pool and table.

Errors

Returns OutboxError::Internal if table_name is not a valid identifier matching ^[a-zA-Z_][a-zA-Z0-9_]*$.

pub fn pool(&self) -> &PgPool

Underlying pool, exposed for callers that open their own transactions.

pub fn table_name(&self) -> &str

Configured table name.

Trait Implementations

impl Clone for PgOutboxPublisher

fn clone(&self) -> PgOutboxPublisher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PgOutboxPublisher

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

Formats the value using the given formatter.

impl OutboxPublisher for PgOutboxPublisher

type Tx<'tx> = Transaction<'tx, Postgres>

Backend-specific transaction handle borrowed by publish_in_tx.

async fn publish_in_tx<E: Event>( &self, tx: &mut Self::Tx<'_>, event: &E, ) -> Result<Uuid, OutboxError>

Insert an event using an existing business transaction.

async fn publish_in_tx_with_subject<E: Event>( &self, tx: &mut Self::Tx<'_>, subject_id: Uuid, event: &E, ) -> Result<Uuid, OutboxError>

Insert an event tagged with a subject for partial ordering.

async fn publish<E: Event>(&self, event: &E) -> Result<Uuid, OutboxError>

Insert an event using a transaction opened by the publisher itself.