Simple queue built with RethinkDB.
View the docs.
$ go get github.com/frozzare/go-rque
que, err := rque.New(rque.Config{
Address: "localhost:28015",
Database: "test",
Table: "queue",
})
if err != nil {
log.Fatalf("Failed to create que: %s", err)
}
for job := range que.Jobs() {
fmt.Printf("Hello %s\n", job.Name)
}
JSON row in the database:
{
"name": "hello",
"data": {}
}
MIT © Fredrik Forsmo