func NewScheduler()

in pkg/scheduler/scheduler.go [62:73]

• 12 lines of code
• 2 McCabe index (conditional complexity)

func NewScheduler(clients ...client.Interface) *Scheduler {
	scheduler := &Scheduler{
		logger:  log.ForPackage("scheduler"),
		wg:      &sync.WaitGroup{},
		sources: make([]Job, len(clients)),
	}
	for i := range clients {
		scheduler.sources[i] = newMetricJob(clients[i], scheduler.wg)
	}
	scheduler.wg.Add(len(clients))
	return scheduler
}