Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewBlockVolumePathHandler (0.23 sec)

  1. pkg/kubelet/kubelet_pods.go

    		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
    	}
    	opts.Devices = append(opts.Devices, blkVolumes...)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_test.go

    		kubelet.podWorkers,
    		fakeKubeClient,
    		kubelet.volumePluginMgr,
    		fakeRuntime,
    		kubelet.mounter,
    		kubelet.hostutil,
    		kubelet.getPodsDir(),
    		kubelet.recorder,
    		volumetest.NewBlockVolumePathHandler())
    
    	kubelet.pluginManager = pluginmanager.NewPluginManager(
    		kubelet.getPluginsRegistrationDir(), /* sockDir */
    		kubelet.recorder,
    	)
    	kubelet.setNodeStatusFuncs = kubelet.defaultNodeStatusFuncs()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet.go

    		klet.podWorkers,
    		klet.kubeClient,
    		klet.volumePluginMgr,
    		klet.containerRuntime,
    		kubeDeps.Mounter,
    		kubeDeps.HostUtil,
    		klet.getPodsDir(),
    		kubeDeps.Recorder,
    		volumepathhandler.NewBlockVolumePathHandler())
    
    	klet.backOff = flowcontrol.NewBackOff(backOffPeriod, MaxContainerBackOff)
    
    	// setup eviction manager
    	evictionManager, evictionAdmitHandler := eviction.NewManager(klet.resourceAnalyzer, evictionConfig,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
Back to top