rque

Simple queue built with RethinkDB.

View the docs.

Installation

$ go get github.com/frozzare/go-rque

Example

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": "Fredrik",
    "data": {}
}

License

MIT © Fredrik Forsmo