Struct EventTrigger 

pub struct EventTrigger { /* private fields */ }

A trigger that reacts to internal domain events.

Register this trigger with the runtime via Runtime::trigger. It must also be registered as an EventSubscriber on the EventPublisher so it receives events.

Examples

use ironflow_runtime::trigger::event::{EventTrigger, EventTriggerRule};
use ironflow_store::entities::EventKind;

let trigger = EventTrigger::new(vec![
    EventTriggerRule {
        on_event: EventKind::RunFailed,
        source_workflow: "deploy".to_string(),
        target_workflow: "rollback".to_string(),
        max_chain_depth: 3,
    },
]);

Implementations

impl EventTrigger

pub fn new(rules: Vec<EventTriggerRule>) -> Self

Create a new event trigger with the given rules.

Examples

use ironflow_runtime::trigger::event::{EventTrigger, EventTriggerRule};
use ironflow_store::entities::EventKind;

let trigger = EventTrigger::new(vec![
    EventTriggerRule {
        on_event: EventKind::RunFailed,
        source_workflow: "deploy".to_string(),
        target_workflow: "rollback".to_string(),
        max_chain_depth: 3,
    },
]);

pub fn subscribed_event_types(&self) -> Vec<&'static str>

The event kinds this trigger listens for (for EventPublisher subscription).

Examples

use ironflow_runtime::trigger::event::{EventTrigger, EventTriggerRule};
use ironflow_store::entities::EventKind;

let trigger = EventTrigger::new(vec![
    EventTriggerRule {
        on_event: EventKind::RunFailed,
        source_workflow: "deploy".to_string(),
        target_workflow: "rollback".to_string(),
        max_chain_depth: 3,
    },
]);
let kinds = trigger.subscribed_event_types();
assert!(kinds.contains(&"run_failed"));

Trait Implementations

impl EventSubscriber for EventTrigger

fn name(&self) -> &str

A short identifier for this subscriber (used in logs).

fn handle<'a>(&'a self, event: &'a Event) -> SubscriberFuture<'a>

Handle a domain event.

impl Trigger for EventTrigger

fn name(&self) -> &str

Human-readable name for logging.

fn start<'a>( &'a self, sink: TriggerSink, token: &'a CancellationToken, ) -> TriggerFuture<'a>

Start the trigger.