Struct disque::QueueQueryBuilder [] [src]

pub struct QueueQueryBuilder { /* fields omitted */ }

Helper to get a list of queues


let disque = Disque::open("redis://").unwrap();
let queues = QueueQueryBuilder::new().busyloop(true).minlen(50)
assert!(queues.len() >= 0);


impl QueueQueryBuilder

Creates a new builder.

A hint about how much work to do per iteration.

If true, blocks and returns all the queues in a busy loop.

Only return queues with at least minlen jobs.

Only return queues with at most maxlen jobs.

Only return queues with a job import rate (from other nodes) greater than or equal to importrate.

Gets the queue iterator.