pqueue

pqueue is a simple persistent directory-backed FIFO queue.

It provides the typical queue interface Enqueue and Dequeue and may store any byte slice or string. Entries are stored as files in the backing directory and are fully managed by Queue.

Usage

Fetch the library:

go get -u heckel.io/pqueue

Then import it like this:

import "heckel.io/pqueue"

The package is imported under the pqueue namespace.

Example

import "heckel.io/pqueue"

q, _ := pqueue.New("/tmp/myqueue")
q.EnqueueString("some entry")
first, _ := q.DequeueString() // some entry

q2, _ := pqueue.New("/tmp/myqueue") // queue persists
second, _ := q2.DequeueString() // another entry

Contributing

I welcome any and all contributions. Just create a PR or an issue.

License

Made with ❤️ by Philipp C. Heckel, distributed under the Apache License 2.0.