- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for NewBlockVolumePathHandler (0.43 sec)
-
pkg/volume/util/operationexecutor/operation_generator_test.go
fakeKubeClient := fakeclient.NewSimpleClientset(objects...) fakeRecorder := &record.FakeRecorder{} fakeHandler := volumetesting.NewBlockVolumePathHandler() operationGenerator := NewOperationGenerator( fakeKubeClient, volumePluginMgr, fakeRecorder, fakeHandler) return operationGenerator }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/volume/util/volumepathhandler/volume_path_handler.go
// GetLoopDevice returns the full path to the loop device associated with the given path. GetLoopDevice(path string) (string, error) } // NewBlockVolumePathHandler returns a new instance of BlockVolumeHandler. func NewBlockVolumePathHandler() BlockVolumePathHandler { var volumePathHandler VolumePathHandler return volumePathHandler } // VolumePathHandler is path related operation handlers for block volume
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 14:49:03 UTC 2023 - 10.7K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_linux_test.go
}, } for name, tc := range testCases { t.Run(name, func(t *testing.T) { pod := v1.Pod{ Spec: v1.PodSpec{ HostNetwork: true, }, } blkutil := volumetest.NewBlockVolumePathHandler() blkVolumes, err := kubelet.makeBlockVolumes(&pod, &tc.container, tc.podVolumes, blkutil) // validate only the error if we expect an error if tc.expectErr {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 18:00:59 UTC 2024 - 11.3K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager_test.go
fakeVolumeHost.WithNode(node) plugMgr.InitPlugins([]volume.VolumePlugin{attachablePlug, unattachablePlug}, nil /* prober */, fakeVolumeHost) stateProvider := &fakePodStateProvider{} fakePathHandler := volumetest.NewBlockVolumePathHandler() vm := NewVolumeManager( true, testHostname, podManager, stateProvider, kubeClient, plugMgr, &containertest.FakeRuntime{}, mount.NewFakeMounter(nil),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
expc.recorder = eventBroadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "volume_expand"}) blkutil := volumepathhandler.NewBlockVolumePathHandler() expc.operationGenerator = operationexecutor.NewOperationGenerator( kubeClient, &expc.volumePluginMgr, expc.recorder, blkutil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/volume/fc/fc.go
func (plugin *fcPlugin) ConstructBlockVolumeSpec(podUID types.UID, volumeName, mapPath string) (*volume.Spec, error) { pluginDir := plugin.host.GetVolumeDevicePluginDir(fcPluginName) blkutil := volumepathhandler.NewBlockVolumePathHandler() globalMapPathUUID, err := blkutil.FindGlobalMapPathUUIDFromPod(pluginDir, mapPath, podUID) if err != nil { return nil, err } klog.V(5).Infof("globalMapPathUUID: %v, err: %v", globalMapPathUUID, err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 17.4K bytes - Viewed (0) -
pkg/volume/iscsi/iscsi.go
func (plugin *iscsiPlugin) ConstructBlockVolumeSpec(podUID types.UID, volumeName, mapPath string) (*volume.Spec, error) { pluginDir := plugin.host.GetVolumeDevicePluginDir(iscsiPluginName) blkutil := volumepathhandler.NewBlockVolumePathHandler() globalMapPathUUID, err := blkutil.FindGlobalMapPathUUIDFromPod(pluginDir, mapPath, podUID) if err != nil { return nil, err } klog.V(5).Infof("globalMapPathUUID: %v, err: %v", globalMapPathUUID, err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 23.4K bytes - Viewed (0) -
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)