- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for volData (0.16 sec)
-
pkg/volume/csi/csi_plugin.go
return ret, nil } ret.Spec = p.constructPVSourceSpec(volData[volDataKey.specVolID], volData[volDataKey.driverName], volData[volDataKey.volHandle]) return ret, nil } // constructVolSourceSpec constructs volume.Spec with CSIVolumeSource func (p *csiPlugin) constructVolSourceSpec(volSpecName, driverName string) *volume.Spec { vol := &api.Volume{
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_mounter.go
} // remove volume path klog.V(4).Info(log("deleting volume path [%s]", volPath)) if err := os.Remove(volPath); err != nil && !os.IsNotExist(err) { return errors.New(log("failed to delete volume path [%s]: %v", volPath, err)) } } return nil } // makeVolumeHandle returns csi-<sha256(podUID,volSourceSpecName)>
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
) func prepareVolumeInfoFile(mountPath string, plug *csiPlugin, specVolumeName, volumeID, driverName, lifecycleMode, seLinuxMountContext string) error { nodeName := string(plug.host.GetNodeName()) volData := map[string]string{ volDataKey.specVolID: specVolumeName, volDataKey.volHandle: volumeID, volDataKey.driverName: driverName, volDataKey.nodeName: nodeName,
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/iscsi/disk_manager.go
if err != nil { klog.Errorf("Failed to bind mount: source:%s, target:%s, err:%v", globalPDPath, volPath, err) noMnt, mntErr := b.mounter.IsLikelyNotMountPoint(volPath) if mntErr != nil { klog.Errorf("IsLikelyNotMountPoint check failed: %v", mntErr) return err } if !noMnt { if mntErr = b.mounter.Unmount(volPath); mntErr != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 03 19:34:37 UTC 2023 - 3.4K bytes - Viewed (0) -
pkg/volume/fc/disk_manager.go
noMnt, mntErr := b.mounter.IsLikelyNotMountPoint(volPath) if mntErr != nil { klog.Errorf("IsLikelyNotMountPoint check failed: %v", mntErr) return err } if !noMnt { if mntErr = b.mounter.Unmount(volPath); mntErr != nil { klog.Errorf("Failed to unmount: %v", mntErr) return err } noMnt, mntErr = b.mounter.IsLikelyNotMountPoint(volPath) if mntErr != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 03 19:34:37 UTC 2023 - 3K bytes - Viewed (0) -
pkg/volume/util/subpath/subpath_linux_test.go
} subpathLink := filepath.Join(volpath, "dirLink") return nil, volpath, subpath, os.Symlink(subpath, subpathLink) }, expectError: false, }, { name: "subpath-file", prepare: func(base string) ([]string, string, string, error) { volpath, _ := getTestPaths(base) subpath := filepath.Join(volpath, "file0") if err := os.MkdirAll(volpath, defaultPerm); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 10 16:52:55 UTC 2021 - 37.3K bytes - Viewed (0) -
pkg/volume/emptydir/empty_dir_test.go
t.Errorf("Got a nil Mounter") } volPath := mounter.GetPath() if volPath != volumePath { t.Errorf("Got unexpected path: %s", volPath) } if config.volumeDirExists { if err := os.MkdirAll(volPath, perm); err != nil { t.Errorf("fail to create path: %s", volPath) } } // Stat the directory and check the permission bits testSetUp(mounter, metadataDir, volPath) log := physicalMounter.GetLog()
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/local/local_test.go
if err != nil { t.Errorf("Failed to make a new Mounter: %v", err) } if mounter == nil { t.Fatalf("Got a nil Mounter") } volPath := filepath.Join(tmpDir, testMountPath) path := mounter.GetPath() if path != volPath { t.Errorf("Got unexpected path: %s", path) } if err := mounter.SetUp(volume.MounterArgs{}); err != nil { t.Errorf("Expected success, got: %v", err) }
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/portworx/portworx_test.go
if err != nil { t.Errorf("Failed to make a new Mounter: %v", err) } if mounter == nil { t.Errorf("Got a nil Mounter") } volPath := filepath.Join(tmpDir, "pods/poduid/volumes/kubernetes.io~portworx-volume/vol1") path := mounter.GetPath() if path != volPath { t.Errorf("Got unexpected path: %s", path) } if err := mounter.SetUp(volume.MounterArgs{}); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 21 02:17:04 UTC 2021 - 7.4K bytes - Viewed (0) -
pkg/volume/hostpath/host_path_test.go
t.Fatal("Can't find the plugin by name") } volPath := "/tmp/vol1" spec := &v1.Volume{ Name: "vol1", VolumeSource: v1.VolumeSource{HostPath: &v1.HostPathVolumeSource{Path: volPath, Type: newHostPathType(string(v1.HostPathDirectoryOrCreate))}}, } pod := &v1.Pod{ObjectMeta: metav1.ObjectMeta{UID: types.UID("poduid")}} defer os.RemoveAll(volPath)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 20.5K bytes - Viewed (0)