rule-engine 1.0.0-rc4

High-performance edge stream processing engine and MQTT rule engine daemon (rekuiper / eKuiper drop-in)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

//! # rule-engine
//!
//! High-performance edge stream processing engine and streaming SQL rule engine in Rust.
//!
//! ## Embedding in Your Own Application
//!
//! You can embed `rule-engine` or its streaming SQL engine directly in your Rust project:
//!
//! ```toml
//! [dependencies]
//! rule-engine = "1.0.0-rc4"
//! ```
//!
//! ### Using the Streaming SQL Engine
//!
//! ```rust
//! use rule_engine::sql::{Parser, RowLookup};
//! use serde_json::json;
//!
//! # fn main() -> anyhow::Result<()> {
//! let sql = "SELECT temperature * 1.8 + 32 AS temp_f FROM sensor WHERE temperature > 20";
//! let mut parser = Parser::new(sql);
//! let stmt = parser.parse_select()?;
//! # Ok(())
//! # }
//! ```

pub use kuiperd::*;
pub use rekuiper_core as core;
pub use rekuiper_sql as sql;