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 declared_body::DeclaredBodies;

pub use declared_body::DeclaredBodyLookup;

pub use declared_body::DeclaredBodySource;

pub use declared_body::DeclaredCommandDispatcher;

pub use declared_body::EngineDeclaredBodies;

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 envelope::CompletionFences;

pub use envelope::CompletionToken;

pub use envelope::idempotency_key;

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_liveness::LivenessPing;

pub use liminal_liveness::LivenessPong;

pub use liminal_liveness::LivenessProbe;

pub use liminal_liveness::LivenessTarget;

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

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_redrive::RedriveRefused;

pub use outbox_redrive::list_dead_letters;

pub use outbox_redrive::redrive_dead_lettered_row;

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 queue_service::ActivityReachability;

pub use queue_service::DeliveryRefusal;

pub use queue_service::EngineQueueDeclarations;

pub use queue_service::ExpiredClock;

pub use queue_service::OpenActivity;

pub use queue_service::PoolCensus;

pub use queue_service::QueueDeclaration;

pub use queue_service::QueueDeclarationSource;

pub use queue_service::QueueDeclarations;

pub use queue_service::QueueServiceConfig;

pub use queue_service::QueueServiceOverride;

pub use queue_service::QueueServicePolicy;

pub use queue_service::QueueServiceReason;

pub use queue_service::QueueServiceState;

pub use queue_service::ServiceAddress;

pub use queue_service::UnavailableSummary;

pub use queue_service::UnservedDispatch;

pub use queue_service::UnservedKey;

pub use queue_service::UnservedQueue;

pub use queue_service::WorkerUnavailable;

pub use queue_service::open_activities_in_active_segment;

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;

pub use transport_loss::TRANSPORT_EXHAUSTED_REASON_PREFIX;

pub use transport_loss::TRANSPORT_LOSS_BUDGET_WINDOWS;

pub use transport_loss::TransportLossLedger;

pub use transport_loss::TransportLossVerdict;

pub use transport_loss::WORKER_LOST_REASON_PREFIX;

pub use transport_loss::is_transport_domain_reason;

pub use transport_loss::worker_lost_detail;

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.

contracts

Worker contract admission shared by every registration transport. Shared worker registration admission against durable package contracts.

declared_body

Server-side execution of declared action bodies (no worker required). Server-side execution of declared action bodies.

dispatch

Activity completion handling and dispatch abstractions. Push dispatch for remote activity workers and result handoff to the engine contract.

envelope

Task-envelope generation, idempotency keys, and completion fencing. Activity task-envelope generation and completion fencing.

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_liveness

Server half of the liminal connection dead-man switch: the liveness ping/pong wire pair and the probe that keeps a healthy idle connection’s lease alive while making a dead one loud on both sides. Server half of the liminal connection dead-man switch: the liveness probe.

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_redrive

Operator-driven redrive of dead-lettered outbox rows, gated on workflow liveness and on whether the dead letter’s failure was already judged. Operator-driven redrive of dead-lettered 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).

queue_service

Unserved-queue honesty at the bridge seam (R1): the four-way taxonomy, service policies, the two service clocks, and the queryable queue state. Module declarations.

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.

transport_loss

Transport-domain classification and re-dispatch budget for activities whose worker died before reporting a result. Transport-domain failure classification for activities whose worker died.