aion_worker/protocol/
mod.rs

1//! Worker protocol session declarations and public protocol types.
2
3/// Heartbeat bookkeeper and sender helpers.
4pub mod heartbeat;
5/// Reconnect loop helpers for worker sessions.
6pub mod reconnect;
7/// Worker session trait and gRPC session implementation.
8pub mod session;
9/// Activity task payloads delivered to workers.
10pub mod task;
11
12pub use heartbeat::{ActivityExecutionKey, HeartbeatBookkeeper, send_heartbeat};
13pub use reconnect::{
14    PendingActivityReport, ReconnectBackoff, UnackedResultTracker, connect_registered_grpc_session,
15    re_report_unacked, reconnect_with_backoff, reconnect_with_sleep, register_connected_session,
16};
17pub use session::{
18    GrpcWorkerSession, WorkerSession, WorkerSessionEvent, WorkerTaskStream,
19    validate_activity_handlers,
20};
21pub use task::ActivityTask;
aion_worker/protocol/mod.rs

aion_worker/protocol/
mod.rs
