Struct TriggerExecutionService

pub struct TriggerExecutionService<T: TriggerRepositoryTrait> { /* private fields */ }

Service for executing triggers with notifications

Coordinates trigger lookup, variable substitution, and notification delivery across different notification channels

Implementations

impl<T: TriggerRepositoryTrait> TriggerExecutionService<T>

pub fn new( trigger_service: TriggerService<T>, notification_service: NotificationService, ) -> Self

Creates a new trigger execution service

Arguments

• trigger_service - Service for trigger operations
• notification_service - Service for notification delivery

Returns

• Self - New trigger execution service instance

Trait Implementations

impl<T: TriggerRepositoryTrait + Send + Sync> TriggerExecutionServiceTrait for TriggerExecutionService<T>

fn execute<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, trigger_slugs: &'life1 [String], variables: HashMap<String, String>, monitor_match: &'life2 MonitorMatch, trigger_scripts: &'life3 HashMap<String, (ScriptLanguage, String)>, ) -> Pin<Box<dyn Future<Output = Result<(), TriggerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Executes multiple triggers with variable substitution

Arguments

• trigger_slugs - List of trigger identifiers to execute
• variables - Variables to substitute in trigger templates

Returns

• Result<(), TriggerError> - Success or error

Errors

• Returns TriggerError::NotFound if a trigger cannot be found
• Returns TriggerError::ExecutionError if notification delivery fails

fn load_scripts<'life0, 'life1, 'async_trait>( &'life0 self, monitors: &'life1 [Monitor], ) -> Pin<Box<dyn Future<Output = Result<HashMap<String, (ScriptLanguage, String)>, TriggerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Loads trigger condition scripts for monitors

Arguments

• monitors - List of monitors containing trigger conditions

Returns

• Result<HashMap<String, (ScriptLanguage, String)>, TriggerError> - Map of monitor names and script path to their script language and content

Errors

• Returns TriggerError::ConfigurationError if script files cannot be read