- Sort Score
- Result 10 results
- Languages All
Results 21 - 25 of 25 for DeletePod (0.13 sec)
-
pkg/controller/controller_utils_test.go
podControl := RealPodControl{ KubeClient: fakeClient, Recorder: &record.FakeRecorder{}, } controllerSpec := newReplicationController(1) err := podControl.DeletePod(context.TODO(), "namespace-name", "podName", controllerSpec) assert.True(t, apierrors.IsNotFound(err)) } func TestCountTerminatingPods(t *testing.T) { now := metav1.Now()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 39.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
addPod := func(name, ip string) { pod := generatePod(ip, name, "nsA", name, "node1", map[string]string{"app": "prod-app"}, map[string]string{}) addPods(t, controller, fx, pod) } deletePod := func(name, ip string) { if err := controller.client.Kube().CoreV1().Pods("nsA").Delete(context.TODO(), name, metav1.DeleteOptions{}); err != nil { t.Fatal(err) } retry.UntilSuccessOrFail(t, func() error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
assert.Nil(t, err, "error while retrieving old value of %q: %v", update.podName, err) assert.Equal(t, true, exists, "pod should exist") esController.podStore.Delete(old) esController.deletePod(old) } time.Sleep(tc.finalDelay) assert.Len(t, client.Actions(), tc.wantRequestCount) // In case of error, make debugging easier. for _, action := range client.Actions() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
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/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)