Enum Event 

pub enum Event {
    WorkflowCreated {
        workflow: String,
        version: String,
        definition_hash: String,
        input: Value,
        parent: Option<ParentRef>,
        schedule_id: Option<String>,
        run: Option<u32>,
    },
    StepFanOut {
        step: String,
        items: Vec<Value>,
    },
    WorkflowStarted {},
    StepScheduled {
        step: String,
        attempt: u32,
        input: Value,
        idempotency_key: String,
        redelivery: bool,
    },
    StepSkipped {
        step: String,
        reason: String,
    },
    StepDispatched {
        step: String,
        attempt: u32,
        token: String,
        worker_id: String,
        worker_session: String,
        deadline_ms: Option<u64>,
    },
    StepSucceeded {
        step: String,
        attempt: u32,
        output: Value,
    },
    StepAttemptFailed {
        step: String,
        attempt: u32,
        error: TaskError,
    },
    StepAttemptUncertain {
        step: String,
        attempt: u32,
        reason: String,
    },
    RetryScheduled {
        step: String,
        next_attempt: u32,
        delay_ms: u64,
        fire_at_ms: u64,
    },
    StepFailed {
        step: String,
        error: TaskError,
    },
    StepCancelled {
        step: String,
    },
    TimerStarted {
        step: String,
        fire_at_ms: u64,
    },
    TimerFired {
        step: String,
    },
    StaleResultIgnored {
        step: String,
        token: String,
        outcome: String,
    },
    CancelRequested {
        reason: String,
    },
    WorkflowTimeoutReached {},
    CompensationStarted {
        reason: String,
        steps: Vec<String>,
    },
    CompensationCompleted {},
    CompensationFailed {
        step: String,
        error: TaskError,
    },
    WorkflowCompleted {
        output: Value,
    },
    WorkflowFailed {
        error: TaskError,
        compensation: CompensationOutcome,
    },
    WorkflowCancelled {
        compensation: CompensationOutcome,
    },
    WorkflowTimedOut {
        compensation: CompensationOutcome,
    },
    SignalReceived {
        name: String,
        payload: Value,
    },
    SignalAwaitStarted {
        step: String,
        signal: String,
        deadline_ms: Option<u64>,
    },
    LimitExceeded {
        limit: String,
        message: String,
    },
    HandlersStarted {
        kind: String,
        compensation: CompensationOutcome,
    },
    SignalDelivered {
        step: String,
        signal_seq: u64,
    },
    WorkflowContinuedAsNew {
        next_run: u32,
        input: Value,
    },
}

Variants

WorkflowCreated

Fields

workflow: String

version: String

definition_hash: String

input: Value

parent: Option<ParentRef>

Set for child workflows started by a workflow "Name" step.

schedule_id: Option<String>

Set for executions started by a schedule (/v1/schedules).

run: Option<u32>

The run number, for runs after the first one (continue-as-new). Absent means run 1.

StepFanOut

A for step expanded into one unit per element (step[0], step[1], …).

Fields

step: String

items: Vec<Value>

WorkflowStarted

StepScheduled

The unit is ready and queued for a worker. input is the fully evaluated payload.

Fields

step: String

attempt: u32

input: Value

idempotency_key: String

redelivery: bool

StepSkipped

Fields

step: String

reason: String

StepDispatched

Fields

step: String

attempt: u32

token: String

worker_id: String

worker_session: String

deadline_ms: Option<u64>

StepSucceeded

Fields

step: String

attempt: u32

output: Value

StepAttemptFailed

Fields

step: String

attempt: u32

error: TaskError

StepAttemptUncertain

The outcome of a dispatched attempt is unknown (worker lost, runtime restarted). The same attempt is redelivered with the same idempotency key.

Fields

step: String

attempt: u32

reason: String

RetryScheduled

Fields

step: String

next_attempt: u32

delay_ms: u64

fire_at_ms: u64

StepFailed

Fields

step: String

error: TaskError

StepCancelled

A queued unit was withdrawn because the workflow is being aborted.

Fields

step: String

TimerStarted

Fields

step: String

fire_at_ms: u64

TimerFired

Fields

step: String

StaleResultIgnored

A result arrived for an attempt that no longer matters (duplicate or late).

Fields

step: String

token: String

outcome: String

CancelRequested

Fields

reason: String

WorkflowTimeoutReached

CompensationStarted

Fields

reason: String

steps: Vec<String>

CompensationCompleted

CompensationFailed

Fields

step: String

error: TaskError

WorkflowCompleted

Fields

output: Value

WorkflowFailed

Fields

error: TaskError

compensation: CompensationOutcome

WorkflowCancelled

Fields

compensation: CompensationOutcome

WorkflowTimedOut

Fields

compensation: CompensationOutcome

SignalReceived

A typed signal sent to the execution (POST .../signals/<name>). Buffered until an await step takes it.

Fields

name: String

payload: Value

SignalAwaitStarted

An await step started waiting. deadline_ms comes from its timeout.

Fields

step: String

signal: String

deadline_ms: Option<u64>

LimitExceeded

A server resource limit was reached; the execution is failed with LIMIT_EXCEEDED (compensation and on failure still run).

Fields

limit: String

message: String

HandlersStarted

Compensation (if any) is done and the on <kind> handler steps start. compensation is the outcome recorded on the terminal event afterwards.

Fields

kind: String

compensation: CompensationOutcome

SignalDelivered

An await step took the signal received at history sequence signal_seq; its payload is the step output.

Fields

step: String

signal_seq: u64

WorkflowContinuedAsNew

continue_as_new: this run ended and run next_run of the same execution starts with input and an empty history. The runtime archives this run’s history and writes the new run’s first events in the same transaction.

Fields

next_run: u32

input: Value

Implementations

impl Event

pub fn name(&self) -> &'static str

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

Trait Implementations

impl Clone for Event

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 Event

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Event

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for Event

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for Event

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 Event