Enum Trigger 

pub enum Trigger {
    Immediate,
    After(Duration),
    OnSignal {
        correlation_key: String,
        timeout: Duration,
    },
}

When the next step of a run becomes claimable. Set on the when field of StepOutcome::Continue.

Variants

Immediate

The next step is claimable immediately.

After(Duration)

The next step is claimable Duration from now.

OnSignal

The next step is claimable when a signal for correlation_key arrives via crate::WorkflowRuntime::signal, or after timeout, whichever comes first. The next step reads Step::signal to distinguish the two: Some(payload) when a signal arrived, None when the timeout elapsed first. A signal that arrived before this step settled is consumed at settlement and the next step runs immediately.

One waiter per correlation key: registering a second waiter while one is already waiting fails the step permanently. Choose keys that are unique per waiter (e.g. include the run id).

Fields

correlation_key: String

Caller-chosen key the signaller addresses.

timeout: Duration

Upper bound on the wait; the next step runs with Step::signal None when it elapses first.

Trait Implementations

impl Clone for Trigger

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Trigger

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

Formats the value using the given formatter.