Skip to main content

Module worker

Module worker 

Source
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_activity calls 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.