Beanstalkg is a go implementation of Beanstalkd a fast, general-purpose work queue. Idea is to support the same set of features and protocol with the addition of high availability and failover built in. You can read the plan.md if interested in contributing.
Right now it supports all the basic commands to run producers and workers. i.e "use", "put", "watch", "ignore", "reserve", "delete", "release", "bury", "reserve-with-timeout".
I wish to complete rest of the commands soon but any help is always appreciated.
Beanstalkg is currently only released as a docker image for users. Latest release is v0.0.3. Assuming you already have a working docker engine installation, you can start a Beanstalkg instance with following steps,
docker run -p 11300:11300 beanstalkg/beanstalkg:v0.0.3. This will start the beanstalkg server in the foreground. The server starts listening on port 11300.
// Produce jobs: c, err := beanstalk.Dial("tcp", "127.0.0.1:11300") id, err := c.Put(byte("hello"), 1, 0, 120*time.Second) // Consume jobs: c, err := beanstalk.Dial("tcp", "127.0.0.1:11300") id, body, err := c.Reserve(5 * time.Second)
Some introductory slides can be found here
Please install golang then with
GOPATH set correctly run,
go get github.com/Beanstalkg/beanstalkg
$GOAPTH/binto the $PATH and run
beanstalkg is licensed under the MIT License. See LICENSE for the full license text.