Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 33 of 33 for DeletePod (0.11 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top