Method enqueue

pkg/workerpool/worker_pool.go:112–118

(obj interface{})

}

func (w *WorkerPool) enqueue(obj interface{}) {
	pod := obj.(*corev1.Pod)
	if isIdleWorker(pod) {
		key, _ := cache.MetaNamespaceKeyFunc(obj)
		w.queue.Add(key)
	}
}

func (w *WorkerPool) Run(stopCh <-chan struct{}) {
	if !cache.WaitForCacheSync(stopCh, w.podInformer.HasSynced) {