Struct RulesEngine 

pub struct RulesEngine { /* private fields */ }

The rules engine evaluates rules against state changes.

Implementations

impl RulesEngine

pub fn new() -> Self

Create a new empty rules engine

pub fn add_rule(&mut self, rule: Rule) -> Result<()>

Add or update a rule

pub fn remove_rule(&mut self, id: &str) -> Result<()>

Remove a rule by ID

pub fn get_rule(&self, id: &str) -> Option<&Rule>

Get a rule by ID

pub fn rules(&self) -> impl Iterator<Item = &Rule>

Get all rules

pub fn len(&self) -> usize

Number of rules

pub fn is_empty(&self) -> bool

Check if empty

pub fn set_enabled(&mut self, id: &str, enabled: bool) -> Result<()>

Enable or disable a rule

pub fn evaluate<F>( &mut self, address: &str, value: &Value, signal_type: SignalType, origin: Option<&str>, state_lookup: F, ) -> Vec<PendingAction>

where F: Fn(&str) -> Option<Value>,

Evaluate rules triggered by a state change.

address: the address that changed value: the new value signal_type: Param or Event origin: if set, skip rules that originated from this source (loop prevention) state_lookup: function to look up current param values (for conditions)

Returns actions that should be executed by the router.

pub fn evaluate_interval<F>( &mut self, rule_id: &str, state_lookup: F, ) -> Vec<PendingAction>

where F: Fn(&str) -> Option<Value>,

Evaluate an interval rule by ID.

Unlike evaluate(), this doesn’t match on address/signal_type — it fires the rule directly (checking enabled, cooldown, and conditions). Returns actions that should be executed by the router.

pub fn interval_rules(&self) -> Vec<(String, u64)>

Get rule IDs that have interval triggers (for the router to schedule)

Trait Implementations

impl Default for RulesEngine

fn default() -> Self

Returns the “default value” for a type.