Struct StreamRuleEngine 

pub struct StreamRuleEngine { /* private fields */ }

Main streaming rule engine

Implementations

impl StreamRuleEngine

pub fn new() -> Self

Create a new stream rule engine

pub fn with_config(config: StreamConfig) -> Self

Create with custom configuration

pub async fn add_rule(&mut self, grl_rule: &str) -> Result<()>

Add streaming rule from GRL string

pub async fn add_rule_file<P: AsRef<Path>>(&mut self, path: P) -> Result<()>

Add streaming rule from file

pub async fn register_action_handler<F>(&self, action_type: &str, handler: F)

where F: Fn(&StreamAction) + Send + Sync + 'static,

Register action handler

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

Start the streaming engine

pub async fn stop(&self)

Stop the streaming engine

pub async fn send_event(&self, event: StreamEvent) -> Result<()>

Send event to stream for processing

pub async fn execute_rules(&self) -> Result<StreamExecutionResult>

Execute rules against current window state

pub async fn get_window_statistics(&self) -> WindowStatistics

Get current window statistics

pub async fn get_field_analytics(&self, field: &str) -> HashMap<String, Value>

Get analytics for a specific field

pub async fn is_running(&self) -> bool

Check if engine is running

Trait Implementations

impl Default for StreamRuleEngine

fn default() -> Self

Returns the “default value” for a type.