Struct disque::JobQueryBuilder [] [src]

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

Helper to get a list of jobs


let disque = Disque::open("redis://").unwrap();
let jobs = JobQueryBuilder::new().queue(b"my queue").state("queued")
assert!(jobs.len() >= 0);


impl<'a> JobQueryBuilder<'a>

A hint about how much work to do per iteration.

Block and return all the elements in a busy loop.

Only get jobs in the specified queue.

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

Gets a job ids iterator.

Gets a job information iterator.