Module protocol 

Worker-session protocol abstractions and task types. Worker protocol session declarations and public protocol types.

Re-exports

pub use heartbeat::ActivityExecutionKey;

pub use heartbeat::HeartbeatBookkeeper;

pub use heartbeat::send_heartbeat;

pub use reconnect::PendingActivityReport;

pub use reconnect::ReconnectBackoff;

pub use reconnect::UnackedResultTracker;

pub use reconnect::connect_registered_grpc_session;

pub use reconnect::re_report_unacked;

pub use reconnect::reconnect_with_backoff;

pub use reconnect::reconnect_with_sleep;

pub use reconnect::register_connected_session;

pub use session::GrpcWorkerSession;

pub use session::RegisteredSessionInfo;

pub use session::WorkerSession;

pub use session::WorkerSessionEvent;

pub use session::WorkerTaskStream;

pub use session::validate_activity_handlers;

pub use task::ActivityTask;

Modules

heartbeat

Heartbeat bookkeeper and sender helpers. heartbeat frame send + heartbeat-timeout bookkeeping

reconnect

Reconnect loop helpers for worker sessions. Backoff reconnect, re-register, and re-report un-acked results.

session

Worker session trait and gRPC session implementation. WorkerSession trait and gRPC-backed implementation.

task

Activity task payloads delivered to workers. ActivityTask decode and TaskResult/TaskFailure encode.