- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for NodeExists (0.42 sec)
-
pkg/controller/volume/attachdetach/cache/desired_state_of_world.go
} } func (dsw *desiredStateOfWorld) NodeExists(nodeName k8stypes.NodeName) bool { dsw.RLock() defer dsw.RUnlock() _, nodeExists := dsw.nodesManaged[nodeName] return nodeExists } func (dsw *desiredStateOfWorld) VolumeExists( volumeName v1.UniqueVolumeName, nodeName k8stypes.NodeName) bool { dsw.RLock() defer dsw.RUnlock() nodeObj, nodeExists := dsw.nodesManaged[nodeName] if nodeExists {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 13.5K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/desired_state_of_world_test.go
nodeName := k8stypes.NodeName("node-name") // Act dsw.AddNode(nodeName) // Assert nodeExists := dsw.NodeExists(nodeName) if !nodeExists { t.Fatalf("Added node %q does not exist, it should.", nodeName) } // Act dsw.AddNode(nodeName) // Assert nodeExists = dsw.NodeExists(nodeName) if !nodeExists { t.Fatalf("Added node %q does not exist, it should.", nodeName) }
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/volume/attachdetach/cache/actual_state_of_world.go
"volumeName", volumeName, "node", klog.KRef("", string(nodeName)), "devicePath", devicePath) } node, nodeExists := volumeObj.nodesAttachedTo[nodeName] if !nodeExists { // Create object if it doesn't exist. node = nodeAttachedTo{ nodeName: nodeName, attachedConfirmed: isAttached, detachRequestedTime: time.Time{}, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 07:35:17 UTC 2024 - 28.7K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/util/util.go
nodeName := types.NodeName(pod.Spec.NodeName) if nodeName == "" { logger.V(10).Info("Skipping processing of pod, it is not scheduled to a node", "pod", klog.KObj(pod)) return } else if !desiredStateOfWorld.NodeExists(nodeName) { // If the node the pod is scheduled to does not exist in the desired // state of the world data structure, that indicates the node is not // yet managed by the controller. Therefore, ignore the pod.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 12K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world.go
volumeName) } _, podExists := volumeObj.mountedPods[podName] if podExists { delete(asw.attachedVolumes[volumeName].mountedPods, podName) } // if there were reconstructed volumes, we should remove them _, podExists = asw.foundDuringReconstruction[volumeName] if podExists { delete(asw.foundDuringReconstruction[volumeName], podName) } return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 45.8K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/pod_devices.go
pdev.RLock() defer pdev.RUnlock() _, podExists := pdev.devs[podUID] return podExists } func (pdev *podDevices) insert(podUID, contName, resource string, devices checkpoint.DevicesPerNUMA, resp *pluginapi.ContainerAllocateResponse) { pdev.Lock() defer pdev.Unlock() if _, podExists := pdev.devs[podUID]; !podExists { pdev.devs[podUID] = make(containerDevices) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 16.7K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go
uid := types.UID(orphanedPod) _, podExists := dswp.podManager.GetPodByUID(uid) if !podExists && dswp.podStateProvider.ShouldPodRuntimeBeRemoved(uid) { dswp.deleteProcessedPod(orphanedPod) } } podsWithError := dswp.desiredStateOfWorld.GetPodsWithErrors() for _, podName := range podsWithError { if _, podExists := dswp.podManager.GetPodByUID(types.UID(podName)); !podExists {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 23.8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/desired_state_of_world.go
return false } } _, podExists := volumeObj.podsToMount[podName] return podExists } func (dsw *desiredStateOfWorld) VolumeExistsWithSpecName(podName types.UniquePodName, volumeSpecName string) bool { dsw.RLock() defer dsw.RUnlock() for _, volumeObj := range dsw.volumesToMount { if podObj, podExists := volumeObj.podsToMount[podName]; podExists { if podObj.volumeSpec.Name() == volumeSpecName {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 27.1K bytes - Viewed (0)