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