Enum FlowTask 

#[non_exhaustive]
pub enum FlowTask {
    DriveRun {
        run_id: String,
    },
    ResumeWait {
        run_id: String,
        wait_id: String,
    },
    ResumeHook {
        run_id: String,
        hook_id: String,
        payload: JsonValue,
    },
    ResumeHookByToken {
        token: String,
        payload: JsonValue,
    },
    SendSignal {
        run_id: String,
        signal: WorkflowSignal,
    },
    DisposeHook {
        run_id: String,
        hook_id: String,
    },
    DisposeHookByToken {
        token: String,
    },
    ResumeScheduledRun {
        run_id: String,
        now: DateTime<Utc>,
    },
    ResumeDueWaits {
        now: DateTime<Utc>,
    },
    ResumeDueRetries {
        now: DateTime<Utc>,
    },
}

Queueable unit of workflow engine work.

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.

DriveRun

Replays a run until it suspends or reaches a terminal state.

Fields

run_id: String

Run to replay.

ResumeWait

Completes one durable timer wait and replays its run.

Fields

run_id: String

Run that owns the wait.

wait_id: String

Stable identity of the wait.

ResumeHook

Delivers a payload to a hook addressed within a run.

Fields

run_id: String

Run that owns the hook.

hook_id: String

Stable identity of the hook.

payload: JsonValue

JSON payload supplied by the external caller.

ResumeHookByToken

Delivers a payload to a hook addressed by its bearer token.

Fields

token: String

Secret token assigned when the hook was created.

payload: JsonValue

JSON payload supplied by the external caller.

SendSignal

Delivers one named asynchronous signal to a run.

Fields

run_id: String

Root or active run targeted by the delivery.

signal: WorkflowSignal

Caller-identified signal delivery.

DisposeHook

Closes a hook without delivering a payload.

Fields

run_id: String

Run that owns the hook.

hook_id: String

Stable identity of the hook.

DisposeHookByToken

Closes a hook addressed by its bearer token.

Fields

token: String

Secret token assigned when the hook was created.

ResumeScheduledRun

Drives due waits and retries for one targeted run.

Fields

run_id: String

Run whose scheduled work should be inspected.

now: DateTime<Utc>

UTC cutoff used to determine readiness.

ResumeDueWaits

Compatibility task that scans all runs for due timer waits.

Fields

now: DateTime<Utc>

UTC cutoff used to determine readiness.

ResumeDueRetries

Compatibility task that scans all runs for due delayed retries.

Fields

now: DateTime<Utc>

UTC cutoff used to determine readiness.

Implementations

impl FlowTask

pub fn target_run_id(&self) -> Option<&str>

Return the single run targeted by this task, when one is explicit.

Public-token callbacks and compatibility-wide due scans require host resolution before they can participate in exact runtime-build routing.

Trait Implementations

impl Clone for FlowTask

fn clone(&self) -> FlowTask

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FlowTask

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for FlowTask

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for FlowTask

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for FlowTask

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for FlowTask