Versions in this module Expand all Collapse all v2 v2.0.1 Feb 14, 2021 v2.0.0 Feb 14, 2021 Changes in this version + func SetLogger(l Logger) + type Boss struct + func NewBoss() *Boss + func NewBossWithContext(ctx context.Context) *Boss + func (b *Boss) AddJob(workerName string, j Job) (err error) + func (b *Boss) HasWorker(name string) bool + func (b *Boss) HireWorker(ctx context.Context, name string, queueLength int) error + func (b *Boss) PlaceWorker(worker Worker) (err error) + func (b *Boss) ScaleDownWorker(workerName string) (err error) + func (b *Boss) Shutdown() + func (b *Boss) Shutdowned() bool + func (b *Boss) Terminate() + func (b *Boss) TerminateWorker(workerName string) (err error) + func (b *Boss) Worker(name string) (worker Worker) + type HR chan<- Worker + type HiringAgencyFunc func(ctx context.Context, name string, queueLength int, hr HR) Worker + var HiringAgency HiringAgencyFunc = NewPitDroid + type Job interface + Process func() error + RespondTo func() chan<- error + type Logger interface + Print func(...interface{}) + Printf func(string, ...interface{}) + type PitDroid struct + func (w *PitDroid) AddJob(j Job) (err error) + func (w *PitDroid) Length() int + func (w *PitDroid) Name() string + func (w *PitDroid) ScaleDown() + func (w *PitDroid) Terminate() + type Worker interface + AddJob func(Job) error + Length func() int + Name func() string + ScaleDown func() + Terminate func() + func NewPitDroid(ctx context.Context, name string, queueLength int, hr HR) Worker Other modules containing this package github.com/dcarbone/jobber/v3