- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 67 for volumePath (0.24 sec)
-
pkg/volume/projected/projected_test.go
} if _, err := os.Stat(volumePath); err != nil { if os.IsNotExist(err) { t.Errorf("SetUp() failed, volume path not created: %s", volumePath) } else { t.Errorf("SetUp() failed: %v", err) } } doTestSecretDataInVolume(volumePath, secret, t) doTestCleanAndTeardown(plugin, testPodUID, testVolumeName, volumePath, t) } func TestPluginOptional(t *testing.T) { var (
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 40.5K bytes - Viewed (0) -
pkg/volume/util/subpath/subpath_windows.go
} return lockAndCheckSubPathWithoutSymlink(finalVolumePath, finalSubPath) } // lock all intermediate subPath directories and check they are all within volumePath // volumePath & subPath should not contain any symlink, otherwise it will return error func lockAndCheckSubPathWithoutSymlink(volumePath, subPath string) ([]uintptr, error) { if len(volumePath) == 0 || len(subPath) == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 23 12:57:11 UTC 2023 - 12.5K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct_test.go
os.MkdirAll(tmpKubeletPodDir, 0755) mountPaths := []string{} // create pod and volume directories so as reconciler can find them. for _, volumePath := range tc.volumePaths { vp := filepath.Join(tmpKubeletPodDir, volumePath) mountPaths = append(mountPaths, vp) os.MkdirAll(vp, 0755) } rc, fakePlugin := getReconciler(tmpKubeletDir, t, mountPaths, nil /*custom kubeclient*/)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct_common.go
for _, volumeName := range volumePluginDirs { volumePath := filepath.Join(volumePluginPath, volumeName) klog.V(5).InfoS("Volume path from volume plugin directory", "podName", podName, "volumePath", volumePath) volumes = append(volumes, podVolume{ podName: volumetypes.UniquePodName(podName), volumeSpecName: volumeName, volumePath: volumePath, pluginName: unescapePluginName,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/kubelet/kubelet_volumes.go
volumePaths, err := kl.getPodVolumePathListFromDisk(uid) if err != nil { orphanVolumeErrors = append(orphanVolumeErrors, fmt.Errorf("orphaned pod %q found, but error occurred during reading volume dir from disk: %v", uid, err)) return orphanVolumeErrors } if len(volumePaths) > 0 { for _, volumePath := range volumePaths { if err := syscall.Rmdir(volumePath); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.1K bytes - Viewed (0) -
pkg/volume/csi/csi_client_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 33.9K bytes - Viewed (0) -
pkg/kubelet/kubelet_getters.go
for _, volumePath := range volumePaths { isNotMount, err := kl.mounter.IsLikelyNotMountPoint(volumePath) if err != nil { return mountedVolumes, fmt.Errorf("fail to check mount point %q: %v", volumePath, err) } if !isNotMount { mountedVolumes = append(mountedVolumes, volumePath) } } return mountedVolumes, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 00:48:07 UTC 2024 - 17.9K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_executor.go
reconstructed, err := plugin.ConstructVolumeSpec(volumeSpecName, volumePath) if err != nil { return volume.ReconstructedVolume{}, err } return reconstructed, nil } // Block Volume case // Create volumeSpec from mount path klog.V(5).Infof("Starting operationExecutor.ReconstructVolume for block volume on pod %q", podName)
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/emptydir/empty_dir_test.go
basePath, err := utiltesting.MkTmpdir("emptydir_volume_test") if err != nil { t.Fatalf("can't make a temp rootdir: %v", err) } defer os.RemoveAll(basePath) var ( volumePath = filepath.Join(basePath, "pods/poduid/volumes/kubernetes.io~empty-dir/test-volume") metadataDir = filepath.Join(basePath, "pods/poduid/plugins/kubernetes.io~empty-dir/test-volume")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 30.7K bytes - Viewed (0) -
pkg/volume/plugins.go
// ConstructVolumeSpec constructs a volume spec based on the given volume name // and volumePath. 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 ConstructVolumeSpec(volumeName, volumePath string) (ReconstructedVolume, error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 38.2K bytes - Viewed (0)