Skip to content
This repository has been archived by the owner. It is now read-only.
Go client for beanstalkd
Branch: master
Clone or download
Pull request Compare This branch is 1 commit ahead, 5 commits behind beanstalkd:master.
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
License add license Apr 11, 2012
Readme.md
common_test.go
conn.go return correct error types in all cases Jan 14, 2013
conn_test.go
doc.go
err.go return correct error types in all cases Jan 14, 2013
example_test.go
name.go
parse.go return correct error types in all cases Jan 14, 2013
parse_test.go
time.go init Apr 11, 2012
time_test.go init Apr 11, 2012
tube.go
tube_test.go gofmt Apr 11, 2012
tubeset.go
tubeset_test.go return correct error types in all cases Jan 14, 2013

Readme.md

Beanstalk

Go client for beanstalkd.

New home

This package has a new home at https://github.com/beanstalkd/beanstalk.

The code is still available here to use, for any clients that depend on this import path, but there is no development on this repo. Maintenance and development now happen in the beanstalkd organization.

Please use github.com/beanstalkd/beanstalk in new code.

Install

$ go get github.com/kr/beanstalk

Use

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)
You can’t perform that action at this time.