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

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.

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