aion-server 0.21.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

//! Event subscription streaming surfaces.

/// WS3 cluster topology/ownership subscription serving.
pub mod cluster_stream;
/// Namespace-aware event gating at the broadcast/encode seam.
pub mod namespace_filter;
/// Replay/live splice for per-workflow subscription resumption.
pub mod resume;
/// Server-side workflow-type/status selector filtering.
pub mod selector;
/// WebSocket frame encoding and subscription forwarding helpers.
pub mod socket;
/// Event subscription request mapping and store subscription helpers.
pub mod subscribe;
/// NOI-5b agent-observability transcript subscription serving.
pub mod transcript_stream;

pub use cluster_stream::serve_cluster_socket;
pub use namespace_filter::{GateVerdict, NamespaceEventGate};
pub use resume::RESUME_CURSOR_AHEAD_OF_HISTORY;
pub use selector::SubscriptionSelector;
pub use socket::{
    EncodedEventStream, EncodedFrame, SEQUENCE_CONTIGUITY_VIOLATION, forward_subscription,
    handle_subscription_socket,
};
pub use subscribe::{
    EventSubscription, MappedSubscription, map_subscription_request, subscribe_events,
};
pub(crate) use transcript_stream::gate_transcript_workflow;
pub use transcript_stream::serve_transcript_socket;