- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 34 for DeletePod (0.12 sec)
-
pkg/controller/volume/attachdetach/cache/desired_state_of_world_test.go
if !volumeExists { t.Fatalf( "Added pod %q to volume %q/node %q. Volume does not exist, it should.", podName, generatedVolumeName, nodeName) } // Act dsw.DeletePod(types.UniquePodName(podName), generatedVolumeName, nodeName) // Assert volumeExists = dsw.VolumeExists(generatedVolumeName, nodeName) if volumeExists { t.Fatalf(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 35.9K 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) -
pkg/controller/volume/attachdetach/populator/desired_state_of_world_populator_test.go
if !volumeExists { t.Fatalf( "VolumeExists(%q) failed. Expected: <true> Actual: <%v>", expectedVolumeName, volumeExists) } //delete the pod and volume manually dswp.desiredStateOfWorld.DeletePod(podName, expectedVolumeName, k8stypes.NodeName(pod.Spec.NodeName)) //check if the given volume referenced by the pod still exists in dsw
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 7.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) -
pkg/controller/disruption/disruption.go
return } } logger.V(4).Info("DeletePod called on pod", "pod", klog.KObj(pod)) pdb := dc.getPdbForPod(logger, pod) if pdb == nil { logger.V(4).Info("No matching PDB for pod", "pod", klog.KObj(pod)) return } logger.V(4).Info("DeletePod -> PDB", "pod", klog.KObj(pod), "podDisruptionBudget", klog.KObj(pdb)) dc.enqueuePdb(logger, pdb) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/graph.go
e := newDestinationEdge(claimVertex, podVertex, nodeVertex) g.graph.SetEdge(e) g.addEdgeToDestinationIndex_locked(e) } } } func (g *Graph) DeletePod(name, namespace string) { start := time.Now() defer func() { graphActionsDuration.WithLabelValues("DeletePod").Observe(time.Since(start).Seconds()) }() g.lock.Lock() defer g.lock.Unlock() g.deleteVertex_locked(podVertexType, namespace, name) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 17.5K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
c.servicesSynced = serviceInformer.Informer().HasSynced podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addPod, UpdateFunc: c.updatePod, DeleteFunc: c.deletePod, }) c.podLister = podInformer.Lister() c.podsSynced = podInformer.Informer().HasSynced c.nodeLister = nodeInformer.Lister() c.nodesSynced = nodeInformer.Informer().HasSynced
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
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/controller/replicaset/replica_set_test.go
// delete handler, because it's already been counted in the update. manager.deletePod(logger, &pod) podExp, exists, err = manager.expectations.GetExpectations(rsKey) if !exists || err != nil || podExp.Fulfilled() { t.Fatalf("Wrong expectations %#v", podExp) } // Deleting the second pod should clear expectations. manager.deletePod(logger, secondPod) queueRS, _ = manager.queue.Get() if queueRS != rsKey {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0)