dataflow-rs 4.0.0

A lightweight rules engine for building IFTTT-style automation and data processing pipelines in Rust. Define rules with JSONLogic conditions, execute actions, and chain workflows.
Documentation 
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
31
32
33
34
35
36

//! Runs: executing a program over a message.

mod builder;
mod cancel;
mod engine;
mod error_context;
mod fan_out;
pub(crate) mod host;
mod interp;
mod message;
mod observers;
mod options;
pub(crate) mod policy;
mod record;
mod report;
#[cfg(test)]
mod tests;
mod trace;

/// The clock a deadline is read on: `web_time::Instant`, which is
/// `std::time::Instant` itself on native targets and a browser clock on
/// wasm32.
pub use crate::base::Instant;
pub use crate::base::{CancelToken, Change, Context, ErrorRecord};
pub use crate::observe::status::{RunStatus, Selection, WorkflowExit, WorkflowRecord};
pub use builder::EngineBuilder;
pub(crate) use cancel::timers_available;
pub use engine::{Engine, EngineConfig};
pub use error_context::ErrorContext;
pub use interp::CHECK_EVERY;
pub use message::{AuditEntry, AuditMode, Message};
pub use options::RunOptions;
pub(crate) use record::TaskIds;
#[doc(hidden)]
pub use report::ArenaStats;
pub use report::Run;