- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for NewBlockVolumePathHandler (0.39 sec)
-
pkg/kubelet/volumemanager/reconciler/reconciler_test.go
asw := cache.NewActualStateOfWorld(nodeName, volumePluginMgr) kubeClient := createTestClient() fakeRecorder := &record.FakeRecorder{} fakeHandler := volumetesting.NewBlockVolumePathHandler() oex := operationexecutor.NewOperationExecutor(operationexecutor.NewOperationGenerator( kubeClient, volumePluginMgr, fakeRecorder, fakeHandler, )) reconciler := NewReconciler( kubeClient,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
asw := cache.NewActualStateOfWorld(volumePluginMgr) fakeKubeClient := controllervolumetesting.CreateTestClient() fakeRecorder := &record.FakeRecorder{} fakeHandler := volumetesting.NewBlockVolumePathHandler() ad := operationexecutor.NewOperationExecutor(operationexecutor.NewOperationGenerator( fakeKubeClient, volumePluginMgr, fakeRecorder, fakeHandler))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0) -
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/runonce_test.go
kb.nodeName, kb.podManager, kb.podWorkers, kb.kubeClient, kb.volumePluginMgr, fakeRuntime, kb.mounter, kb.hostutil, kb.getPodsDir(), kb.recorder, volumetest.NewBlockVolumePathHandler()) // TODO: Factor out "stats.Provider" from Kubelet so we don't have a cyclic dependency volumeStatsAggPeriod := time.Second * 10
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 06:59:54 UTC 2024 - 6.5K 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)