Crate fuse_rule

Crate fuse_rule 

Source
Expand description

§FuseRule - High-Performance Rule Engine

FuseRule is a high-performance, Arrow-native Complex Event Processing (CEP) engine with SQL-powered rules for real-time data auditing and event processing.

§Quick Start

use fuse_rule::{RuleEngine, config::FuseRuleConfig};

let config = FuseRuleConfig::from_file("fuse_rule_config.yaml")?;
let mut engine = RuleEngine::from_config(config).await?;
// Process batches and evaluate rules...

§Features

  • Arrow-Native: Zero-copy columnar data processing
  • SQL-Powered Rules: Write predicates using standard SQL
  • Stateful Transitions: Track rule activation/deactivation
  • Time Windows: Sliding windows for aggregate functions
  • Pluggable Architecture: Custom state stores, evaluators, and agents

Modules§

agent
agent_queue
cli
config
debugger
evaluator
ingestion
metrics
repl
rule
server
state
window

Structs§

EvaluationTrace
A trace of what happened during an evaluation batch.
RuleEngine
The core rule engine that evaluates rules against data batches.