Go Beanstalkd client library.
go get github.com/iwanbk/gobeanstalk
import (
"github.com/iwanbk/gobeanstalk"
"log"
"time"
)
func main() {
conn, err := gobeanstalk.Dial("localhost:11300")
if err != nil {
log.Fatal(err)
}
id, err := conn.Put([]byte("hello"), 0, 10*time.Second, 30*time.Second)
if err != nil {
log.Fatal(err)
}
log.Printf("Job id %d inserted\n", id)
}
import (
"github.com/iwanbk/gobeanstalk"
"log"
)
func main() {
conn, err := gobeanstalk.Dial("localhost:11300")
if err != nil {
log.Fatal(err)
}
for {
j, err := conn.Reserve()
if err != nil {
log.Fatal(err)
}
log.Printf("id:%d, body:%s\n", j.ID, string(j.Body))
err = conn.Delete(j.ID)
if err != nil {
log.Fatal(err)
}
}
}
- use
- put
- watch
- ignore
- reserve
- delete
- touch
- release
- bury
- kick
- kick-job
- list-tubes
- stats
- stats-tube
- stats-job
- quit
Latest release is v0.3 that contains API changes, see release notes here