Struct WorkerActivityDispatcher 

pub struct WorkerActivityDispatcher { /* private fields */ }

Dispatcher that routes run_activity NIF calls to connected workers.

Synchronous interface — uses try_send for the task channel and std::sync::mpsc::Receiver::recv for the response. Callers on a multi-thread tokio runtime are detected and moved into tokio::task::block_in_place so the blocking wait never starves the runtime tasks that flush the worker stream (see the module docs).

Implementations

impl WorkerActivityDispatcher

pub fn new( registry: ConnectedWorkerRegistry, namespace: impl Into<String>, heartbeat_tracker: HeartbeatTracker, ) -> Self

Build a dispatcher for the given namespace, worker registry, and liveness tracker.

The tracker must be the same instance the worker stream handler and shutdown coordinator share: the unbounded completion wait relies on stream teardown sweeping this tracker’s in-flight entries to fail dispatches whose worker was lost.

pub fn with_queue_service(self, queue_service: QueueServiceConfig) -> Self

Share the operator’s R1 queue-service settings: the default policy, the written per-queue durable_pending opt-ins, and the two clocks.

pub fn with_queue_declarations( self, queue_declarations: QueueDeclarationSource, ) -> Self

Share the queue-declaration source the boot path fills in once the engine exists (the handle is cloneable; installing on any clone is visible here).

pub fn with_queue_state(self, queue_state: QueueServiceState) -> Self

Share the queue-service state so the server can read which addresses are unserved and which runs are parked on them.

pub fn with_attempt_owners(self, attempt_owners: AttemptOwnerIndex) -> Self

Share the server’s NOI-6 attempt→owner back-index so liminal-delivered dispatches are visible (and targetable) to the intervention router for exactly as long as they are in flight. The production boot passes ServerState’s index — the SAME instance intervenable_attempts and intervene read — or the console’s live-attempts list stays empty for every bridge-dispatched agent step.

pub fn with_pending(self, pending: PendingActivities) -> Self

Share a caller-supplied pending-activities tracker.

pub fn with_drain_state(self, drain_state: DrainState) -> Self

Share the server drain gate.

pub fn with_tokio_handle(self, tokio_handle: Handle) -> Self

Share the server runtime handle for sync history writes from dirty NIF threads.

Trait Implementations

impl ActivityDispatcher for WorkerActivityDispatcher

fn dispatch(&self, request: ActivityDispatch) -> Result<String, String>

Dispatch the activity and block until completion.

fn dispatch_async( self: Arc<Self>, request: ActivityDispatch, ) -> Pin<Box<dyn Future<Output = Result<String, String>> + Send>>

Dispatch the activity from a Tokio task.

impl Debug for WorkerActivityDispatcher

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.