Enum Event 

pub enum Event {
    RunCreated {
        run_id: Uuid,
        workflow_name: String,
        at: DateTime<Utc>,
    },
    RunStatusChanged {
        run_id: Uuid,
        workflow_name: String,
        from: RunStatus,
        to: RunStatus,
        error: Option<String>,
        cost_usd: Decimal,
        duration_ms: u64,
        at: DateTime<Utc>,
    },
    RunFailed {
        run_id: Uuid,
        workflow_name: String,
        error: Option<String>,
        cost_usd: Decimal,
        duration_ms: u64,
        at: DateTime<Utc>,
    },
    StepCompleted {
        run_id: Uuid,
        step_id: Uuid,
        step_name: String,
        kind: StepKind,
        duration_ms: u64,
        cost_usd: Decimal,
        at: DateTime<Utc>,
    },
    StepFailed {
        run_id: Uuid,
        step_id: Uuid,
        step_name: String,
        kind: StepKind,
        error: String,
        at: DateTime<Utc>,
    },
    ApprovalRequested {
        run_id: Uuid,
        step_id: Uuid,
        message: String,
        at: DateTime<Utc>,
    },
    ApprovalGranted {
        run_id: Uuid,
        approved_by: String,
        at: DateTime<Utc>,
    },
    ApprovalRejected {
        run_id: Uuid,
        rejected_by: String,
        at: DateTime<Utc>,
    },
    LogLine {
        run_id: Uuid,
        step_id: Uuid,
        step_name: String,
        stream: LogStream,
        line: String,
        at: DateTime<Utc>,
    },
    UserSignedIn {
        user_id: Uuid,
        username: String,
        at: DateTime<Utc>,
    },
    UserSignedUp {
        user_id: Uuid,
        username: String,
        at: DateTime<Utc>,
    },
    UserSignedOut {
        user_id: Uuid,
        at: DateTime<Utc>,
    },
}

A domain event emitted by the ironflow system.

Covers the full lifecycle: runs, steps, approvals, and authentication. Subscribers receive these via EventPublisher and pattern-match on the variants they care about.

Examples

use ironflow_engine::notify::Event;
use ironflow_store::models::RunStatus;
use uuid::Uuid;

let event = Event::RunStatusChanged {
    run_id: Uuid::now_v7(),
    workflow_name: "deploy".to_string(),
    from: RunStatus::Running,
    to: RunStatus::Completed,
    error: None,
    cost_usd: rust_decimal::Decimal::ZERO,
    duration_ms: 5000,
    at: chrono::Utc::now(),
};

Variants

RunCreated

A new run was created (status: Pending).

Fields

run_id: Uuid

Run identifier.

workflow_name: String

Workflow name.

at: DateTime<Utc>

When the run was created.

RunStatusChanged

A run changed status.

Fields

run_id: Uuid

Run identifier.

workflow_name: String

Workflow name.

from: RunStatus

Previous status.

to: RunStatus

New status.

error: Option<String>

Error message (when transitioning to Failed).

cost_usd: Decimal

Aggregated cost in USD at the time of transition.

duration_ms: u64

Aggregated duration in milliseconds at the time of transition.

at: DateTime<Utc>

When the transition occurred.

RunFailed

A run transitioned to Failed.

This is a convenience event emitted alongside RunStatusChanged when the target status is Failed. Subscribe to this instead of RUN_STATUS_CHANGED when you only care about failures.

Fields

run_id: Uuid

Run identifier.

workflow_name: String

Workflow name.

error: Option<String>

Error message.

cost_usd: Decimal

Aggregated cost in USD at the time of failure.

duration_ms: u64

Aggregated duration in milliseconds at the time of failure.

at: DateTime<Utc>

When the failure occurred.

StepCompleted

A step completed successfully.

Fields

run_id: Uuid

Run identifier.

step_id: Uuid

Step identifier.

step_name: String

Human-readable step name.

kind: StepKind

Step operation kind.

duration_ms: u64

Step duration in milliseconds.

cost_usd: Decimal

Step cost in USD.

at: DateTime<Utc>

When the step completed.

StepFailed

A step failed.

Fields

run_id: Uuid

Run identifier.

step_id: Uuid

Step identifier.

step_name: String

Human-readable step name.

kind: StepKind

Step operation kind.

error: String

Error message.

at: DateTime<Utc>

When the step failed.

ApprovalRequested

A run is waiting for human approval.

Fields

run_id: Uuid

Run identifier.

step_id: Uuid

Approval step identifier.

message: String

Message displayed to reviewers.

at: DateTime<Utc>

When the approval was requested.

ApprovalGranted

A run was approved by a human.

Fields

run_id: Uuid

Run identifier.

approved_by: String

User who approved (ID or username).

at: DateTime<Utc>

When the approval was granted.

ApprovalRejected

A run was rejected by a human.

Fields

run_id: Uuid

Run identifier.

rejected_by: String

User who rejected (ID or username).

at: DateTime<Utc>

When the rejection occurred.

LogLine

A log line emitted during step execution.

Pushed by the worker in real time so that SSE clients can stream step output as it happens, without waiting for step completion.

Fields

run_id: Uuid

Run identifier.

step_id: Uuid

Step identifier.

step_name: String

Human-readable step name.

stream: LogStream

Output stream.

line: String

The log line content.

at: DateTime<Utc>

When the line was emitted.

UserSignedIn

A user signed in.

Fields

user_id: Uuid

User identifier.

username: String

Username.

at: DateTime<Utc>

When the sign-in occurred.

UserSignedUp

A new user signed up.

Fields

user_id: Uuid

User identifier.

username: String

Username.

at: DateTime<Utc>

When the sign-up occurred.

UserSignedOut

A user signed out.

Fields

user_id: Uuid

User identifier.

at: DateTime<Utc>

When the sign-out occurred.

Implementations

impl Event

pub const RUN_CREATED: &'static str = "run_created"

Event type constant for RunCreated.

pub const RUN_STATUS_CHANGED: &'static str = "run_status_changed"

Event type constant for RunStatusChanged.

pub const RUN_FAILED: &'static str = "run_failed"

Event type constant for RunFailed.

pub const STEP_COMPLETED: &'static str = "step_completed"

Event type constant for StepCompleted.

pub const STEP_FAILED: &'static str = "step_failed"

Event type constant for StepFailed.

pub const APPROVAL_REQUESTED: &'static str = "approval_requested"

Event type constant for ApprovalRequested.

pub const APPROVAL_GRANTED: &'static str = "approval_granted"

Event type constant for ApprovalGranted.

pub const APPROVAL_REJECTED: &'static str = "approval_rejected"

Event type constant for ApprovalRejected.

pub const LOG_LINE: &'static str = "log_line"

Event type constant for LogLine.

pub const USER_SIGNED_IN: &'static str = "user_signed_in"

Event type constant for UserSignedIn.

pub const USER_SIGNED_UP: &'static str = "user_signed_up"

Event type constant for UserSignedUp.

pub const USER_SIGNED_OUT: &'static str = "user_signed_out"

Event type constant for UserSignedOut.

pub const ALL: &'static [&'static str]

All event types. Pass this to EventPublisher::subscribe to receive every event.

Examples

use ironflow_engine::notify::{Event, EventPublisher, WebhookSubscriber};

let mut publisher = EventPublisher::new();
publisher.subscribe(
    WebhookSubscriber::new("https://example.com/all"),
    Event::ALL,
);

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

Returns the event type as a static string (e.g. "run_status_changed").

Useful for filtering and logging without deserializing.

Examples

use ironflow_engine::notify::Event;
use uuid::Uuid;
use chrono::Utc;

let event = Event::UserSignedIn {
    user_id: Uuid::now_v7(),
    username: "alice".to_string(),
    at: Utc::now(),
};
assert_eq!(event.event_type(), "user_signed_in");

Trait Implementations

impl Clone for Event

fn clone(&self) -> Event

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 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.