aion_server/worker/
mod.rs

1//! Module declarations.
2
3/// Bridge from engine activity dispatch to connected workers.
4pub mod bridge;
5/// Activity completion handling and dispatch abstractions.
6pub mod dispatch;
7/// Worker heartbeat and liveness tracking.
8pub mod heartbeat;
9/// Cross-node outbox dispatch over the liminal bus (#13-0 spike, feature-gated).
10#[cfg(feature = "liminal-transport")]
11pub mod liminal_transport;
12/// Server-side outbox completion delivery into live workflows.
13pub mod outbox_delivery;
14/// Non-replayed durable-outbox fan-out dispatcher (dormant unless commissioned).
15pub mod outbox_dispatcher;
16/// Live stale-claim outbox reconciler (dormant unless commissioned).
17pub mod outbox_reconciler;
18/// Connected-worker registry and handles.
19pub mod registry;
20
21pub use bridge::{OutboxDeliveryCallback, PendingActivities, WorkerActivityDispatcher};
22pub use dispatch::{
23    ActivityCompletion, ActivityCompletionOutcome, ActivityCompletionSink, ActivityDispatcher,
24    ScheduledActivity, handle_activity_result,
25};
26pub use heartbeat::{
27    HeartbeatTracker, HeartbeatUpdate, InFlightActivity, LostWorkerReport, TaskLiveness,
28};
29#[cfg(feature = "liminal-transport")]
30pub use liminal_transport::{
31    DispatchRequest, DispatchResponse, LiminalCompletionSource, LiminalConnectionNotifier,
32    LiminalWorkerDelivery, RegistryLiminalDispatch, channel_for_row, dispatch_channel_name,
33};
34pub use outbox_delivery::ServerOutboxDeliveryCallback;
35pub use outbox_dispatcher::{
36    OutboxDispatcher, OutboxDispatcherConfig, OutboxRowDispatch, WorkerOutboxDispatch,
37};
38pub use outbox_reconciler::{OutboxReconciler, OutboxReconcilerConfig};
39pub use registry::{
40    ConnectedWorkerRegistry, WorkerDelivery, WorkerHandle, WorkerId, WorkerRegistration,
41};
aion_server/worker/mod.rs

aion_server/worker/
mod.rs
