Struct CeremonyWorkerDriver 

pub struct CeremonyWorkerDriver { /* private fields */ }

Bounded host loop that drains every admitted chunk before observing stop.

Implementations

impl CeremonyWorkerDriver

pub const fn new( inspect_recovery: Arc<dyn ExecutionRecoveryInspectorPort>, deadlines: Arc<dyn CeremonyDeadlineEnforcementPort>, worker: Arc<dyn RecoverableCeremonyWorkerPort>, policy: CeremonyWorkerPolicy, stop: CeremonyWorkerStopToken, ) -> Self

pub const fn for_claims( deadlines: Arc<dyn CeremonyDeadlineEnforcementPort>, worker: Arc<dyn RecoverableCeremonyWorkerPort>, policy: CeremonyWorkerPolicy, stop: CeremonyWorkerStopToken, ) -> Self

pub async fn execute_claims( &self, claims: Vec<ExecuteCeremonyOperationInput>, ) -> Result<CeremonyWorkerBatchOutcome, DomainError>

pub async fn recover_page( &self, after: Option<&ExecutionRecoveryCursor>, ) -> Result<CeremonyWorkerBatchOutcome, DomainError>

Trait Implementations

impl Debug for CeremonyWorkerDriver

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

Formats the value using the given formatter.