broker

Documentation

Index

• func BuryJobFunc(ctx context.Context) (func(), bool)
• func CancelFunc(ctx context.Context) (context.CancelFunc, bool)
• func JobID(ctx context.Context) (uint64, bool)
• func New(addr string, queue string) (furrow.Broker, error)

Functions

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