Struct WorkflowWorker 

pub struct WorkflowWorker { /* private fields */ }

One distributed workflow worker.

Implementations

impl WorkflowWorker

pub fn new( store: Arc<dyn WorkflowStore>, registry: WorkflowRegistry, worker: WorkerId, lease_duration: LeaseDuration, heartbeat_interval: Duration, ) -> Result<Self, WorkflowWorkerError>

Creates a worker with validated heartbeat timing.

Errors

Rejects a zero heartbeat interval or one not shorter than the lease.

pub const fn with_missing_definition_retry(self, delay: Duration) -> Self

Overrides the retry delay for definitions absent from this worker.

pub const fn with_budget_denied_retry(self, delay: Duration) -> Self

Overrides the retry delay when a tenant aggregate budget is exhausted.

pub fn with_sleeper(self, sleeper: Arc<dyn WorkflowWorkerSleeper>) -> Self

Overrides heartbeat sleeping for deterministic runtimes and tests.

pub async fn run_once( &self, ) -> Result<WorkflowWorkerOutcome, WorkflowWorkerError>

Claims and processes at most one task.

Errors

Returns infrastructure, checkpoint, or restored-budget failures.

Trait Implementations

impl Debug for WorkflowWorker

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

Formats the value using the given formatter.