Module worker 

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

Re-exports

pub use activity_cancel::CancelDelivery;

pub use activity_cancel::CancelRequest;

pub use activity_cancel::InFlightCancellation;

pub use activity_cancel::cancel_in_flight_activities;

pub use admission_audit::AdmissionAudit;

pub use attempt_progress::AttemptProgress;

pub use attempt_progress::attempt_progress;

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

pub use declared_body::EngineDeclaredBodies;

pub use declared_body_ambiguity::DeclaringVersion;

pub use declared_body_ambiguity::ambiguous_body_refusal;

pub use declared_body_cancel::DeclaredAttemptRegistration;

pub use declared_body_cancel::DeclaredCommandAttempts;

pub use declared_body_selection::select_declared_body;

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 grpc_liveness::GrpcLivenessTarget;

pub use grpc_liveness::GrpcLivenessWaiters;

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 supervisor::ManagedExecutable;

pub use supervisor::ManagedWorkerExit;

pub use supervisor::ManagedWorkerReport;

pub use supervisor::ManagedWorkerState;

pub use supervisor::ManagedWorkerStatus;

pub use supervisor::SpawnedBinary;

pub use supervisor::SupervisionError;

pub use supervisor::SupervisionPolicy;

pub use supervisor::WorkerSupervisor;

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;

pub use workspace_root::ExpandedCommand;

pub use workspace_root::WorkspaceRoot;

pub use workspace_root::WorkspaceRootError;

Modules

activity_cancel

Asking the workers holding a cancelled run’s activities to stop (#233). Stopping a run’s in-flight activities, wherever they are executing (#233).

admission_audit

Whether a contract refusal is new information, and therefore worth saying. Whether a contract refusal is NEW INFORMATION, and therefore worth saying.

attempt_progress

Reading one attempt’s volatile worker progress note, with typed absence. Reading the volatile worker progress note of one attempt — honestly.

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.

declared_body_ambiguity

The refusal, and the followable remedy, for retained versions that declare different bodies for one action. The refusal an operator reads when retained package versions disagree about an action’s declared body — and the remedy it names.

declared_body_cancel

Stopping the declared bodies this server is executing: the registry that makes a running server-executed attempt visible, and the signal that reaches its process group. Stopping the declared bodies THIS server is executing.

declared_body_selection

Which retained version’s body a declared-command dispatch runs — the dispatching run’s own, not the queue’s. Which retained version’s body a declared-command dispatch runs.

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.

grpc_liveness

gRPC half of the worker dead-man switch (#197): the transport liveness ping pushed down a worker’s task stream, and the registry its answers correlate through. gRPC half of the worker dead-man switch: the transport liveness ping and the correlation registry its answers land in (#197).

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).

liveness

The transport-neutral vocabulary the dead-man switch’s transport halves share: why a ping failed, and which wire carried it. The transport-neutral vocabulary of the worker dead-man switch.

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.

supervisor

Managed-worker supervision (W-1..W-4): desired state in, contained OS processes out, with a status surface that is a join of the two. Module declarations.

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.

workspace_root

Server-side {workspace_root} expansion for declared action bodies (#139). {workspace_root} expansion — for declared action bodies, and for the path-valued settings of a worker document’s harness section.

Constants

WORKSPACE_ROOT_PLACEHOLDER

The literal placeholder a declared command carries where the server’s workspace root belongs.