aion-server 0.20.0

Aion workflow server library: HTTP, gRPC, WebSocket, and worker endpoints. Run it with the `aion` binary from the aion-cli crate.
Documentation 
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
30
31

//! Module declarations.

/// Live poller census for a pool address and the taxonomy classification it feeds.
pub mod census;
/// Whether a task queue is declared by any deployed `.v4` contract.
pub mod declarations;
/// Schedule-to-start hand-off to a live worker (where `SATURATED` is emitted).
pub mod delivery;
/// Service policies (`strict` / `durable_pending`) and the two service clocks.
pub mod policy;
/// Whether an in-flight activity can still reach a worker.
pub mod reachability;
/// The live, queryable unserved-queue state.
pub mod state;
/// The four-way taxonomy and the typed `WorkerUnavailable` dispatch failure.
pub mod taxonomy;
/// The classification-driven selection wait.
pub mod wait;

pub use census::{PoolCensus, classify};
pub use declarations::{
    EngineQueueDeclarations, QueueDeclaration, QueueDeclarationSource, QueueDeclarations,
};
pub use delivery::{DeliveryRefusal, PARK_POLL_INTERVAL, deliver_within_schedule_to_start};
pub use policy::{QueueServiceConfig, QueueServiceOverride, QueueServicePolicy};
pub use reachability::{ActivityReachability, OpenActivity, open_activities_in_active_segment};
pub use state::{Parked, QueueServiceState, UnservedDispatch, UnservedKey, UnservedQueue};
pub use taxonomy::{
    ExpiredClock, QueueServiceReason, ServiceAddress, UnavailableSummary, WorkerUnavailable,
};
pub use wait::{SelectionRefusal, ServiceWait, select_worker_or_refuse};