Skip to content
Branch: master
Find file Copy path
Find file Copy path
Fetching contributors…
Cannot retrieve contributors at this time
42 lines (32 sloc) 1.19 KB
Cmdstalk is a unix-process-based [beanstalkd][beanstalkd] queue broker.
Written in [Go][golang], cmdstalk uses the [kr/beanstalk][beanstalk]
library to interact with the [beanstalkd][beanstalkd] queue daemon.
Each job is passed as stdin to a new instance of the configured worker
command. On `exit(0)` the job is deleted. On `exit(1)` (or any non-zero
status) the job is released with an exponential-backoff delay (releases^4),
up to 10 times.
If the worker has not finished by the time the job TTR is reached, the
worker is killed (SIGTERM, SIGKILL) and the job is allowed to time out.
When the job is subsequently reserved, the `timeouts: 1` will cause it to
be buried.
In this way, job workers can be arbitrary commands, and queue semantics are
reduced down to basic unix concepts of exit status and signals.
package main
import (
func main() {
opts := cli.MustParseFlags()
bd := broker.NewBrokerDispatcher(opts.Address, opts.Cmd, opts.PerTube)
if opts.All {
} else {
// TODO: wire up to SIGTERM handler etc.
exitChan := make(chan bool)
You can’t perform that action at this time.