aion-worker 0.4.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

//! Worker protocol session declarations and public protocol types.

/// Heartbeat bookkeeper and sender helpers.
pub mod heartbeat;
/// Reconnect loop helpers for worker sessions.
pub mod reconnect;
/// Worker session trait and gRPC session implementation.
pub mod session;
/// Activity task payloads delivered to workers.
pub mod task;

pub use heartbeat::{ActivityExecutionKey, HeartbeatBookkeeper, send_heartbeat};
pub use reconnect::{
    PendingActivityReport, ReconnectBackoff, UnackedResultTracker, connect_registered_grpc_session,
    re_report_unacked, reconnect_with_backoff, reconnect_with_sleep, register_connected_session,
};
pub use session::{
    GrpcWorkerSession, RegisteredSessionInfo, WorkerSession, WorkerSessionEvent, WorkerTaskStream,
    validate_activity_handlers,
};
pub use task::ActivityTask;