Enum WorkerDecision 

#[non_exhaustive]
pub enum WorkerDecision {
    Step,
    WaitMicros(u64),
    Stop,
}

Scheduling decision for a concurrent worker.

Returned by WorkerScheduler::decide to control per-worker stepping in scoped concurrent execution.

#[non_exhaustive] — future variants will be added as planned work lands:

• StepBatch(usize) (C1 batch semantics — step N messages in one call)
• StepWithBudget { max_micros: u64 } (R11 execution measurement)

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Step

Step the node once.

WaitMicros(u64)

Wait before calling decide() again. Duration in microseconds.

Stop

This worker should exit.

Trait Implementations

impl Clone for WorkerDecision

fn clone(&self) -> WorkerDecision

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerDecision

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

Formats the value using the given formatter.

impl PartialEq for WorkerDecision

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for WorkerDecision

impl Eq for WorkerDecision

impl StructuralPartialEq for WorkerDecision