Enum WorkflowBusEvent 

pub enum WorkflowBusEvent {
    WorkflowCreated {
        workflow_id: String,
        workflow_type: String,
        task_queue: String,
        status: String,
    },
    WorkflowStatusChanged {
        workflow_id: String,
        old_status: String,
        new_status: String,
        task_queue: String,
    },
    WorkflowNeedsDispatch {
        workflow_id: String,
        task_queue: String,
    },
    WorkflowStarted {
        workflow_id: String,
    },
    WorkflowRunning {
        workflow_id: String,
    },
    WorkflowCompleted {
        workflow_id: String,
    },
    WorkflowFailed {
        workflow_id: String,
    },
    WorkflowCancelled {
        workflow_id: String,
    },
    WorkflowTerminated {
        workflow_id: String,
    },
    ActivityInserted {
        activity_id: i64,
        workflow_id: String,
        task_queue: String,
        name: String,
    },
    ActivityStatusChanged {
        activity_id: i64,
        workflow_id: String,
        old_status: String,
        new_status: String,
    },
    SignalReceived {
        workflow_id: String,
        signal_name: String,
    },
    TimerFired {
        workflow_id: String,
        seq: i32,
    },
}

Every event kind the workflow subsystem emits. Each variant serialises to a workflow_* / activity_* kind string + a JSON payload. Fields are chosen to be small and self-contained; we never dump whole rows.

Variants

WorkflowCreated

Fields

workflow_id: String

workflow_type: String

task_queue: String

status: String

WorkflowStatusChanged

Fields

workflow_id: String

old_status: String

new_status: String

task_queue: String

WorkflowNeedsDispatch

Fields

workflow_id: String

task_queue: String

WorkflowStarted

Fields

workflow_id: String

WorkflowRunning

Fields

workflow_id: String

WorkflowCompleted

Fields

workflow_id: String

WorkflowFailed

Fields

workflow_id: String

WorkflowCancelled

Fields

workflow_id: String

WorkflowTerminated

Fields

workflow_id: String

ActivityInserted

Fields

activity_id: i64

workflow_id: String

task_queue: String

name: String

ActivityStatusChanged

Fields

activity_id: i64

workflow_id: String

old_status: String

new_status: String

SignalReceived

Fields

workflow_id: String

signal_name: String

TimerFired

Fields

workflow_id: String

seq: i32

Implementations

impl WorkflowBusEvent

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

The kind string written to engine_events.kind. Matches the serde rename_all = "snake_case" tag for each variant.

pub fn payload(&self) -> Value

Serialise the variant’s fields to JSON for engine_events.payload. Strips the kind serde tag from the payload since the kind lives in its own column.

Trait Implementations

impl Clone for WorkflowBusEvent

fn clone(&self) -> WorkflowBusEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowBusEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WorkflowBusEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for WorkflowBusEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.