Skip to main content

aion_server/worker/queue_service/
mod.rs

1//! Module declarations.
2
3/// Live poller census for a pool address and the taxonomy classification it feeds.
4pub mod census;
5/// Whether a task queue is declared by any deployed `.v4` contract.
6pub mod declarations;
7/// Schedule-to-start hand-off to a live worker (where `SATURATED` is emitted).
8pub mod delivery;
9/// Service policies (`strict` / `durable_pending`) and the two service clocks.
10pub mod policy;
11/// Whether an in-flight activity can still reach a worker.
12pub mod reachability;
13/// The live, queryable unserved-queue state.
14pub mod state;
15/// The reason taxonomy and the typed `WorkerUnavailable` dispatch failure.
16pub mod taxonomy;
17/// The classification-driven selection wait.
18pub mod wait;
19
20pub use census::{PoolCensus, classify};
21pub use declarations::{
22    EngineQueueDeclarations, QueueDeclaration, QueueDeclarationSource, QueueDeclarations,
23};
24pub use delivery::{DeliveryRefusal, PARK_POLL_INTERVAL, deliver_within_schedule_to_start};
25pub use policy::{QueueServiceConfig, QueueServiceOverride, QueueServicePolicy};
26pub use reachability::{ActivityReachability, OpenActivity, open_activities_in_active_segment};
27pub use state::{Parked, QueueServiceState, UnservedDispatch, UnservedKey, UnservedQueue};
28pub use taxonomy::{
29    ExpiredClock, QueueServiceReason, ServiceAddress, UnavailableSummary, WorkerUnavailable,
30};
31pub use wait::{SelectionRefusal, ServiceWait, select_worker_or_refuse};