- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for DeletePod (0.19 sec)
-
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
verifyNewDetacherCallCount(t, true /* expectZeroNewDetacherCallCount */, fakePlugin) waitForDetachCallCount(t, 0 /* expectedDetachCallCount */, fakePlugin) // Act dsw.DeletePod(types.UniquePodName(podName), generatedVolumeName, nodeName) volumeExists = dsw.VolumeExists(generatedVolumeName, nodeName) if volumeExists { t.Fatalf(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_test.go
om.setsIndexer.Add(set1) om.setsIndexer.Add(set2) ssc.deletePod(logger, pod1) key, done := ssc.queue.Get() if key == "" || done { t.Error("failed to enqueue StatefulSet") } else if expectedKey, _ := controller.KeyFunc(set1); expectedKey != key { t.Errorf("expected StatefulSet key %s found %s", expectedKey, key) } ssc.deletePod(logger, pod2) key, done = ssc.queue.Get() if key == "" || done {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.1K bytes - Viewed (0) -
pilot/pkg/xds/workload_test.go
deletePod(s, "pod") expectRemoved(ads.ExpectResponse(), "Kubernetes//Pod/default/pod") // Create pod we are not subscribed to; due to same-node optimization this will push createPod(s, "pod-same-node", "sa", "127.0.0.3", "node") expect(ads.ExpectResponse(), "Kubernetes//Pod/default/pod-same-node") deletePod(s, "pod-same-node")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 15.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
for _, set := range sets { ssc.enqueueStatefulSet(set) } } } // deletePod enqueues the statefulset for the pod accounting for deletion tombstones. func (ssc *StatefulSetController) deletePod(logger klog.Logger, obj interface{}) { pod, ok := obj.(*v1.Pod) // When a delete is dropped, the relist will notice a pod in the store not
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
// an rs never initiates a phase change, and so is never asleep waiting for the same. rsc.deletePod(logger, curPod) if labelChanged { // we don't need to check the oldPod.DeletionTimestamp because DeletionTimestamp cannot be unset. rsc.deletePod(logger, oldPod) } return } curControllerRef := metav1.GetControllerOf(curPod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control.go
type StatefulPodControlObjectManager interface { CreatePod(ctx context.Context, pod *v1.Pod) error GetPod(namespace, podName string) (*v1.Pod, error) UpdatePod(pod *v1.Pod) error DeletePod(pod *v1.Pod) error CreateClaim(claim *v1.PersistentVolumeClaim) error GetClaim(namespace, claimName string) (*v1.PersistentVolumeClaim, error) UpdateClaim(claim *v1.PersistentVolumeClaim) error }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 14.9K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller.go
if d == nil { return } logger.V(4).Info("ReplicaSet deleted", "replicaSet", klog.KObj(rs)) dc.enqueueDeployment(d) } // deletePod will enqueue a Recreate Deployment once all of its pods have stopped running. func (dc *DeploymentController) deletePod(logger klog.Logger, obj interface{}) { pod, ok := obj.(*v1.Pod) // When a delete is dropped, the relist will notice a pod in the store not
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
AddFunc: func(obj interface{}) { dsc.addPod(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { dsc.updatePod(logger, oldObj, newObj) }, DeleteFunc: func(obj interface{}) { dsc.deletePod(logger, obj) }, }) dsc.podLister = podInformer.Lister() dsc.podStoreSynced = podInformer.Informer().HasSynced nodeInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
s.lookup(s.addrXdsName("127.0.0.6"))[0].Address.GetWorkload().Waypoint.GetAddress().Address, netip.MustParseAddr("10.0.0.2").AsSlice()) s.deletePod(t, "pod6") s.assertEvent(t, s.podXdsName("pod6")) s.deletePod(t, "pod3") s.assertEvent(t, s.podXdsName("pod3")) s.deletePod(t, "pod2") s.assertEvent(t, s.podXdsName("pod2")) s.deleteWaypoint(t, "waypoint-ns") s.assertEvent(t, s.podXdsName("pod1"))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 70.2K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller_test.go
t.Fatalf("error creating Deployment controller: %v", err) } enqueued := false c.enqueueDeployment = func(d *apps.Deployment) { if d.Name == "foo" { enqueued = true } } c.deletePod(logger, pod) if !enqueued { t.Errorf("expected deployment %q to be queued after pod deletion", foo.Name) } } // TestPodDeletionDoesntEnqueueRecreateDeployment ensures that the deletion of a pod
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.5K bytes - Viewed (0)