beanstalk

Mar 23, 2020

Changes in this version

+ const WatchThrottleLimit

Mar 4, 2020

Changes in this version

+ type Broker struct

+ func (b *Broker) Consume(pipe *jobs.Pipeline, execPool chan jobs.Handler, errHandler jobs.ErrorHandler) error

+ func (b *Broker) Init(cfg *Config) (bool, error)

+ func (b *Broker) Listen(lsn func(event int, ctx interface{}))

+ func (b *Broker) Push(pipe *jobs.Pipeline, j *jobs.Job) (string, error)

+ func (b *Broker) Register(pipe *jobs.Pipeline) error

+ func (b *Broker) Serve() (err error)

+ func (b *Broker) Stat(pipe *jobs.Pipeline) (stat *jobs.Stat, err error)

+ func (b *Broker) Stop()

+ type Config struct

+ Addr string

+ Timeout int

+ func (c *Config) Hydrate(cfg service.Config) error

+ func (c *Config) TimeoutDuration() time.Duration