Struct InfallibleTransaction 

pub struct InfallibleTransaction { /* private fields */ }

InfallibleTransaction is a sequence of operations that are executed in a way that if any of the operations or the underlying Golem executor fails, the whole transaction is going to be retried.

In addition to that, user level failures (represented by the Result::Err value of an operation) lead to performing the compensation actions of each already performed operation in reverse order.

Fatal errors (panic) and external executor failures are currently cannot perform the rollback actions.

Implementations

impl InfallibleTransaction

pub async fn execute<OpIn: Clone + 'static, OpOut: Clone + 'static, OpErr: Debug + Clone + 'static>( &mut self, operation: impl Operation<In = OpIn, Out = OpOut, Err = OpErr> + 'static, input: OpIn, ) -> OpOut

pub async fn retry(&mut self)

Stop executing the transaction and retry from the beginning, after executing the compensation actions

Trait Implementations

impl<Err: Debug + Clone + 'static> Transaction<Err> for InfallibleTransaction

async fn execute<OpIn: Clone + 'static, OpOut: Clone + 'static>( &mut self, operation: impl Operation<In = OpIn, Out = OpOut, Err = Err> + 'static, input: OpIn, ) -> Result<OpOut, Err>

async fn fail(&mut self, error: Err) -> Result<(), Err>

async fn run<Out: 'static>( f: impl for<'a> FnOnce(&'a mut Self) -> LocalBoxFuture<'a, Result<Out, Err>>, ) -> TransactionResult<Out, Err>