Struct disque::QueueQueryBuilder
source · pub struct QueueQueryBuilder { /* private fields */ }
Expand description
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§
source§impl QueueQueryBuilder
impl QueueQueryBuilder
sourcepub fn new() -> QueueQueryBuilder
pub fn new() -> QueueQueryBuilder
Creates a new builder.
sourcepub fn count(&mut self, count: u64) -> &mut Self
pub fn count(&mut self, count: u64) -> &mut Self
A hint about how much work to do per iteration.
sourcepub fn busyloop(&mut self, busyloop: bool) -> &mut Self
pub fn busyloop(&mut self, busyloop: bool) -> &mut Self
If true, blocks and returns all the queues in a busy loop.
sourcepub fn minlen(&mut self, minlen: u64) -> &mut Self
pub fn minlen(&mut self, minlen: u64) -> &mut Self
Only return queues with at least minlen
jobs.
sourcepub fn maxlen(&mut self, maxlen: u64) -> &mut Self
pub fn maxlen(&mut self, maxlen: u64) -> &mut Self
Only return queues with at most maxlen
jobs.
sourcepub fn importrate(&mut self, importrate: u64) -> &mut Self
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
.