Struct ruva_core::unit_of_work::UnitOfWork

pub struct UnitOfWork<R, E>
where
    R: TRepository,
    E: Executor,
{
    pub repository: R,
    /* private fields */
}

Fields

repository: R

event local repository for Executor

Implementations

impl<R, E> UnitOfWork<R, E>

where R: TRepository, E: Executor,

pub fn new( context: AtomicContextManager, executor: Arc<RwLock<E>>, repository: R ) -> Self

Trait Implementations

impl<R, E> Clone for UnitOfWork<R, E>

where R: TRepository + Clone, E: Executor + Clone,

fn clone(&self) -> UnitOfWork<R, E>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<R, E> TClone for UnitOfWork<R, E>

where R: TRepository + TClone, E: Executor,

fn clone(&self) -> Self

impl<R, E> TCloneContext for UnitOfWork<R, E>

where R: TRepository, E: Executor,

fn clone_context(&self) -> AtomicContextManager

impl<R, E> TRepositoyCallable<R> for UnitOfWork<R, E>

where R: TRepository, E: Executor,

fn repository(&mut self) -> &mut R

impl<R, E> TUnitOfWork for UnitOfWork<R, E>

where R: TRepository, E: Executor,

fn begin<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<(), BaseError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Begin transaction.

fn commit<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<(), BaseError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Commit transaction.

fn rollback<'async_trait>( self ) -> Pin<Box<dyn Future<Output = Result<(), BaseError>> + Send + 'async_trait>>

where Self: 'async_trait,

Rollback transaction.