Versions in this module Expand all Collapse all v1 v1.6.4 Feb 24, 2021 Changes in this version + func GetNumWorkers(j *JobManager) int + type Job interface + Execute func() error + GetID func() string + OnFailure func(err error) + type JobManager struct + func NewJobManager(name string, numWorkers int, l log.Logger) *JobManager + func (j *JobManager) AddJob(job Job, queueID string) + func (j *JobManager) GetPendingJobCount() int + func (j *JobManager) GetWorkQueueLengths() map[string]int + func (j *JobManager) GetWorkerCounts() map[string]int + func (j *JobManager) Start() + func (j *JobManager) Stop()