Method run

pkg/workerpool/worker_pool.go:128–150

(stopCh <-chan struct{})

}

func (w *WorkerPool) run(stopCh <-chan struct{}) {
	var waitGroup sync.WaitGroup
	waitGroup.Add(3)
	go func() {
		defer waitGroup.Done()
		w.worker(stopCh)
	}()

	go func() {
		defer waitGroup.Done()
		w.tryHandleRequestQueue(stopCh)
	}()

	go func() {
		defer waitGroup.Done()
		w.tryScaleInWorkerQueue(stopCh)
	}()

	<-stopCh

	w.queue.ShutDown()
	waitGroup.Wait()
}

func (w *WorkerPool) worker(stopCh <-chan struct{}) {
	for w.processNextCluster() {