Struct FletchTransactionManager 

pub struct FletchTransactionManager<DB: FletchDatabase> { /* private fields */ }

Fletch-backed TransactionManager implementation.

Wraps a fletch_orm::Pool<DB> and drives commit/rollback through SQLx transactions. Prefer the inherent transaction method, which passes a FletchTransactionContext so repository writes use the open transaction.

Implementations

impl<DB: FletchDatabase> FletchTransactionManager<DB>

pub fn new(pool: Pool<DB>) -> Self

Create a new transaction manager from a fletch pool.

pub fn from_dep(dep: &Dep<Pool<DB>>) -> Self

Create a new transaction manager by cloning the pool from a Dep.

pub fn pool(&self) -> &Pool<DB>

Return a reference to the underlying pool.

pub async fn transaction<F, Fut, R>(&self, f: F) -> Result<R, RepoError>

where F: FnOnce(FletchTransactionContext<DB>) -> Fut, Fut: Future<Output = Result<R, RepoError>>, R: Send,

Execute f within a transactional boundary.

The closure receives an owned FletchTransactionContext with txn-scoped repositories. On Ok, the transaction is committed; on Err, it is rolled back.

Do not retain clones of the context beyond this closure — once the transaction finishes, cloned contexts cannot execute further queries.

pub fn transaction_boxed<F, Fut, R>( &self, f: F, ) -> BoxFuture<'_, Result<R, RepoError>>

where F: FnOnce(FletchTransactionContext<DB>) -> Fut + Send + 'static, Fut: Future<Output = Result<R, RepoError>> + Send + 'static, R: Send + 'static,

Boxed variant of transaction for 'static callbacks.

Trait Implementations

impl<DB: FletchDatabase> TransactionManager for FletchTransactionManager<DB>

type Context = FletchTransactionContext<DB>

Opaque handle passed to transaction closures.

fn transaction<F, Fut, R>(&self, f: F) -> BoxFuture<'_, Result<R, RepoError>>

where F: FnOnce(FletchTransactionContext<DB>) -> Fut + Send + 'static, Fut: Future<Output = Result<R, RepoError>> + Send + 'static, R: Send + 'static,

Execute the given closure within a transactional boundary.