Enum EventDetails 

pub enum EventDetails {
    WorkflowStarted {
        metadata: WorkflowMetadata,
        input: HashMap<String, Value>,
    },
    WorkflowCompleted {
        duration_ms: u64,
        result: ExecutionResult,
    },
    WorkflowFailed {
        error: String,
        duration_ms: u64,
        stack_trace: Option<String>,
    },
    WorkflowCancelled {
        reason: String,
        duration_ms: u64,
    },
    NodeStarted {
        node_kind: NodeKind,
        input: HashMap<String, Value>,
    },
    NodeCompleted {
        node_kind: NodeKind,
        duration_ms: u64,
        metrics: NodeMetrics,
        output: HashMap<String, Value>,
    },
    NodeFailed {
        node_kind: NodeKind,
        error: String,
        stack_trace: Option<String>,
        retry_attempt: u32,
    },
    NodeSkipped {
        node_kind: NodeKind,
        reason: String,
    },
    VariableChanged {
        variable_name: String,
        old_value: Option<Value>,
        new_value: Value,
        source: String,
    },
    ErrorOccurred {
        error: String,
        stack_trace: Option<String>,
        context: HashMap<String, Value>,
    },
    CheckpointCreated {
        checkpoint_id: String,
        nodes_completed: usize,
        state: String,
    },
    ExecutionResumed {
        checkpoint_id: String,
        nodes_to_skip: usize,
    },
}

Detailed event information

Variants

WorkflowStarted

Workflow started event

Fields

metadata: WorkflowMetadata

Workflow metadata

input: HashMap<String, Value>

Input parameters

WorkflowCompleted

Workflow completed successfully

Fields

duration_ms: u64

Total execution duration in milliseconds

result: ExecutionResult

Final execution result

WorkflowFailed

Workflow failed

Fields

error: String

Error message

duration_ms: u64

Total execution duration in milliseconds

stack_trace: Option<String>

Stack trace if available

WorkflowCancelled

Workflow cancelled by user

Fields

reason: String

Reason for cancellation

duration_ms: u64

Partial execution duration

NodeStarted

Node started execution

Fields

node_kind: NodeKind

Type of node being executed

input: HashMap<String, Value>

Node input data

NodeCompleted

Node completed successfully

Fields

node_kind: NodeKind

Type of node executed

duration_ms: u64

Node execution duration in milliseconds

metrics: NodeMetrics

Performance metrics

output: HashMap<String, Value>

Node output data

NodeFailed

Node failed

Fields

node_kind: NodeKind

Type of node that failed

error: String

Error message

stack_trace: Option<String>

Stack trace if available

retry_attempt: u32

Retry attempt number (0 for first attempt)

NodeSkipped

Node skipped (e.g., due to conditional logic)

Fields

node_kind: NodeKind

Type of node skipped

reason: String

Reason for skipping

VariableChanged

Variable changed

Fields

variable_name: String

Variable name

old_value: Option<Value>

Previous value (None if newly created)

new_value: Value

New value

source: String

Source of the change (node ID or “system”)

ErrorOccurred

Error occurred

Fields

error: String

Error message

stack_trace: Option<String>

Stack trace if available

context: HashMap<String, Value>

Additional error context

CheckpointCreated

Checkpoint created

Fields

checkpoint_id: String

Checkpoint identifier

nodes_completed: usize

Number of nodes completed

state: String

Current execution state

ExecutionResumed

Execution resumed

Fields

checkpoint_id: String

Checkpoint used for resumption

nodes_to_skip: usize

Number of nodes to skip

Trait Implementations

impl Clone for EventDetails

fn clone(&self) -> EventDetails

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventDetails

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for EventDetails

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for EventDetails

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

where __S: Serializer,

Serialize this value into the given Serde serializer.