aion-rs 0.2.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

//! pub mod declarations + re-exports only

/// Durable command model and resolution outcomes.
pub mod command;
/// Correlation keys used to match commands to recorded events.
pub mod correlation;
/// History cursor used during replay resolution.
pub mod cursor;
/// Deterministic time and randomness context.
pub mod determinism;
/// Durability and non-determinism errors.
pub mod error;
/// Live execution handoff after replay is exhausted.
pub mod executor;
/// Single-writer recorder for workflow history events.
pub mod recorder;
/// Active workflow recovery and replay orchestration.
pub mod recovery;
/// Replay driver and replay-step outcomes.
pub mod replay;
/// Command resolver that compares live commands with recorded history.
pub mod resolver;
/// Event sequence-head helpers.
pub mod seq;
/// Signal delivery state for durable signal handling.
pub mod signal;

pub use command::{Command, Resolution, ResolveOutcome};
pub use correlation::CorrelationKey;
pub use cursor::{
    ChildTerminalResolveResult, CursorResolveResult, FoundEventDescriptor, HistoryCursor,
    RecordedEventFamily, current_run_segment,
};
pub use determinism::DeterminismContext;
pub use error::{DurabilityError, NonDeterminismError};
pub use executor::{
    HandoffOutcome, LiveActivityOutcome, LiveChildOutcome, LiveExecutor, resolve_or_execute_live,
};
pub use recorder::{Recorder, WorkflowStartRecord};
pub use recovery::{
    ActiveWorkflowRecovery, ActiveWorkflowRecoverySeam, ActiveWorkflowRecoverySeamImpl,
    RecoveryDriver, RecoveryOutcome, RecoveryPlan, RecoveryReport, RecoveryResumePoint, recover,
};
pub use replay::{Replay, ReplayOutcome, ReplayStep, ReplayTerminal};
pub use resolver::{
    NON_DETERMINISM_WORKFLOW_ERROR_PREFIX, ResolvedCommand, Resolver, fail_on_violation,
};
pub use seq::SequenceHead;
pub use signal::SignalDelivery;