- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for GetPluginDir (0.26 sec)
-
pkg/kubelet/volume_host.go
var _ volume.VolumeHost = &kubeletVolumeHost{} var _ volume.KubeletVolumeHost = &kubeletVolumeHost{} func (kvh *kubeletVolumeHost) GetPluginDir(pluginName string) string { return kvh.kubelet.getPluginDir(pluginName) } type kubeletVolumeHost struct { kubelet *Kubelet volumePluginMgr volume.VolumePluginMgr secretManager secret.Manager
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
"k8s.io/kubernetes/pkg/volume/util/subpath" ) // VolumeHost interface implementation for PersistentVolumeController. var _ vol.VolumeHost = &PersistentVolumeController{} func (ctrl *PersistentVolumeController) GetPluginDir(pluginName string) string { return "" } func (ctrl *PersistentVolumeController) GetVolumeDevicePluginDir(pluginName string) string { return "" } func (ctrl *PersistentVolumeController) GetPodsDir() string {
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
exp = filepath.Join(root, "plugins") assert.Equal(t, exp, got) got = kubelet.getPluginsRegistrationDir() exp = filepath.Join(root, "plugins_registry") assert.Equal(t, exp, got) got = kubelet.getPluginDir("foobar") exp = filepath.Join(root, "plugins/foobar") assert.Equal(t, exp, got) got = kubelet.getPodDir("abc123") exp = filepath.Join(root, "pods/abc123") assert.Equal(t, exp, got)
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.getRootDir(), config.DefaultKubeletPluginsRegistrationDirName) } // getPluginDir returns a data directory name for a given plugin name. // Plugins can use these directories to store data that they need to persist. // For per-pod plugin data, see getPodPluginDir. func (kl *Kubelet) getPluginDir(pluginName string) string { return filepath.Join(kl.getPluginsDir(), 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/volume/flexvolume/plugin.go
volumeName, err := plugin.GetVolumeName(spec) if err != nil { return "", fmt.Errorf("GetVolumeName failed from getDeviceMountPath: %s", err) } mountsDir := filepath.Join(plugin.host.GetPluginDir(flexVolumePluginName), plugin.driverName, "mounts") return filepath.Join(mountsDir, volumeName), nil } func (plugin *flexVolumePlugin) RequiresFSResize() bool { return plugin.capabilities.RequiresFSResize
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 9.7K bytes - Viewed (0) -
pkg/volume/testing/volume_host.go
if err := host.WaitForKubeletErrNil(); err != nil { t.Fatalf("Failed to wait for kubelet err to be nil while creating fake volume host: %v", err) } return host } func (f *fakeVolumeHost) GetPluginDir(podUID string) string { return filepath.Join(f.rootDir, "plugins", podUID) } func (f *fakeVolumeHost) GetVolumeDevicePluginDir(pluginName string) string {
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/controller/volume/expand/expand_controller.go
// with pv spec capacity. if pvcStatusCap.Cmp(*pvcSpecCap) >= 0 && pvcStatusCap.Cmp(pvCap) >= 0 { return true } return false } // Implementing VolumeHost interface func (expc *expandController) GetPluginDir(pluginName string) string { return "" } func (expc *expandController) GetVolumeDevicePluginDir(pluginName string) string { return "" } func (expc *expandController) GetPodsDir() string {
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/plugins.go
// VolumeHost is an interface that plugins can use to access the kubelet. type VolumeHost interface { // GetPluginDir returns the absolute path to a directory under which // a given plugin may store data. This directory might not actually // exist on disk yet. For plugin data that is per-pod, see // GetPodPluginDir(). GetPluginDir(pluginName string) string // GetVolumeDevicePluginDir returns the absolute path to a directory
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/fc/fc.go
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/emptydir/empty_dir.go
if isMnt && medium == v1.StorageMediumMemory { return nil } options := ed.generateTmpfsMountOptions(swap.IsTmpfsNoswapOptionSupported(ed.mounter, ed.plugin.host.GetPluginDir(emptyDirPluginName))) klog.V(3).Infof("pod %v: mounting tmpfs for volume %v", ed.pod.UID, ed.volName) return ed.mounter.MountSensitiveWithoutSystemd("tmpfs", dir, "tmpfs", options, nil) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 19K bytes - Viewed (0)