Struct EventDrivenProcessor

pub struct EventDrivenProcessor { /* private fields */ }

Event-driven graph processing system that triggers algorithms based on graph changes This system monitors graph updates and automatically executes relevant algorithms

Implementations

impl EventDrivenProcessor

pub fn new(graph: ArrowGraph) -> Result<Self>

Create new event-driven processor

pub fn initialize(&mut self) -> Result<()>

Initialize the processor with default algorithms

pub fn add_rule(&mut self, rule: EventRule)

Add a new event rule

pub fn update(&mut self, changes: UpdateResult) -> Result<Vec<ProcessedEvent>>

Update the graph and process events

pub fn processor(&self) -> &IncrementalGraphProcessor

Get processor reference

pub fn processor_mut(&mut self) -> &mut IncrementalGraphProcessor

Get mutable processor reference

pub fn pagerank_results(&self) -> Option<&HashMap<String, f64>>

Get PageRank results

pub fn components_results(&self) -> Option<&HashMap<String, String>>

Get connected components results

pub fn recent_events(&self, count: usize) -> Vec<&ProcessedEvent>

Get recent events

pub fn algorithm_stats(&self) -> &HashMap<String, AlgorithmStats>

Get algorithm statistics

pub fn event_rules(&self) -> &[EventRule]

Get event rules

pub fn set_rule_enabled(&mut self, rule_name: &str, enabled: bool)

Enable/disable a rule

pub fn recent_anomalies(&self, count: usize) -> Vec<&AnomalyEvent>

Get recent anomalies

Trait Implementations

impl Debug for EventDrivenProcessor

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

Formats the value using the given formatter.