- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for DeletePod (0.11 sec)
-
pkg/controller/job/job_controller.go
AddFunc: func(obj interface{}) { jm.addPod(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { jm.updatePod(logger, oldObj, newObj) }, DeleteFunc: func(obj interface{}) { jm.deletePod(logger, obj, true) }, }); err != nil { return nil, fmt.Errorf("adding Pod event handler: %w", err) } jm.podStore = podInformer.Lister() jm.podStoreSynced = podInformer.Informer().HasSynced
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
} } return podsToSync } // deletePod deletes the pod from the internal state of the kubelet by: // 1. stopping the associated pod worker asynchronously // 2. signaling to kill the pod by sending on the podKillingCh channel // // deletePod returns an error if not all sources are ready or the pod is not // found in the runtime cache. func (kl *Kubelet) deletePod(pod *v1.Pod) error { if pod == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K 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)