Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 34 for GetVolumeName (0.18 sec)

  1. pkg/volume/configmap/configmap.go

    	plugin.host = host
    	plugin.getConfigMap = host.GetConfigMapFunc()
    	return nil
    }
    
    func (plugin *configMapPlugin) GetPluginName() string {
    	return configMapPluginName
    }
    
    func (plugin *configMapPlugin) GetVolumeName(spec *volume.Spec) (string, error) {
    	volumeSource, _ := getVolumeSource(spec)
    	if volumeSource == nil {
    		return "", fmt.Errorf("Spec does not reference a ConfigMap volume type")
    	}
    
    	return fmt.Sprintf(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 10K bytes
    - Viewed (0)
  2. pkg/volume/csi/csi_plugin.go

    	return CSIPluginName
    }
    
    // GetvolumeName returns a concatenated string of CSIVolumeSource.Driver<volNameSe>CSIVolumeSource.VolumeHandle
    // That string value is used in Detach() to extract driver name and volumeName.
    func (p *csiPlugin) GetVolumeName(spec *volume.Spec) (string, error) {
    	csi, err := getPVSourceFromSpec(spec)
    	if err != nil {
    		return "", errors.New(log("plugin.GetVolumeName failed to extract volume source from spec: %v", err))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 29.2K bytes
    - Viewed (0)
  3. pkg/volume/git_repo/git_repo.go

    	plugin.host = host
    	return nil
    }
    
    func (plugin *gitRepoPlugin) GetPluginName() string {
    	return gitRepoPluginName
    }
    
    func (plugin *gitRepoPlugin) GetVolumeName(spec *volume.Spec) (string, error) {
    	volumeSource, _ := getVolumeSource(spec)
    	if volumeSource == nil {
    		return "", fmt.Errorf("Spec does not reference a Git repo volume type")
    	}
    
    	return fmt.Sprintf(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  4. pkg/volume/nfs/nfs.go

    )
    
    func (plugin *nfsPlugin) Init(host volume.VolumeHost) error {
    	plugin.host = host
    	return nil
    }
    
    func (plugin *nfsPlugin) GetPluginName() string {
    	return nfsPluginName
    }
    
    func (plugin *nfsPlugin) GetVolumeName(spec *volume.Spec) (string, error) {
    	volumeSource, _, err := getVolumeSource(spec)
    	if err != nil {
    		return "", err
    	}
    
    	return fmt.Sprintf(
    		"%v/%v",
    		volumeSource.Server,
    		volumeSource.Path), nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  5. pkg/volume/secret/secret.go

    	plugin.host = host
    	plugin.getSecret = host.GetSecretFunc()
    	return nil
    }
    
    func (plugin *secretPlugin) GetPluginName() string {
    	return secretPluginName
    }
    
    func (plugin *secretPlugin) GetVolumeName(spec *volume.Spec) (string, error) {
    	volumeSource, _ := getVolumeSource(spec)
    	if volumeSource == nil {
    		return "", fmt.Errorf("Spec does not reference a Secret volume type")
    	}
    
    	return volumeSource.SecretName, nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  6. pkg/volume/downwardapi/downwardapi.go

    	plugin.host = host
    	return nil
    }
    
    func (plugin *downwardAPIPlugin) GetPluginName() string {
    	return downwardAPIPluginName
    }
    
    func (plugin *downwardAPIPlugin) GetVolumeName(spec *volume.Spec) (string, error) {
    	volumeSource, _ := getVolumeSource(spec)
    	if volumeSource == nil {
    		return "", fmt.Errorf("Spec does not reference a DownwardAPI volume type")
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  7. pkg/volume/testing/testing.go

    	Plugin FakeVolumePlugin
    }
    
    func (f *FakeBasicVolumePlugin) GetPluginName() string {
    	return f.Plugin.GetPluginName()
    }
    
    func (f *FakeBasicVolumePlugin) GetVolumeName(spec *volume.Spec) (string, error) {
    	return f.Plugin.GetVolumeName(spec)
    }
    
    // CanSupport tests whether the plugin supports a given volume specification by
    // testing volume spec name begins with plugin name or not.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 12:32:15 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  8. pkg/volume/portworx/portworx.go

    		portworxClient: client,
    	}
    
    	return nil
    }
    
    func (plugin *portworxVolumePlugin) GetPluginName() string {
    	return portworxVolumePluginName
    }
    
    func (plugin *portworxVolumePlugin) GetVolumeName(spec *volume.Spec) (string, error) {
    	volumeSource, _, err := getVolumeSource(spec)
    	if err != nil {
    		return "", err
    	}
    
    	return volumeSource.VolumeID, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  9. pkg/volume/projected/projected.go

    	plugin.deleteServiceAccountToken = host.DeleteServiceAccountTokenFunc()
    	return nil
    }
    
    func (plugin *projectedPlugin) GetPluginName() string {
    	return projectedPluginName
    }
    
    func (plugin *projectedPlugin) GetVolumeName(spec *volume.Spec) (string, error) {
    	_, _, err := getVolumeSource(spec)
    	if err != nil {
    		return "", err
    	}
    
    	return spec.Name(), nil
    }
    
    func (plugin *projectedPlugin) CanSupport(spec *volume.Spec) bool {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  10. pkg/volume/volume.go

    // Detacher can detach a volume from a node.
    type Detacher interface {
    	DeviceUnmounter
    	// Detach the given volume from the node with the given Name.
    	// volumeName is name of the volume as returned from plugin's
    	// GetVolumeName().
    	Detach(volumeName string, nodeName types.NodeName) error
    }
    
    // DeviceUnmounter can unmount a block volume from the global path.
    type DeviceUnmounter interface {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 11.8K bytes
    - Viewed (0)
Back to top