Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 18 of 18 for GetPluginDir (0.25 sec)

  1. 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)
  2. 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)
  3. 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)
  4. pkg/volume/iscsi/iscsi.go

    		return volume.ReconstructedVolume{}, err
    	}
    	if err != nil {
    		return volume.ReconstructedVolume{}, err
    	}
    
    	for _, path := range paths {
    		if strings.Contains(path, plugin.host.GetPluginDir(iscsiPluginName)) {
    			globalPDPath = path
    			break
    		}
    	}
    	// Couldn't fetch globalPDPath
    	if len(globalPDPath) == 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
Back to top