Struct UnitOfWork

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

Fields

repository: R

event local repository for Executor

Trait Implementations

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

where R: Clone + TRepository<E, A>, E: Clone + Executor, A: Clone + Aggregate,

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

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

where R: TRepository<E, A>, E: Executor, A: Aggregate,

fn new<'async_trait>( context: Arc<RwLock<ContextManager>>, ) -> Pin<Box<dyn Future<Output = UnitOfWork<R, E, A>> + Send + 'async_trait>>

where UnitOfWork<R, E, A>: 'async_trait,

Creeate UOW object with context manager.

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

Get local event repository.

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

where 'life0: 'async_trait, UnitOfWork<R, E, A>: 'async_trait,

Begin transaction.

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

where O: 'async_trait + IOutBox<E>, UnitOfWork<R, E, A>: 'async_trait,

Commit transaction.

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

where UnitOfWork<R, E, A>: 'async_trait,

Rollback transaction.

fn clone_context(&self) -> Arc<RwLock<ContextManager>>

fn clone_executor(&self) -> Arc<RwLock<E>>