Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for volumeManager (0.74 sec)

  1. pkg/kubelet/kubelet_test.go

    			}
    		})
    	}
    }
    
    func waitForVolumeUnmount(
    	volumeManager kubeletvolume.VolumeManager,
    	pod *v1.Pod) error {
    	var podVolumes kubecontainer.VolumeMap
    	err := retryWithExponentialBackOff(
    		time.Duration(50*time.Millisecond),
    		func() (bool, error) {
    			// Verify volumes detached
    			podVolumes = volumeManager.GetMountedVolumesForPod(
    				util.GetUniquePodName(pod))
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet.go

    		// so that service name could be resolved
    		klet.dnsConfigurer.SetupDNSinContainerizedMounter(experimentalMounterPath)
    	}
    
    	// setup volumeManager
    	klet.volumeManager = volumemanager.NewVolumeManager(
    		kubeCfg.EnableControllerAttachDetach,
    		nodeName,
    		klet.podManager,
    		klet.podWorkers,
    		klet.kubeClient,
    		klet.volumePluginMgr,
    		klet.containerRuntime,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (1)
  3. pkg/features/kube_features.go

    	// owner: @jsafrane
    	// kep: https://kep.k8s.io/3756
    	// alpha: v1.25 (as part of SELinuxMountReadWriteOncePod)
    	// beta: v1.27
    	// GA: v1.30
    	// Robust VolumeManager reconstruction after kubelet restart.
    	NewVolumeManagerReconstruction featuregate.Feature = "NewVolumeManagerReconstruction"
    
    	// owner: @danwinship
    	// kep: https://kep.k8s.io/3866
    	// alpha: v1.29
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 22:51:23 UTC 2024
    - 45.2K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_pods.go

    	if err != nil {
    		return nil, nil, err
    	}
    	opts.Hostname = nodename
    	podName := volumeutil.GetUniquePodName(pod)
    	volumes := kl.volumeManager.GetMountedVolumesForPod(podName)
    
    	blkutil := volumepathhandler.NewBlockVolumePathHandler()
    	blkVolumes, err := kl.makeBlockVolumes(pod, container, volumes, blkutil)
    	if err != nil {
    		return nil, nil, err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
Back to top