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

//! Engine API, builder, and delegated seam surfaces.

/// High-level workflow engine API.
pub mod api;
/// Engine durable-schedule API surface and coordinator assembly.
mod api_schedule;
/// Engine construction and package source configuration.
pub mod builder;
/// Delegated signal, query, and event-publishing seams.
pub mod delegated;
/// Runtime package-load seam: live load, routing, listing, unload.
mod reload;
/// `EngineHandle` seam implementation for the engine.
mod seam_handle;
/// Seam-assembly helpers used by `EngineBuilder::build()`.
mod seams;
/// Shutdown gating for in-flight lifecycle operations.
mod shutdown_gate;
/// Startup recovery wiring used by `EngineBuilder::build()`.
mod startup;
/// Crash-window repair sweeps run by startup recovery.
mod startup_sweeps;

pub use api::Engine;
pub use builder::EngineBuilder;
pub use delegated::{
    DeferredEventPublisher, DeferredQueryService, DeferredSignalRouter, DelegatedSeams,
    EventFamily, EventFilter, EventPublisher, EventStreamLagged, QueryService, SignalRouter,
};