Struct WorkflowSupervisor 

pub struct WorkflowSupervisor { /* private fields */ }

Continuous, bounded-concurrency host for a WorkflowWorker.

Implementations

impl WorkflowSupervisor

pub fn new( worker: Arc<WorkflowWorker>, config: WorkflowSupervisorConfig, ) -> Self

Creates a continuous supervisor around one shareable worker.

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

Overrides supervisor sleeping for deterministic runtimes and tests.

pub fn with_metrics(self, metrics: WorkflowSupervisorMetrics) -> Self

Uses the supplied cumulative metric set.

pub const fn metrics(&self) -> &WorkflowSupervisorMetrics

Returns the cumulative metric set used by this supervisor.

pub async fn run( &self, shutdown: &CancellationToken, ) -> WorkflowSupervisorReport

Continuously polls and executes work until shutdown, then drains started cycles.

Infrastructure errors are counted and retried with backoff. Once shutdown is observed, no replacement cycles are scheduled. Already-started claim or execution operations are awaited so their lease protocol can finish safely.

Trait Implementations

impl Debug for WorkflowSupervisor

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

Formats the value using the given formatter.