Struct Dispatcher 

pub struct Dispatcher { /* private fields */ }

Central task dispatcher. Manages worker connections and routes tasks.

Implementations

impl Dispatcher

pub fn builder() -> DispatcherBuilder

pub async fn start(&self) -> Result<(), DispatchError>

pub async fn stop(&self)

Gracefully stops the dispatcher. Cancels background tasks and shuts down transport.

pub async fn dispatch( &self, task: Task, ) -> Result<DispatchResult, DispatchError>

pub fn pool_stats(&self) -> PoolStats

pub fn workers(&self) -> Vec<WorkerInfo>

List all connected workers with their full info.

pub fn drain_worker(&self, worker_id: &str) -> Result<(), PoolError>

Set a worker’s status to Draining. No new tasks will be routed to it, but existing in-flight tasks will finish normally.

pub fn remove_worker(&self, worker_id: &str) -> Result<(), PoolError>

Force-remove a worker from the pool and fail all pending tasks assigned to it.

pub async fn dispatch_to( &self, worker_id: &str, task: Task, ) -> Result<DispatchResult, DispatchError>

Dispatch a task to a specific worker by ID, bypassing least-loaded selection.

pub async fn dispatch_with_tag( &self, tag: &str, task: Task, ) -> Result<DispatchResult, DispatchError>

Dispatch a task to a worker that has a matching tag. Routes to the least-loaded worker among those with the specified tag.