drain_worker

Function drain_worker 

Source
pub async fn drain_worker(broker_url: &str, worker_id: &str) -> Result<()>
Expand description

Drain worker (stop accepting new tasks)