Struct TriggerEngine 

pub struct TriggerEngine { /* private fields */ }

Engine that manages triggers and evaluates them.

Implementations

impl TriggerEngine

pub fn new() -> Self

Create a new trigger engine.

pub fn add_trigger(&mut self, workflow_id: &str, trigger: TriggerType)

Add a trigger for a workflow.

pub fn evaluate_file_arrival(&self, path: &str, size: u64) -> Vec<String>

Evaluate file arrival event and return workflow IDs that should be triggered.

pub fn evaluate_event(&self, event: &HashMap<String, String>) -> Vec<String>

Evaluate an event and return workflow IDs that should be triggered.

pub fn get_triggers(&self, workflow_id: &str) -> &[TriggerType]

Get triggers for a workflow.

pub fn remove_workflow(&mut self, workflow_id: &str)

Remove all triggers for a workflow.

pub fn workflow_ids(&self) -> Vec<&str>

List all registered workflow IDs.

Trait Implementations

impl Debug for TriggerEngine

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

Formats the value using the given formatter.

impl Default for TriggerEngine

fn default() -> TriggerEngine

Returns the “default value” for a type.