Skip to main content

aion_worker/runtime/
mod.rs

1//! Worker activity dispatch runtime support.
2
3/// Typed activity dispatch and payload conversion helpers.
4pub mod dispatch;
5/// Liminal worker transport (LSUB-1): receive pushed dispatches, execute, reply.
6#[cfg(feature = "liminal-transport")]
7pub mod liminal;
8/// Candidate-cycling redial driver for liminal worker reconnect-to-survivor
9/// (G-1, #112): the transport-free cursor + backoff + loop the liminal worker
10/// uses to migrate from a dead owner to a survivor's listener.
11#[cfg(feature = "liminal-transport")]
12pub mod liminal_redial;
13/// Reconnect-to-survivor serve entry point: wires the real liminal worker connect
14/// + serve into the redial driver (G-1, #112).
15#[cfg(feature = "liminal-transport")]
16pub mod liminal_serve;
17/// Activity polling loop and shutdown primitives.
18pub mod loop_;
19/// Dispatch-outcome reporting and runtime-channel draining.
20pub(crate) mod report;
21
22pub use dispatch::{TypedActivityDispatcher, decode_payload, encode_payload};
23#[cfg(feature = "liminal-transport")]
24pub use liminal::{DispatchRequest, DispatchResponse, LiminalActivityWorker};
25#[cfg(feature = "liminal-transport")]
26pub use liminal_serve::serve_with_redial;
27pub use loop_::{
28    ActivityDispatcher, DispatchOutcome, NoShutdown, ServeEnd, SessionHealth, serve_activity_tasks,
29    serve_activity_tasks_until,
30};