Method matchWorkerFor

pkg/workerpool/worker_pool.go:401–423

matchWorkerRequest returns the worker name.

(req *Request)

// matchWorkerRequest returns the worker name.
func (w *WorkerPool) matchWorkerFor(req *Request) (*corev1.Pod, error) {
	var workerName string
	for _, item := range w.workerQueue.All() {
		ns, name, image, _ := SplitWorkerKey(item.(string))

		if ns == req.Namespace && image == req.Image {
			workerName = name
			break
		}
	}

	if len(workerName) != 0 {
		worker, err := w.podLister.Pods(req.Namespace).Get(workerName)
		// TODO: if err is notfound?
		if err != nil {
			return nil, err
		}

		return worker, nil
	}

	return nil, ErrNotWorker
}

func (w *WorkerPool) matchRequestFor(worker *corev1.Pod) *Request {
	for _, item := range w.requestQueue.All() {