Expand description
Remote-worker registry, heartbeat, and dispatch support. Module declarations.
Re-exports§
pub use bridge::PendingActivities;pub use bridge::WorkerActivityDispatcher;pub use dispatch::ActivityCompletion;pub use dispatch::ActivityCompletionOutcome;pub use dispatch::ActivityCompletionSink;pub use dispatch::ActivityDispatcher;pub use dispatch::ScheduledActivity;pub use dispatch::handle_activity_result;pub use heartbeat::HeartbeatTracker;pub use heartbeat::HeartbeatUpdate;pub use heartbeat::InFlightActivity;pub use heartbeat::LostWorkerReport;pub use heartbeat::TaskLiveness;pub use registry::ConnectedWorkerRegistry;pub use registry::WorkerHandle;pub use registry::WorkerId;pub use registry::WorkerRegistration;
Modules§
- bridge
- Bridge from engine activity dispatch to connected workers.
NIF bridge dispatcher that routes
run_activitycalls to connected workers. - dispatch
- Activity completion handling and dispatch abstractions. Push dispatch for remote activity workers and result handoff to the engine contract.
- heartbeat
- Worker heartbeat and liveness tracking. Heartbeat window tracking and lost-worker failure surfacing.
- registry
- Connected-worker registry and handles. Connected-worker registry keyed by namespace and activity type.