oppgave 0.1.0

A simple Redis-based task queue
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

# oppgave - A simple Redis-based task queue

[![Build Status](https://travis-ci.org/badboy/oppgave.svg?branch=master)](https://travis-ci.org/badboy/oppgave)
[![crates.io](http://meritbadge.herokuapp.com/oppgave)](https://crates.io/crates/oppgave)

## [Documentation][]

[Documentation is available online][documentation]

[documentation]: http://badboy.github.io/oppgave

## Installation

Add it to your dependencies in `Cargo.toml`

```toml
[dependencies]
oppgave = "0.1.0"
```

## Example: Producer

```rust
#[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

```rust
#[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);
}
```

## License

MIT. See [LICENSE](LICENSE).