Struct disqrust::EventLoop [] [src]

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

Workers manager.


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

Adds a queue to process its jobs.

Removes a queue from job processing.

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

Number of jobs produced by the current server.

Identifier of the current server.

Connects to the server doing most jobs.

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

Runs until times jobs are received.

Runs times jobs and changes server every cycle.

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