Struct EngineEventData 

pub struct EngineEventData {
    pub timestamp: u64,
    pub run_id: String,
    pub event: EngineEvent,
}

A single workflow engine event with timestamp and run identity.

Fields

timestamp: u64

Unix timestamp (seconds) when the event was emitted.

run_id: String

The workflow run ID this event belongs to.

event: EngineEvent

The event payload.

Implementations

impl EngineEventData

pub fn new(run_id: String, event: EngineEvent) -> Self

Examples found in repository

examples/stdout_event_sink.rs (lines 37-42)

fn main() {
    let sink = StdoutEventSink;

    sink.emit(&EngineEventData::new(
        "run-001".into(),
        EngineEvent::RunStarted {
            workflow_name: "my-workflow".into(),
        },
    ));
    sink.emit(&EngineEventData::new(
        "run-001".into(),
        EngineEvent::RunCompleted { succeeded: true },
    ));

    // Wire it into a FlowEngine (builder shown; engine not actually run here):
    let _engine = FlowEngineBuilder::new()
        .event_sink(Box::new(StdoutEventSink))
        .build()
        .expect("engine build failed");
    println!("engine built with StdoutEventSink attached");
}

Trait Implementations

impl Clone for EngineEventData

fn clone(&self) -> EngineEventData

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EngineEventData

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

Formats the value using the given formatter.