broker

func BuryJobFunc ¶

func BuryJobFunc(ctx context.Context) (func(), bool)

func CancelFunc ¶

func CancelFunc(ctx context.Context) (context.CancelFunc, bool)

func JobID ¶

func JobID(ctx context.Context) (uint64, bool)

func New ¶

func New(addr string, queue string) (furrow.Broker, error)

A seperate connection to Beanstalk is opened for each broker instance. This is due to how the beanstalk protocol works. A job must be deleted before a new command can be issued on the same connection. https://github.com/kr/beanstalk/issues/6