Struct EventHandlingEngine 

pub struct EventHandlingEngine { /* private fields */ }

Event handling engine

Implementations

impl EventHandlingEngine

pub fn new() -> EventHandlingEngine

Create a new event handling engine

pub fn with_max_concurrent_handlers(self, limit: usize) -> EventHandlingEngine

Create a new event handling engine with custom concurrent handlers limit

pub async fn set_rule_strategy(&self, strategy: RuleAdjustmentStrategy)

Set rule adjustment strategy

pub async fn register_plugin( &self, plugin: Box<dyn EventResponsePlugin + Sync + Send>, )

Register an event response plugin

pub async fn register_plugins( &self, plugins: Vec<Box<dyn EventResponsePlugin + Sync + Send>>, )

Register multiple plugins at once

pub async fn submit_event(&self, event: Event)

Submit an event to be handled

pub async fn process_next_event(&self) -> Result<Option<Event>, Error>

Process the next event in the queue

pub async fn start(&self) -> Result<(), Error>

Start the engine and process events continuously