Enum Action 

pub enum Action {
    CallActivity {
        scheduling_event_id: u64,
        name: String,
        input: String,
        session_id: Option<String>,
        tag: Option<String>,
    },
    CreateTimer {
        scheduling_event_id: u64,
        fire_at_ms: u64,
    },
    WaitExternal {
        scheduling_event_id: u64,
        name: String,
    },
    StartOrchestrationDetached {
        scheduling_event_id: u64,
        name: String,
        version: Option<String>,
        instance: String,
        input: String,
    },
    StartSubOrchestration {
        scheduling_event_id: u64,
        name: String,
        version: Option<String>,
        instance: String,
        input: String,
    },
    ContinueAsNew {
        input: String,
        version: Option<String>,
    },
    UpdateCustomStatus {
        status: Option<String>,
    },
    DequeueEvent {
        scheduling_event_id: u64,
        name: String,
    },
    SetKeyValue {
        key: String,
        value: String,
    },
    ClearKeyValue {
        key: String,
    },
    ClearKeyValues,
}

Declarative decisions produced by an orchestration turn. The host/provider is responsible for materializing these into corresponding Events.

Variants

CallActivity

Schedule an activity invocation. scheduling_event_id is the event_id of the ActivityScheduled event.

Fields

scheduling_event_id: u64

name: String

input: String

session_id: Option<String>

Optional session ID for worker affinity routing. When set, the activity is routed to the worker owning this session.

tag: Option<String>

Optional routing tag for directing this activity to specific workers. Set via .with_tag() on the returned DurableFuture.

CreateTimer

Create a timer that will fire at the specified absolute time. scheduling_event_id is the event_id of the TimerCreated event. fire_at_ms is the absolute timestamp (ms since epoch) when the timer should fire.

Fields

scheduling_event_id: u64

fire_at_ms: u64

WaitExternal

Subscribe to an external event by name. scheduling_event_id is the event_id of the ExternalSubscribed event.

Fields

scheduling_event_id: u64

name: String

StartOrchestrationDetached

Start a detached orchestration (no result routing back to parent).

Fields

scheduling_event_id: u64

name: String

version: Option<String>

instance: String

input: String

StartSubOrchestration

Start a sub-orchestration by name and child instance id. scheduling_event_id is the event_id of the SubOrchestrationScheduled event.

Fields

scheduling_event_id: u64

name: String

version: Option<String>

instance: String

input: String

ContinueAsNew

Continue the current orchestration as a new execution with new input (terminal for current execution). Optional version string selects the target orchestration version for the new execution.

Fields

input: String

version: Option<String>

UpdateCustomStatus

Update the custom status of the orchestration. Some(s) means set to s; None means cleared back to NULL.

Fields

status: Option<String>

DequeueEvent

Subscribe to a persistent external event by name (mailbox semantics). Unlike WaitExternal, persistent events use FIFO matching and survive cancellation.

Fields

scheduling_event_id: u64

name: String

SetKeyValue

Set a key-value pair on this orchestration instance. Fire-and-forget metadata action (like UpdateCustomStatus).

Fields

key: String

value: String

ClearKeyValue

Clear a single key from the KV store.

Fields

key: String

ClearKeyValues

Clear all keys from the KV store.

Trait Implementations

impl Clone for Action

fn clone(&self) -> Action

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Action

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

Formats the value using the given formatter.