Enum EventKind 

pub enum EventKind {
    OrchestrationStarted {
        name: String,
        version: String,
        input: String,
        parent_instance: Option<String>,
        parent_id: Option<u64>,
        carry_forward_events: Option<Vec<(String, String)>>,
    },
    OrchestrationCompleted {
        output: String,
    },
    OrchestrationFailed {
        details: ErrorDetails,
    },
    ActivityScheduled {
        name: String,
        input: String,
        session_id: Option<String>,
    },
    ActivityCompleted {
        result: String,
    },
    ActivityFailed {
        details: ErrorDetails,
    },
    ActivityCancelRequested {
        reason: String,
    },
    TimerCreated {
        fire_at_ms: u64,
    },
    TimerFired {
        fire_at_ms: u64,
    },
    ExternalSubscribed {
        name: String,
    },
    ExternalEvent {
        name: String,
        data: String,
    },
    OrchestrationChained {
        name: String,
        instance: String,
        input: String,
    },
    SubOrchestrationScheduled {
        name: String,
        instance: String,
        input: String,
    },
    SubOrchestrationCompleted {
        result: String,
    },
    SubOrchestrationFailed {
        details: ErrorDetails,
    },
    SubOrchestrationCancelRequested {
        reason: String,
    },
    OrchestrationContinuedAsNew {
        input: String,
    },
    OrchestrationCancelRequested {
        reason: String,
    },
    ExternalSubscribedCancelled {
        reason: String,
    },
    QueueSubscribed {
        name: String,
    },
    QueueEventDelivered {
        name: String,
        data: String,
    },
    QueueSubscriptionCancelled {
        reason: String,
    },
}

Event-specific payloads.

Common fields have been extracted to the Event struct:

• event_id: moved to Event.event_id
• source_event_id: moved to Event.source_event_id (Option<u64>)
• execution_id: moved to Event.execution_id (was in 4 variants)

Variants

OrchestrationStarted

Orchestration instance was created and started by name with input. Version is required; parent linkage is present when this is a child orchestration.

Fields

name: String

version: String

input: String

parent_instance: Option<String>

parent_id: Option<u64>

carry_forward_events: Option<Vec<(String, String)>>

Persistent events carried forward from the previous execution during continue-as-new. Present only on CAN-initiated executions for audit trail. Each tuple is (event_name, data).

OrchestrationCompleted

Orchestration completed with a final result.

Fields

output: String

OrchestrationFailed

Orchestration failed with a final error.

Fields

details: ErrorDetails

ActivityScheduled

Activity was scheduled.

Fields

name: String

input: String

session_id: Option<String>

ActivityCompleted

Activity completed successfully with a result.

Fields

result: String

ActivityFailed

Activity failed with error details.

Fields

details: ErrorDetails

ActivityCancelRequested

Cancellation was requested for an activity (best-effort; completion may still arrive). Correlates to the ActivityScheduled event via Event.source_event_id.

Fields

reason: String

TimerCreated

Timer was created and will logically fire at fire_at_ms.

Fields

fire_at_ms: u64

TimerFired

Timer fired at logical time fire_at_ms.

Fields

fire_at_ms: u64

ExternalSubscribed

Subscription to an external event by name was recorded.

Fields

name: String

ExternalEvent

An external event was raised. Matched by name (no source_event_id).

Fields

name: String

data: String

OrchestrationChained

Fire-and-forget orchestration scheduling (detached).

Fields

name: String

instance: String

input: String

SubOrchestrationScheduled

Sub-orchestration was scheduled with deterministic child instance id.

Fields

name: String

instance: String

input: String

SubOrchestrationCompleted

Sub-orchestration completed and returned a result to the parent.

Fields

result: String

SubOrchestrationFailed

Sub-orchestration failed and returned error details to the parent.

Fields

details: ErrorDetails

SubOrchestrationCancelRequested

Cancellation was requested for a sub-orchestration (best-effort; completion may still arrive). Correlates to the SubOrchestrationScheduled event via Event.source_event_id.

Fields

reason: String

OrchestrationContinuedAsNew

Orchestration continued as new with fresh input (terminal for this execution).

Fields

input: String

OrchestrationCancelRequested

Cancellation has been requested for the orchestration (terminal will follow deterministically).

Fields

reason: String

ExternalSubscribedCancelled

An external event subscription was cancelled (e.g., lost a select2 race). Correlates to the ExternalSubscribed event via Event.source_event_id. This breadcrumb ensures deterministic replay — cancelled subscriptions are skipped during index-based matching.

Fields

reason: String

QueueSubscribed

Persistent subscription to an external event by name was recorded. Unlike positional ExternalSubscribed, persistent subscriptions use mailbox semantics: FIFO matching, no positional pairing.

Fields

name: String

QueueEventDelivered

A persistent external event was raised. Matched by name using FIFO mailbox semantics (not positional). Events stick around until consumed.

Fields

name: String

data: String

QueueSubscriptionCancelled

A persistent external event subscription was cancelled (e.g., lost a select2 race). Correlates to the QueueSubscribed event via Event.source_event_id. This breadcrumb ensures correct CAN carry-forward — cancelled subscriptions are not counted as having consumed an arrival.

Fields

reason: String

Trait Implementations

impl Clone for EventKind

fn clone(&self) -> EventKind

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventKind

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for EventKind

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for EventKind

fn eq(&self, other: &EventKind) -> 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 Serialize for EventKind

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for EventKind

impl StructuralPartialEq for EventKind