A small reliable queue on top of Redis. Allows to push tasks and fetch them again. Can handle whatever task object you hand it, as long as it can be encoded and decoded to and from JSON.
oppgave
is Norwegian for task.
So oppgave
is a oppgave kø, a task queue.
Sadly, characters like ø
don't play to well with stable Rust. Non-ASCII identifiers are feature-gated.
It would be possible with nightly and the non_ascii_idents
feature to use oppgave-kø
, but crates.io doesn't accept crates with non-ascii characters in the name. :(
Documentation is available online.
Add it to your dependencies in Cargo.toml
[dependencies]
oppgave = "0.1.0"
See examples/worker.rs
for a working example.
Run it with cargo run --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 producer = Queue::new("default".into(), con);
producer.push(Job{ id: 42 });
See examples/worker.rs
for a working example.
Run it with cargo run --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);
}
MIT. See LICENSE.