- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for specVolID (0.12 sec)
-
pkg/volume/csi/csi_plugin_test.go
defer os.RemoveAll(tmpDir) testCases := []struct { name string specVolID string data map[string]string shouldFail bool }{ { name: "valid spec name", specVolID: "test.vol.id", data: map[string]string{volDataKey.specVolID: "test.vol.id", volDataKey.volHandle: "test-vol0", volDataKey.driverName: "test-driver0"}, }, }
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/csi/csi_util.go
} // getVolumePluginDir returns the path where CSI plugin keeps metadata for given volume func getVolumePluginDir(specVolID string, host volume.VolumeHost) string { sanitizedSpecVolID := utilstrings.EscapeQualifiedName(specVolID) return filepath.Join(host.GetVolumeDevicePluginDir(CSIPluginName), sanitizedSpecVolID) } // getVolumeDevicePluginDir returns the path where the CSI plugin keeps the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 28 17:14:00 UTC 2023 - 7.3K bytes - Viewed (0) -
pkg/volume/csi/csi_util_test.go
} for i, tc := range testCases { t.Logf("test case: %s", tc.name) specVolID := fmt.Sprintf("spec-volid-%d", i) targetPath := getTargetPath(testPodUID, specVolID, plug.host) mountDir := filepath.Join(targetPath, "mount") if err := os.MkdirAll(mountDir, 0755); err != nil && !os.IsNotExist(err) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 14:49:03 UTC 2023 - 5.5K bytes - Viewed (0) -
pkg/volume/csi/csi_mounter.go
utilstrings "k8s.io/utils/strings" ) // TODO (vladimirvivien) move this in a central loc later var ( volDataKey = struct { specVolID, volHandle, driverName, nodeName, attachmentID, volumeLifecycleMode, seLinuxMountContext string }{ "specVolID", "volumeHandle", "driverName", "nodeName", "attachmentID", "volumeLifecycleMode", "seLinuxMountContext", } )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 30 10:47:59 UTC 2024 - 21K bytes - Viewed (0) -
pkg/volume/csi/csi_mounter_test.go
t.Fatal(err) } } data, err := loadVolumeData(dataDir, volDataFileName) if err != nil { t.Fatal(err) } if data[volDataKey.specVolID] != csiMounter.spec.Name() { t.Error("volume data file unexpected specVolID:", data[volDataKey.specVolID]) } if data[volDataKey.volHandle] != csiMounter.volumeID { t.Error("volume data file unexpected volHandle:", data[volDataKey.volHandle]) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 50.1K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin.go
if storage.VolumeLifecycleMode(volData[volDataKey.volumeLifecycleMode]) == storage.VolumeLifecycleEphemeral { ret.Spec = p.constructVolSourceSpec(volData[volDataKey.specVolID], volData[volDataKey.driverName]) return ret, nil } ret.Spec = p.constructPVSourceSpec(volData[volDataKey.specVolID], volData[volDataKey.driverName], volData[volDataKey.volHandle]) return ret, nil }
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/csi/csi_block_test.go
t.Errorf("failed to create dir [%s]: %v", dir, err) } if err := saveVolumeData( dir, volDataFileName, map[string]string{ volDataKey.specVolID: pv.ObjectMeta.Name, volDataKey.driverName: testDriver, volDataKey.volHandle: testVol, }, ); err != nil { t.Fatalf("failed to save volume data: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 11 06:07:40 UTC 2023 - 26.5K bytes - Viewed (0)