dataflow_rs/run/
mod.rs

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

dataflow_rs/run/
mod.rs
