- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for ConstructBlockVolumeSpec (0.57 sec)
-
pkg/volume/fc/fc.go
return volume.ReconstructedVolume{ Spec: volume.NewSpecFromVolume(fcVolume), SELinuxMountContext: mountContext, }, nil } // ConstructBlockVolumeSpec creates a new volume.Spec with following steps. // - Searches a file whose name is {pod uuid} under volume plugin directory. // - If a file is found, then retrieves volumePluginDependentPath from globalMapPathUUID.
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/local/local_test.go
defer os.RemoveAll(tmpDir) podPath := filepath.Join(tmpDir, testPodPath) spec, err := plug.ConstructBlockVolumeSpec(types.UID("poduid"), testPVName, podPath) if err != nil { t.Errorf("ConstructBlockVolumeSpec() failed: %v", err) } if spec == nil { t.Fatalf("ConstructBlockVolumeSpec() returned nil") } volName := spec.Name() if volName != testPVName {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 08 10:53:39 UTC 2023 - 22.5K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin.go
unmapper.csiClientGetter.driverName = unmapper.driverName return unmapper, nil } func (p *csiPlugin) ConstructBlockVolumeSpec(podUID types.UID, specVolName, mapPath string) (*volume.Spec, error) { klog.V(4).Infof("plugin.ConstructBlockVolumeSpec [podUID=%s, specVolName=%s, path=%s]", string(podUID), specVolName, mapPath) dataDir := getVolumeDeviceDataDir(specVolName, p.host)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 29.2K bytes - Viewed (0) -
pkg/volume/iscsi/iscsi.go
} } return volume.ReconstructedVolume{ Spec: volume.NewSpecFromVolume(iscsiVolume), SELinuxMountContext: mountContext, }, nil } func (plugin *iscsiPlugin) ConstructBlockVolumeSpec(podUID types.UID, volumeName, mapPath string) (*volume.Spec, error) { pluginDir := plugin.host.GetVolumeDevicePluginDir(iscsiPluginName) blkutil := volumepathhandler.NewBlockVolumePathHandler()
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/volume/plugins.go
// ConstructBlockVolumeSpec constructs a volume spec based on the given // podUID, volume name and a pod device map path. // The spec may have incomplete information due to limited information // from input. This function is used by volume manager to reconstruct // volume spec by reading the volume directories from disk.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 38.2K bytes - Viewed (0) -
pkg/volume/local/local.go
}, }, VolumeMode: &fs, }, } return volume.ReconstructedVolume{ Spec: volume.NewSpecFromPersistentVolume(localVolume, false), }, nil } func (plugin *localVolumePlugin) ConstructBlockVolumeSpec(podUID types.UID, volumeName, mapPath string) (*volume.Spec, error) { block := v1.PersistentVolumeBlock localVolume := &v1.PersistentVolume{ ObjectMeta: metav1.ObjectMeta{ Name: volumeName,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 22.2K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin_test.go
} if err := saveVolumeData(deviceDataDir, volDataFileName, tc.data); err != nil { t.Fatal(err) } } // rebuild spec spec, err := plug.ConstructBlockVolumeSpec("test-podUID", tc.specVolID, getVolumeDevicePluginDir(tc.specVolID, plug.host)) if tc.shouldFail { if err == nil { t.Fatal("expecting ConstructVolumeSpec to fail, but got nil error") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 41.8K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_executor.go
// corresponding to raw block device. // ex. volumePath: pods/{podUid}}/{DefaultKubeletVolumeDevicesDirName}/{escapeQualifiedPluginName}/{volumeName} volumeSpec, err := mapperPlugin.ConstructBlockVolumeSpec(uid, volumeSpecName, volumePath) if err != nil { return volume.ReconstructedVolume{}, err } return volume.ReconstructedVolume{ Spec: volumeSpec, }, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 42.6K bytes - Viewed (0) -
pkg/volume/testing/testing.go
return volume.ReconstructedVolume{ Spec: &volume.Spec{ Volume: &v1.Volume{ Name: volumeName, }, }, }, nil } // Block volume support func (plugin *FakeVolumePlugin) ConstructBlockVolumeSpec(podUID types.UID, volumeName, mountPath string) (*volume.Spec, error) { return &volume.Spec{ Volume: &v1.Volume{ Name: volumeName, }, }, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 53.3K bytes - Viewed (0)