Struct SqlxRuntime 

pub struct SqlxRuntime { /* private fields */ }

Implementations

impl SqlxRuntime

pub fn new(pool: PgPool) -> Self

pub fn pool(&self) -> &PgPool

pub fn with_audit_sink(self, sink: Arc<dyn AuditSink>) -> Self

Install a custom AuditSink that every @@audit mutation on this runtime fans out to, in addition to the in-database cratestack_audit table row enqueue_audit_event always writes. Composable via cratestack_core::MulticastAuditSink for more than one downstream (Kafka, Redis pubsub, a webhook — this crate ships none of them; see AuditSink’s doc comment).

impl SqlxRuntime

pub async fn transaction<F, T>(&self, body: F) -> Result<T, CratestackError>

where F: AsyncFnOnce(&mut Tx) -> Result<T, CratestackError>,

Run body inside one Postgres transaction: commit if it returns Ok, roll back if it returns Err. body receives an opaque Tx it can pass straight through to any write builder’s run_in_tx — see the module doc comment for why no sqlx type ever needs to be named to do that.

On the Err path this issues an explicit tx.rollback().await rather than relying on sqlx::Transaction’s Drop impl. That matters: sqlx-core’s Drop for Transaction only queues a rollback for the next time the underlying connection is used (see sqlx-core::transaction::Transaction’s Drop impl) — it does not synchronously roll back. A caller asserting “neither write is visible” immediately after an Err return needs that to have already happened, not to be pending on some future unrelated query.

Does not retry — see the module doc comment for why that’s left to crate::run_in_isolated_tx instead, and how the two compose.

Does not dispatch to an installed AuditSink or drain the @@emit outbox on its own — see the module doc comment’s “Composing through here does not close the AuditSink/outbox gap” section (cratestack#534) for why that can’t be made automatic here.

Trait Implementations

impl Clone for SqlxRuntime

fn clone(&self) -> SqlxRuntime

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqlxRuntime

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

Formats the value using the given formatter.