Struct QueueQueryBuilder 

pub struct QueueQueryBuilder { /* private fields */ }

Helper to get a list of queues

Examples

let disque = Disque::open("redis://127.0.0.1:7711/").unwrap();
let queues = QueueQueryBuilder::new().busyloop(true).minlen(50)
    .iter(&disque).unwrap().collect::<Vec<_>>();
assert!(queues.len() >= 0);

Implementations

impl QueueQueryBuilder

pub fn new() -> QueueQueryBuilder

Creates a new builder.

pub fn count(&mut self, count: u64) -> &mut Self

A hint about how much work to do per iteration.

pub fn busyloop(&mut self, busyloop: bool) -> &mut Self

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

pub fn minlen(&mut self, minlen: u64) -> &mut Self

Only return queues with at least minlen jobs.

pub fn maxlen(&mut self, maxlen: u64) -> &mut Self

Only return queues with at most maxlen jobs.

pub fn importrate(&mut self, importrate: u64) -> &mut Self

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

pub fn iter<'a>(&'a self, disque: &'a Disque) -> RedisResult<Iter<'_, Vec<u8>>>

Gets the queue iterator.