- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for podVolumes (0.17 sec)
-
pkg/scheduler/framework/plugins/volumebinding/binder.go
} podVolumes.StaticBindings = newBindings podVolumes.DynamicProvisions = newProvisionedPVCs return } // RevertAssumedPodVolumes will revert assumed PV and PVC cache. func (b *volumeBinder) RevertAssumedPodVolumes(podVolumes *PodVolumes) { b.revertAssumedPVs(podVolumes.StaticBindings) b.revertAssumedPVCs(podVolumes.DynamicProvisions) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 14:55:34 UTC 2024 - 42.6K bytes - Viewed (0) -
pkg/kubelet/kubelet_volumes.go
func (kl *Kubelet) ListVolumesForPod(podUID types.UID) (map[string]volume.Volume, bool) { volumesToReturn := make(map[string]volume.Volume) podVolumes := kl.volumeManager.GetMountedVolumesForPod( volumetypes.UniquePodName(podUID)) for outerVolumeSpecName, volume := range podVolumes { // TODO: volume.Mounter could be nil if volume object is recovered // from reconciler's sync state process. PR 33616 will fix this problem
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.1K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
InnerVolumeSpecName: mountedVolume.InnerVolumeSpecName, } } return podVolumes } func (vm *volumeManager) GetPossiblyMountedVolumesForPod(podName types.UniquePodName) container.VolumeMap { podVolumes := make(container.VolumeMap) for _, mountedVolume := range vm.actualStateOfWorld.GetPossiblyMountedVolumesForPod(podName) { podVolumes[mountedVolume.OuterVolumeSpecName] = container.VolumeInfo{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go
for _, podVolume := range pod.Spec.Volumes { if !mounts.Has(podVolume.Name) && !devices.Has(podVolume.Name) { // Volume is not used in the pod, ignore it. klog.V(4).InfoS("Skipping unused volume", "pod", klog.KObj(pod), "volumeName", podVolume.Name) continue } pvc, volumeSpec, volumeGidValue, err := dswp.createVolumeSpec(podVolume, pod, mounts, devices) if err != nil {
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/reconciler/reconstruct_test.go
} defaultVolume := podVolume{ podName: "pod1uid", volumeSpecName: "volume-name", volumePath: "", pluginName: "fake-plugin", volumeMode: v1.PersistentVolumeFilesystem, } tests := []struct { name string podInfos []podInfo volumesFailedReconstruction []podVolume expectedUnmounts int }{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
volumeSpec, err := util.CreateVolumeSpec(logger, podVolume, podToAdd, nodeName, &adc.volumePluginMgr, adc.pvcLister, adc.pvLister, adc.csiMigratedPluginManager, adc.intreeToCSITranslator) if err != nil { logger.Error( err, "Error creating spec for volume of pod", "pod", klog.KObj(podToAdd), "volumeName", podVolume.Name) continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler_common.go
volumePluginMgr: volumePluginMgr, kubeletPodsDir: kubeletPodsDir, timeOfLastSync: time.Time{}, volumesFailedReconstruction: make([]podVolume, 0), volumesNeedUpdateFromNodeStatus: make([]v1.UniqueVolumeName, 0), } } type reconciler struct { kubeClient clientset.Interface controllerAttachDetachEnabled bool
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 14.8K bytes - Viewed (0)