dataflow_rs/run/
mod.rs

1//! Runs: executing a program over a message.
2
3mod builder;
4mod cancel;
5mod engine;
6mod error_context;
7mod fan_out;
8pub(crate) mod host;
9mod interp;
10mod message;
11mod observers;
12mod options;
13pub(crate) mod policy;
14mod record;
15mod report;
16#[cfg(test)]
17mod tests;
18mod trace;
19
20/// The clock a deadline is read on: `web_time::Instant`, which is
21/// `std::time::Instant` itself on native targets and a browser clock on
22/// wasm32.
23pub use crate::base::Instant;
24pub use crate::base::{CancelToken, Change, Context, ErrorRecord};
25pub use crate::observe::status::{RunStatus, Selection, WorkflowExit, WorkflowRecord};
26pub use builder::EngineBuilder;
27pub(crate) use cancel::timers_available;
28pub use engine::{Engine, EngineConfig};
29pub use error_context::ErrorContext;
30pub use interp::CHECK_EVERY;
31pub use message::{AuditEntry, AuditMode, Message};
32pub use options::RunOptions;
33pub(crate) use record::TaskIds;
34#[doc(hidden)]
35pub use report::ArenaStats;
36pub use report::Run;
dataflow_rs/run/mod.rs

dataflow_rs/run/
mod.rs
