Module worker 

Remote-worker registry, heartbeat, and dispatch support. Module declarations.

Re-exports

pub use bridge::OutboxDeliveryCallback;

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 outbox_delivery::ServerOutboxDeliveryCallback;

pub use outbox_dispatcher::OutboxDispatcher;

pub use outbox_dispatcher::OutboxDispatcherConfig;

pub use outbox_dispatcher::OutboxRowDispatch;

pub use outbox_dispatcher::WorkerOutboxDispatch;

pub use outbox_reconciler::OutboxReconciler;

pub use outbox_reconciler::OutboxReconcilerConfig;

pub use registry::ConnectedWorkerRegistry;

pub use registry::WorkerDelivery;

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.

outbox_delivery

Server-side outbox completion delivery into live workflows. Server-side outbox completion delivery callback.

outbox_dispatcher

Non-replayed durable-outbox fan-out dispatcher (dormant unless commissioned). Non-replayed background dispatcher for the durable fan-out outbox.

outbox_reconciler

Live stale-claim outbox reconciler (dormant unless commissioned). Live reconciliation for stranded claimed outbox rows.

registry

Connected-worker registry and handles. Connected-worker registry keyed by worker-pool address and activity type.