Skip to main content

Module worker

Module worker 

Source
Expand description

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::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_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). Asking the workers holding a run’s activities to stop (#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_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.