Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 15 of 15 for NewBlockVolumePathHandler (0.27 sec)

  1. pkg/controller/volume/attachdetach/attach_detach_controller.go

    	}
    
    	adc.broadcaster = record.NewBroadcaster(record.WithContext(ctx))
    	recorder := adc.broadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "attachdetach-controller"})
    	blkutil := volumepathhandler.NewBlockVolumePathHandler()
    
    	adc.desiredStateOfWorld = cache.NewDesiredStateOfWorld(&adc.volumePluginMgr)
    	adc.actualStateOfWorld = cache.NewActualStateOfWorld(&adc.volumePluginMgr)
    	adc.attacherDetacher =
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  2. pkg/volume/testing/testing.go

    	}
    
    	return pv, nil
    }
    
    var _ volumepathhandler.BlockVolumePathHandler = &FakeVolumePathHandler{}
    
    // NewDeviceHandler Create a new IoHandler implementation
    func NewBlockVolumePathHandler() volumepathhandler.BlockVolumePathHandler {
    	return &FakeVolumePathHandler{}
    }
    
    type FakeVolumePathHandler struct {
    	sync.RWMutex
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 12:32:15 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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