Struct disque::JobQueryBuilder

pub struct JobQueryBuilder<'a> { /* private fields */ }

Helper to get a list of jobs

Examples

let disque = Disque::open("redis://127.0.0.1:7711/").unwrap();
let jobs = JobQueryBuilder::new().queue(b"my queue").state("queued")
    .iter_ids(&disque).unwrap().collect::<Vec<_>>();
assert!(jobs.len() >= 0);

Implementations

impl<'a> JobQueryBuilder<'a>

pub fn new() -> JobQueryBuilder<'a>

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

Block and return all the elements in a busy loop.

pub fn queue(&mut self, queue: &'a [u8]) -> &mut Self

Only get jobs in the specified queue.

pub fn state(&mut self, state: &'a str) -> &mut Self

Only return jobs in specified states. Can be called multiple times to get jobs in any of those states.

pub fn iter_ids<'b>( &'b self, disque: &'b Disque ) -> RedisResult<Iter<'_, String>>

Gets a job ids iterator.

pub fn iter_all<'b>( &'b self, disque: &'b Disque ) -> RedisResult<Iter<'_, HashMap<String, Value>>>

Gets a job information iterator.