Struct RecoverableCeremonyWorker 

pub struct RecoverableCeremonyWorker { /* private fields */ }

Runs an accepted claim through receipt persistence and fenced completion.

Implementations

impl RecoverableCeremonyWorker

pub const fn new( execute_operation: Arc<ExecuteCeremonyOperationUseCase>, recover_intent: Arc<RecoverExecutionIntentUseCase>, complete_receipt: Arc<CompleteExecutionReceiptUseCase>, ) -> Self

pub async fn execute_claim( &self, input: ExecuteCeremonyOperationInput, ) -> Result<RecoverableCeremonyWorkerOutcome, DomainError>

pub async fn recover( &self, item: ExecutionRecoveryItem, ) -> Result<RecoverableCeremonyWorkerOutcome, DomainError>

Trait Implementations

impl Debug for RecoverableCeremonyWorker

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl RecoverableCeremonyWorkerPort for RecoverableCeremonyWorker

fn execute_claim<'life0, 'async_trait>( &'life0 self, input: ExecuteCeremonyOperationInput, ) -> Pin<Box<dyn Future<Output = Result<RecoverableCeremonyWorkerOutcome, DomainError>> + Send + 'async_trait>>

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

fn recover<'life0, 'async_trait>( &'life0 self, item: ExecutionRecoveryItem, ) -> Pin<Box<dyn Future<Output = Result<RecoverableCeremonyWorkerOutcome, DomainError>> + Send + 'async_trait>>

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