- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for GetPodVolumeDeviceDir (0.53 sec)
-
pkg/kubelet/volume_host.go
if runtime.GOOS == "windows" { dir = util.GetWindowsPath(dir) } return dir } func (kvh *kubeletVolumeHost) GetPodVolumeDeviceDir(podUID types.UID, pluginName string) string { return kvh.kubelet.getPodVolumeDeviceDir(podUID, pluginName) } func (kvh *kubeletVolumeHost) GetPodPluginDir(podUID types.UID, pluginName string) string { return kvh.kubelet.getPodPluginDir(podUID, pluginName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 10K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/volume_host.go
return "" } func (ctrl *PersistentVolumeController) GetPodPluginDir(podUID types.UID, pluginName string) string { return "" } func (ctrl *PersistentVolumeController) GetPodVolumeDeviceDir(ppodUID types.UID, pluginName string) string { return "" } func (ctrl *PersistentVolumeController) GetKubeClient() clientset.Interface { return ctrl.kubeClient }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/kubelet/kubelet_getters_test.go
assert.Equal(t, exp, got) got = kubelet.getPodVolumeDevicesDir("abc123") exp = filepath.Join(root, "pods/abc123/volumeDevices") assert.Equal(t, exp, got) got = kubelet.getPodVolumeDeviceDir("abc123", "plugin") exp = filepath.Join(root, "pods/abc123/volumeDevices/plugin") assert.Equal(t, exp, got) got = kubelet.getPodPluginsDir("abc123") exp = filepath.Join(root, "pods/abc123/plugins")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 00:48:07 UTC 2024 - 3.8K bytes - Viewed (0) -
pkg/kubelet/kubelet_getters.go
return filepath.Join(kl.getPodDir(podUID), config.DefaultKubeletVolumeDevicesDirName) } // getPodVolumeDeviceDir returns the full path to the directory which represents the // named plugin for specified pod. This directory may not exist if the pod does not exist. func (kl *Kubelet) getPodVolumeDeviceDir(podUID types.UID, pluginName string) string { return filepath.Join(kl.getPodVolumeDevicesDir(podUID), pluginName) }
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/controller/volume/expand/expand_controller.go
return "" } func (expc *expandController) GetPodVolumeDir(podUID types.UID, pluginName string, volumeName string) string { return "" } func (expc *expandController) GetPodVolumeDeviceDir(podUID types.UID, pluginName string) string { return "" } func (expc *expandController) GetPodPluginDir(podUID types.UID, pluginName string) string { return "" }
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/testing/volume_host.go
func (f *fakeVolumeHost) GetPodVolumeDir(podUID types.UID, pluginName, volumeName string) string { return filepath.Join(f.rootDir, "pods", string(podUID), "volumes", pluginName, volumeName) } func (f *fakeVolumeHost) GetPodVolumeDeviceDir(podUID types.UID, pluginName string) string { return filepath.Join(f.rootDir, "pods", string(podUID), "volumeDevices", pluginName) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 16.5K bytes - Viewed (0) -
pkg/volume/fc/fc.go
return "", err } return fc.manager.MakeGlobalVDPDName(*mounter.fcDisk), nil } func (fc *fcDisk) fcPodDeviceMapPath() (string, string) { return fc.plugin.host.GetPodVolumeDeviceDir(fc.podUID, utilstrings.EscapeQualifiedName(fcPluginName)), fc.volName } type fcDiskMounter struct { *fcDisk readOnly bool fsType string
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/plugins.go
GetPodPluginDir(podUID types.UID, pluginName string) string // GetPodVolumeDeviceDir returns the absolute path a directory which // represents the named plugin for the given pod. // If the specified pod does not exist, the result of this call // might not exist. // ex. pods/{podUid}/{DefaultKubeletVolumeDevicesDirName}/{escapeQualifiedPluginName}/ GetPodVolumeDeviceDir(podUID types.UID, pluginName string) string
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/csi/csi_block.go
// returns: pods/{podUID}/volumeDevices/kubernetes.io~csi, {specName} func (m *csiBlockMapper) GetPodDeviceMapPath() (string, string) { path := m.plugin.host.GetPodVolumeDeviceDir(m.podUID, utilstrings.EscapeQualifiedName(CSIPluginName)) klog.V(4).Infof(log("blockMapper.GetPodDeviceMapPath [path=%s; name=%s]", path, m.specName)) return path, m.specName }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 11 06:07:40 UTC 2023 - 20.1K bytes - Viewed (0) -
pkg/volume/iscsi/iscsi.go
} return iscsi.manager.MakeGlobalVDPDName(*mounter.iscsiDisk), nil } func (iscsi *iscsiDisk) iscsiPodDeviceMapPath() (string, string) { name := iscsiPluginName return iscsi.plugin.host.GetPodVolumeDeviceDir(iscsi.podUID, utilstrings.EscapeQualifiedName(name)), iscsi.VolName } type iscsiDiskMounter struct { *iscsiDisk readOnly bool fsType string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 23.4K bytes - Viewed (0)