aion-rs 0.21.0

Transport-agnostic Aion workflow engine with durability, replay, timers, and supervision.
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
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76

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

mod cleanup_executor;
/// Runtime configuration values passed to beamr.
pub mod config;
mod engine_nifs;
pub(crate) mod engine_tasks;
/// 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_advisory;
mod nif_activity_agent;
mod nif_activity_await;
#[cfg(test)]
mod nif_activity_delivery_tests;
mod nif_activity_dispatch;
mod nif_activity_fallback;
mod nif_activity_in_vm;
mod nif_activity_retry;
mod nif_activity_retry_dispatch;
mod nif_child;
mod nif_child_engine;
mod nif_child_spawn_retry;
mod nif_child_watch;
mod nif_collect;
mod nif_collect_dispatch;
mod nif_collect_settlement;
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_diagnostic;
mod nif_query_mailbox;
mod nif_query_pump;
mod nif_result_term;
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;
pub(crate) mod nif_timer_fire;
mod nif_wake;
/// Workflow process exit outcomes.
pub mod outcome;
/// Payload conversion helpers used at the runtime boundary.
pub mod payload;
mod process_exit;
mod wake_confirm;
/// Workflow module and entrypoint execution helpers.
pub mod workflow;

pub use config::{
    CompletionRetryConfig, InvalidCompletionRetryLadder, RuntimeConfig, SignalDeliveryConfig,
};
pub use handle::{Pid, RuntimeHandle, RuntimeInput};
pub use nif::{Determinism, Mfa, NifEntry, NifRegistration};
pub(crate) use nif_activity::install_nif_runtime_context;
pub use nif_activity_retry::{
    PARKED_ACTIVITY_REASON, activity_timeout_from_config, activity_timeout_reason, is_parked_reason,
};
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;