Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for GetPodVolumeDeviceDir (0.53 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top