- Sort Score
- Result 10 results
- Languages All
Results 31 - 33 of 33 for DeletePod (0.11 sec)
-
pkg/controller/job/job_controller_test.go
pod1 := newPod("pod1", job1) pod2 := newPod("pod2", job2) informer.Core().V1().Pods().Informer().GetIndexer().Add(pod1) informer.Core().V1().Pods().Informer().GetIndexer().Add(pod2) jm.deletePod(logger, pod1, true) verifyEmptyQueueAndAwaitForQueueLen(ctx, t, jm, 1) key, done := jm.queue.Get() if key == "" || done { t.Fatalf("failed to enqueue controller for pod %v", pod1.Name) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller_test.go
} if !exists { t.Fatalf("Pod %q doesn't exist", update.podName) } endpoints.podStore.Delete(old) endpoints.deletePod(old) } time.Sleep(tc.finalDelay) endpointsHandler.ValidateRequestCount(t, tc.wantRequestCount) }) } } func TestSyncEndpointsServiceNotFound(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
defer om.updatePodTracker.trackParallelRequests() if err := om.updatePodTracker.incWithOptionalError(); err != nil { return err } return om.podsIndexer.Update(pod) } func (om *fakeObjectManager) DeletePod(pod *v1.Pod) error { defer om.deletePodTracker.trackParallelRequests() if err := om.deletePodTracker.incWithOptionalError(); err != nil { return err } if key, err := controller.KeyFunc(pod); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0)