Struct MySqlOutboxPublisher 

pub struct MySqlOutboxPublisher { /* private fields */ }

MySQL implementation of OutboxPublisher backed by sqlx::MySqlPool.

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

Implementations

impl MySqlOutboxPublisher

pub fn new( pool: MySqlPool, 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) -> &MySqlPool

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

pub fn table_name(&self) -> &str

Configured table name.

Trait Implementations

impl Clone for MySqlOutboxPublisher

fn clone(&self) -> MySqlOutboxPublisher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MySqlOutboxPublisher

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

Formats the value using the given formatter.

impl OutboxPublisher for MySqlOutboxPublisher

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

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.