Struct TriggerManager 

pub struct TriggerManager { /* private fields */ }

Business logic layer for the trigger system.

Wraps a dyn TriggerStore and implements condition evaluation, trigger firing, and execution dedup. Modelled after pynenc’s BaseTrigger evaluation methods.

Implementations

impl TriggerManager

pub fn new(store: Arc<dyn TriggerStore>) -> Self

pub fn store(&self) -> &Arc<dyn TriggerStore>

Access the underlying store (for registration passthrough).

pub async fn report_status_change( &self, ctx: &StatusContext, ) -> RustvelloResult<Vec<ValidCondition>>

Report a status change — finds and records matching StatusConditions.

pub async fn report_result( &self, ctx: &ResultContext, ) -> RustvelloResult<Vec<ValidCondition>>

Report a successful task result — finds and records matching ResultConditions.

pub async fn report_failure( &self, ctx: &ExceptionContext, ) -> RustvelloResult<Vec<ValidCondition>>

Report a task failure — finds and records matching ExceptionConditions.

pub async fn emit_event( &self, event_code: &str, payload: Value, ) -> RustvelloResult<String>

Emit a custom event — finds and records matching EventConditions. Returns the generated event ID.

pub async fn evaluate_cron_conditions( &self, ) -> RustvelloResult<Vec<ValidCondition>>

Evaluate all cron conditions against the current time.

For each cron condition:

1. Parse the cron_expression with the croner crate; log and skip on syntax error.
2. Check whether the current minute matches the schedule via is_time_matched.
3. Also enforce min_interval_seconds to prevent double-firing within the same minute.
4. Use optimistic locking (store_cron_execution) across multiple runner instances.

pub async fn evaluate_triggers( &self, ) -> RustvelloResult<Vec<(TriggerDefinitionDTO, Value)>>

Process all pending valid conditions and determine which triggers should fire.

Returns a list of (trigger definition, arguments) pairs ready for invocation.

Trait Implementations

impl Clone for TriggerManager

fn clone(&self) -> TriggerManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.