Struct golem_rust::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 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 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

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>

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

fn run<Out>( f: impl FnOnce(&mut Self) -> Result<Out, Err>, ) -> TransactionResult<Out, Err>