Struct PgTransaction 

pub struct PgTransaction { /* private fields */ }

An open transaction. Dropping it without PgTransaction::commit rolls it back — an early ? in a use case is the rollback.

Implementations

impl PgTransaction

pub async fn begin(pool: &PgPool) -> Result<Self, RepositoryError>

pub fn tx(&mut self) -> &mut PgConnection

The connection the entity’s own writes run on: query(…).execute(uow.tx()).

pub async fn record( &mut self, event: &impl DomainEvent, ) -> Result<(), RepositoryError>

Records a new event in the outbox, inside this transaction.

pub async fn record_envelope( &mut self, event: &EventEnvelope, ) -> Result<(), RepositoryError>

Records an envelope built by the caller — one carrying headers (correlation_id).

pub async fn commit(self) -> Result<(), RepositoryError>