Module worker 

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

Re-exports

pub use backpressure::Backpressure;

pub use backpressure::OwnedShardFraction;

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::HeartbeatSweeper;

pub use heartbeat::HeartbeatTracker;

pub use heartbeat::HeartbeatUpdate;

pub use heartbeat::InFlightActivity;

pub use heartbeat::LostWorkerReport;

pub use heartbeat::TaskLiveness;

pub use heartbeat::sweep_interval;

pub use intervention::AttemptKey;

pub use intervention::AttemptOwnerIndex;

pub use intervention::InterventionRouter;

pub use intervention::InterventionTransport;

pub use liminal_transport::DispatchRequest;

pub use liminal_transport::DispatchResponse;

pub use liminal_transport::InterventionReply;

pub use liminal_transport::InterventionRequest;

pub use liminal_transport::LiminalCompletionSource;

pub use liminal_transport::LiminalConnectionNotifier;

pub use liminal_transport::LiminalInterventionTransport;

pub use liminal_transport::LiminalWorkerDelivery;

pub use liminal_transport::RegistryLiminalDispatch;

pub use liminal_transport::channel_for_row;

pub use liminal_transport::dispatch_channel_name;

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 outbox_settle::settle_terminal_outbox_rows;

pub use placement_cache::PlacementCache;

pub use placement_cache::WorkerSelection;

pub use placement_cache::preferred_node_order;

pub use placement_cache::worker_selection_for;

pub use quota_broadcast::QuotaBroadcaster;

pub use quota_cache::QuotaCache;

pub use registry::ConnectedWorkerRegistry;

pub use registry::WorkerDelivery;

pub use registry::WorkerHandle;

pub use registry::WorkerId;

pub use registry::WorkerRegistration;

Modules

backpressure

Per-tenant keyed backpressure at the outbox claim (Control-Plane Phase 2, P2-Q2). Per-tenant keyed backpressure at the outbox claim (Control-Plane Phase 2, P2-Q2).

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.

intervention

Server-side mid-run intervention routing (NOI-6): capability gate + attempt owner resolution + push to the owning worker over a pluggable transport. Server-side mid-run intervention routing (NOI-6).

liminal_transport

Cross-node outbox dispatch over the liminal bus (#13-0 spike, feature-gated). Cross-node outbox dispatch over the liminal bus (LSUB push transport).

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.

outbox_settle

Terminal-workflow outbox settlement sweep for boot and shard adoption (#253). Terminal-workflow outbox settlement sweep (#253).

placement_cache

Short-TTL per-namespace placement cache for the dispatcher (Control-Plane Phase 2, P2-P3). Short-TTL in-process cache of per-namespace placement directives, read by the non-replayed outbox dispatcher (Control-Plane Phase 2, P2-P3).

quota_broadcast

Throttled per-namespace quota-state broadcaster for the ops-console live badge (Control-Plane Phase 2, P2-Q3). Throttled per-namespace quota-state broadcaster for the ops console live badge (Control-Plane Phase 2, P2-Q3).

quota_cache

Short-TTL per-namespace concurrency-quota cache for the dispatcher’s keyed backpressure (Control-Plane Phase 2, P2-Q2). Short-TTL in-process cache of per-namespace concurrency quotas, read by the non-replayed outbox dispatcher’s keyed backpressure (Control-Plane Phase 2, P2-Q2).

registry

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