Crate oppgave

oppgave - A simple Redis-based task queue

Example: Producer

#[derive(RustcDecodable, RustcEncodable)]
struct Job { id: u64 }

let client = redis::Client::open("redis://127.0.0.1/").unwrap();
let con = client.get_connection().unwrap();
let producer = Queue::new("default".into(), con);

producer.push(Job{ id: 42 });

Example: Worker

#[derive(RustcDecodable, RustcEncodable)]
struct Job { id: u64 }

let client = redis::Client::open("redis://127.0.0.1/").unwrap();
let con = client.get_connection().unwrap();
let worker = Queue::new("default".into(), con);

while let Some(task) = worker.next() {
    println!("Working with Job {}", job.id);
}

Structs

Queue

A Queue allows to push new tasks or wait for them

TaskGuard

A wrapper of the fetched task

Traits

TaskDecodable

Task objects that can be reconstructed from the JSON stored in Redis

TaskEncodable

Task objects that can be encoded to JSON to be stored in Redis