Module processing 

Advanced Event Processing Module

This module provides sophisticated event processing capabilities including:

• Time-based and count-based windowing
• Streaming aggregations (count, sum, average, min, max)
• Complex event pattern detection
• Event correlation and causality tracking
• Real-time analytics and metrics computation

The module is organized into several sub-modules:

• window: Window management and windowing logic
• aggregation: Aggregation functions and state management
• processor: Main event processing engine
• complex: Complex event processing patterns
• analytics: Real-time analytics and metrics
• anomaly: Anomaly detection capabilities
• temporal: Advanced temporal processing
• causality: Causality analysis and correlation

Re-exports

pub use aggregation::AggregateFunction;

pub use aggregation::AggregationManager;

pub use aggregation::AggregationState;

pub use processor::EventProcessor;

pub use processor::ProcessorConfig;

pub use processor::ProcessorStats;

pub use window::EventWindow;

pub use window::Watermark;

pub use window::WindowConfig;

pub use window::WindowResult;

pub use window::WindowTrigger;

pub use window::WindowType;

Modules

aggregation

Aggregation functions and state management for event processing

processor

Main event processor implementation

window

Window management for event processing