aion-rs 0.3.0

Transport-agnostic Aion workflow engine with durability, replay, timers, and supervision.
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
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

//! Sole beamr boundary for aion per D1; other modules use `RuntimeHandle`.

/// Runtime configuration values passed to beamr.
pub mod config;
mod engine_nifs;
/// Runtime handle, process identifiers, and spawn input.
pub mod handle;
/// Loaded BEAM module representation.
pub mod module;
/// Runtime monitor utilities.
pub mod monitor;
/// Native-function registration records.
pub mod nif;
mod nif_activity;
mod nif_activity_dispatch;
mod nif_child;
mod nif_child_engine;
mod nif_child_spawn_retry;
mod nif_child_tasks;
mod nif_child_watch;
mod nif_collect;
mod nif_concurrency;
/// Workflow NIF execution context.
pub mod nif_context;
mod nif_continue_as_new;
pub(crate) mod nif_determinism;
mod nif_query;
mod nif_query_mailbox;
mod nif_query_pump;
mod nif_signal;
pub(crate) mod nif_state;
#[cfg(test)]
mod nif_test_stores;
pub(crate) mod nif_timeout;
pub(crate) mod nif_timer;
pub(crate) mod nif_timer_bridge;
mod nif_wake;
/// Workflow process exit outcomes.
pub mod outcome;
/// Payload conversion helpers used at the runtime boundary.
pub mod payload;
mod wake_confirm;
/// Workflow module and entrypoint execution helpers.
pub mod workflow;

pub use config::{RuntimeConfig, SignalDeliveryConfig};
pub use handle::{Pid, RuntimeHandle, RuntimeInput};
pub use nif::{Mfa, NifEntry, NifRegistration};
pub(crate) use nif_activity::install_nif_runtime_context;
pub(crate) use nif_child::install_child_nif_bridge;
pub(crate) use nif_child_engine::{ChildNifBridge, ChildNifBridgeParts};
pub(crate) use nif_query::install_query_bridge;
pub(crate) use nif_signal::{SignalNifBridge, install_signal_nif_bridge};
pub(crate) use nif_state::EngineNifState;
pub use outcome::WorkflowProcessOutcome;