Struct EventLoop

pub struct EventLoop<H: Handler + Clone + 'static> { /* private fields */ }

Workers manager.

Implementations

impl<H: Handler + Clone + 'static> EventLoop<H>

pub fn new(disque: Disque, numworkers: usize, handler: H) -> Self

pub fn watch_queue(&mut self, queue_name: Vec<u8>)

Adds a queue to process its jobs.

pub fn unwatch_queue(&mut self, queue_name: &Vec<u8>)

Removes a queue from job processing.

pub fn choose_favorite_node(&self) -> (Vec<u8>, usize)

Connects to the server that is issuing most of the jobs.

pub fn jobcount_current_node(&self) -> usize

Number of jobs produced by the current server.

pub fn current_node_id(&self) -> String

Identifier of the current server.

pub fn do_cycle(&mut self)

Connects to the server doing most jobs.

pub fn run(&mut self, cycle: usize)

Runs for ever. Every cycle jobs reevaluates which server to use.

pub fn run_times(&mut self, times: usize)

Runs until times jobs are received.

pub fn run_times_cycle(&mut self, times: usize, cycle: usize)

Runs times jobs and changes server every cycle.

pub fn stop(self)

Sends a kill signal to all workers and waits for them to finish their current job.