- Sort Score
- Result 10 results
- Languages All
Results 11 - 18 of 18 for GetPluginDir (0.25 sec)
-
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) -
pkg/volume/iscsi/iscsi_util.go
func makePDNameInternal(host volume.VolumeHost, portal string, iqn string, lun string, iface string) string { return filepath.Join(host.GetPluginDir(iscsiPluginName), "iface-"+iface, portal+"-"+iqn+"-lun-"+lun) } // make a directory like /var/lib/kubelet/plugins/kubernetes.io/iscsi/volumeDevices/iface_name/portal-some_iqn-lun-lun_id
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 22 12:53:01 UTC 2022 - 34.1K bytes - Viewed (0) -
pkg/volume/local/local.go
}, } return volume.NewSpecFromPersistentVolume(localVolume, false), nil } func (plugin *localVolumePlugin) generateBlockDeviceBaseGlobalPath() string { return filepath.Join(plugin.host.GetPluginDir(localVolumePluginName), util.MountsInGlobalPDPath) } func (plugin *localVolumePlugin) getGlobalLocalPath(spec *volume.Spec) (string, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 22.2K bytes - Viewed (0) -
pkg/volume/iscsi/iscsi.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 23.4K bytes - Viewed (0) -
pkg/volume/csi/csi_attacher.go
} result := sha256.Sum256([]byte(fmt.Sprintf("%s", csiSource.VolumeHandle))) volSha := fmt.Sprintf("%x", result) return filepath.Join(plugin.host.GetPluginDir(plugin.GetPluginName()), driver, volSha, globalMountInGlobalPath), nil } func verifyAttachmentStatus(attachment *storage.VolumeAttachment, volumeHandle string) (bool, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 03 07:38:14 UTC 2023 - 25.9K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
// code to be implemented by all initializers even if the initializer does not // do mounting (like this attach/detach controller). // Issue kubernetes/kubernetes/issues/14217 to fix this. func (adc *attachDetachController) GetPluginDir(podUID string) string { return "" } func (adc *attachDetachController) GetVolumeDevicePluginDir(podUID string) string { return "" } func (adc *attachDetachController) GetPodsDir() string {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/volume/util/util.go
} // GetPluginMountDir returns the global mount directory name appended // to the given plugin name's plugin directory func GetPluginMountDir(host volume.VolumeHost, name string) string { mntDir := filepath.Join(host.GetPluginDir(name), MountsInGlobalPDPath) return mntDir } // IsLocalEphemeralVolume determines whether the argument is a local ephemeral // volume vs. some other type
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 28.8K bytes - Viewed (0) -
pkg/volume/csi/csi_attacher_test.go
if err0 != nil { t.Fatalf("failed to create new attacher: %v", err0) } csiAttacher := getCsiAttacherFromVolumeAttacher(attacher, testWatchTimeout) pluginDir := csiAttacher.plugin.host.GetPluginDir(plug.GetPluginName()) testCases := []struct { testName string pvName string volumeId string skipPVCSISource bool // The test clears PV.Spec.CSI
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 58.1K bytes - Viewed (0)