aion_server/worker/
mod.rs

1//! Module declarations.
2
3/// Per-tenant keyed backpressure at the outbox claim (Control-Plane Phase 2,
4/// P2-Q2).
5pub mod backpressure;
6/// Bridge from engine activity dispatch to connected workers.
7pub mod bridge;
8/// Activity completion handling and dispatch abstractions.
9pub mod dispatch;
10/// Worker heartbeat and liveness tracking.
11pub mod heartbeat;
12/// Server-side mid-run intervention routing (NOI-6): capability gate + attempt
13/// owner resolution + push to the owning worker over a pluggable transport.
14pub mod intervention;
15/// Cross-node outbox dispatch over the liminal bus (#13-0 spike, feature-gated).
16#[cfg(feature = "liminal-transport")]
17pub mod liminal_transport;
18/// Server-side outbox completion delivery into live workflows.
19pub mod outbox_delivery;
20/// Non-replayed durable-outbox fan-out dispatcher (dormant unless commissioned).
21pub mod outbox_dispatcher;
22/// Live stale-claim outbox reconciler (dormant unless commissioned).
23pub mod outbox_reconciler;
24/// Terminal-workflow outbox settlement sweep for boot and shard adoption (#253).
25pub mod outbox_settle;
26/// Short-TTL per-namespace placement cache for the dispatcher (Control-Plane
27/// Phase 2, P2-P3).
28pub mod placement_cache;
29/// Throttled per-namespace quota-state broadcaster for the ops-console live badge
30/// (Control-Plane Phase 2, P2-Q3).
31pub mod quota_broadcast;
32/// Short-TTL per-namespace concurrency-quota cache for the dispatcher's keyed
33/// backpressure (Control-Plane Phase 2, P2-Q2).
34pub mod quota_cache;
35/// Connected-worker registry and handles.
36pub mod registry;
37
38pub use backpressure::{Backpressure, OwnedShardFraction};
39pub use bridge::{OutboxDeliveryCallback, PendingActivities, WorkerActivityDispatcher};
40pub use dispatch::{
41    ActivityCompletion, ActivityCompletionOutcome, ActivityCompletionSink, ActivityDispatcher,
42    ScheduledActivity, handle_activity_result,
43};
44pub use heartbeat::{
45    HeartbeatSweeper, HeartbeatTracker, HeartbeatUpdate, InFlightActivity, LostWorkerReport,
46    TaskLiveness, sweep_interval,
47};
48pub use intervention::{AttemptKey, AttemptOwnerIndex, InterventionRouter, InterventionTransport};
49#[cfg(feature = "liminal-transport")]
50pub use liminal_transport::{
51    DispatchRequest, DispatchResponse, InterventionReply, InterventionRequest,
52    LiminalCompletionSource, LiminalConnectionNotifier, LiminalInterventionTransport,
53    LiminalWorkerDelivery, RegistryLiminalDispatch, channel_for_row, dispatch_channel_name,
54};
55pub use outbox_delivery::ServerOutboxDeliveryCallback;
56pub use outbox_dispatcher::{
57    OutboxDispatcher, OutboxDispatcherConfig, OutboxRowDispatch, WorkerOutboxDispatch,
58};
59pub use outbox_reconciler::{OutboxReconciler, OutboxReconcilerConfig};
60pub use outbox_settle::settle_terminal_outbox_rows;
61pub use placement_cache::{
62    PlacementCache, WorkerSelection, preferred_node_order, worker_selection_for,
63};
64pub use quota_broadcast::QuotaBroadcaster;
65pub use quota_cache::QuotaCache;
66pub use registry::{
67    ConnectedWorkerRegistry, WorkerDelivery, WorkerHandle, WorkerId, WorkerRegistration,
68};
aion_server/worker/mod.rs

aion_server/worker/
mod.rs
