- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for findAndRemoveDeletedPods (0.32 sec)
-
pkg/controller/volume/attachdetach/populator/desired_state_of_world_populator.go
} func (dswp *desiredStateOfWorldPopulator) populatorLoopFunc(ctx context.Context) func(ctx context.Context) { return func(ctx context.Context) { logger := klog.FromContext(ctx) dswp.findAndRemoveDeletedPods(logger) // findAndAddActivePods is called periodically, independently of the main // populator loop. if time.Since(dswp.timeOfLastListPods) < dswp.listPodsRetryDuration { logger.V(5).Info(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 7.7K 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) } fakePodInformer.Informer().GetStore().Delete(pod) dswp.findAndRemoveDeletedPods(logger) //check if the given volume referenced by the pod still exists in dsw volumeExists = dswp.desiredStateOfWorld.VolumeExists(expectedVolumeName, k8stypes.NodeName(pod.Spec.NodeName)) if volumeExists {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 7.3K bytes - Viewed (0)