aion-worker 0.8.0

Rust remote-worker SDK for executing Aion activities over the gRPC worker protocol.
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

//! Worker activity dispatch runtime support.

/// Typed activity dispatch and payload conversion helpers.
pub mod dispatch;
/// Liminal worker transport (LSUB-1): receive pushed dispatches, execute, reply.
#[cfg(feature = "liminal-transport")]
pub mod liminal;
/// Candidate-cycling redial driver for liminal worker reconnect-to-survivor
/// (G-1, #112): the transport-free cursor + backoff + loop the liminal worker
/// uses to migrate from a dead owner to a survivor's listener.
#[cfg(feature = "liminal-transport")]
pub mod liminal_redial;
/// Reconnect-to-survivor serve entry point: wires the real liminal worker connect
/// + serve into the redial driver (G-1, #112).
#[cfg(feature = "liminal-transport")]
pub mod liminal_serve;
/// Activity polling loop and shutdown primitives.
pub mod loop_;
/// Dispatch-outcome reporting and runtime-channel draining.
pub(crate) mod report;

pub use dispatch::{TypedActivityDispatcher, decode_payload, encode_payload};
#[cfg(feature = "liminal-transport")]
pub use liminal::{DispatchRequest, DispatchResponse, LiminalActivityWorker};
#[cfg(feature = "liminal-transport")]
pub use liminal_serve::serve_with_redial;
pub use loop_::{
    ActivityDispatcher, DispatchOutcome, NoShutdown, ServeEnd, SessionHealth, serve_activity_tasks,
    serve_activity_tasks_until,
};