fn watch_queue(&mut self, queue_name: Vec<u8>)
Adds a queue to process its jobs.
fn unwatch_queue(&mut self, queue_name: &Vec<u8>)
Removes a queue from job processing.
Connects to the server that is issuing most of the jobs.
fn jobcount_current_node(&self) -> usize
Number of jobs produced by the current server.
fn current_node_id(&self) -> String
Identifier of the current server.
fn do_cycle(&mut self)
Connects to the server doing most jobs.
Runs for ever. Every
cycle jobs reevaluates which server to use.
times jobs are received.
fn run_times_cycle(&mut self, times: usize, cycle: usize)
times jobs and changes server every
Sends a kill signal to all workers and waits for them to finish their current job.