Function NewWorkers

worker.go:158–162

NewWorkers initializes a new registry of available job workers. Use the top-level AddWorker function combined with a Workers registry to register each available worker.

()

// Use the top-level AddWorker function combined with a Workers registry to
// register each available worker.
func NewWorkers() *Workers {
	return &Workers{
		workersMap: make(map[string]workerInfo),
	}
}

func (w Workers) add(jobArgs JobArgs, workUnitFactory workunit.WorkUnitFactory) error {
	checkRegistered := func(kind string) error {