(worker *corev1.Pod)
| 423 | } |
| 424 | |
| 425 | func (w *WorkerPool) matchRequestFor(worker *corev1.Pod) *Request { |
| 426 | for _, item := range w.requestQueue.All() { |
| 427 | req := item.(Request) |
| 428 | |
| 429 | ttyd := worker.Spec.Containers[0] |
| 430 | if req.Namespace == worker.Namespace && req.Image == ttyd.Image { |
| 431 | return &req |
| 432 | } |
| 433 | } |
| 434 | |
| 435 | return nil |
| 436 | } |
| 437 | |
| 438 | func (w *WorkerPool) Back(worker *corev1.Pod) error { |
| 439 | return retry.RetryOnConflict(retry.DefaultRetry, func() error { |
no test coverage detected