Struct WorkflowSupervisorConfig 

pub struct WorkflowSupervisorConfig { /* private fields */ }

Validated policy for continuous worker polling and bounded concurrency.

Implementations

impl WorkflowSupervisorConfig

pub fn new(max_concurrency: usize) -> Result<Self, WorkflowWorkerError>

Creates a supervisor configuration with a 10 ms to 5 second idle backoff.

Errors

Rejects zero concurrency.

pub fn with_backoff( self, initial: Duration, maximum: Duration, ) -> Result<Self, WorkflowWorkerError>

Sets the exponential backoff used after idle polls and infrastructure errors.

Errors

Rejects zero delays or a maximum shorter than the initial delay.

pub const fn max_concurrency(self) -> usize

Returns the maximum number of simultaneous claim-and-execute cycles.

Trait Implementations

impl Clone for WorkflowSupervisorConfig

fn clone(&self) -> WorkflowSupervisorConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for WorkflowSupervisorConfig

impl Debug for WorkflowSupervisorConfig

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

Formats the value using the given formatter.

impl Eq for WorkflowSupervisorConfig

impl PartialEq for WorkflowSupervisorConfig

fn eq(&self, other: &WorkflowSupervisorConfig) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for WorkflowSupervisorConfig