Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for podVolumes (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top