Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for AppendSpec (0.25 sec)

  1. pkg/volume/flexvolume/attacher.go

    // Attach is part of the volume.Attacher interface
    func (a *flexVolumeAttacher) Attach(spec *volume.Spec, hostName types.NodeName) (string, error) {
    
    	call := a.plugin.NewDriverCall(attachCmd)
    	call.AppendSpec(spec, a.plugin.host, nil)
    	call.Append(string(hostName))
    
    	status, err := call.Run()
    	if isCmdNotSupportedErr(err) {
    		return (*attacherDefaults)(a).Attach(spec, hostName)
    	} else if err != nil {
    		return "", err
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jul 03 23:29:42 UTC 2021
    - 3.6K bytes
    - Viewed (0)
  2. pkg/volume/flexvolume/expander.go

    )
    
    func (plugin *flexVolumePlugin) ExpandVolumeDevice(spec *volume.Spec, newSize resource.Quantity, oldSize resource.Quantity) (resource.Quantity, error) {
    	call := plugin.NewDriverCall(expandVolumeCmd)
    	call.AppendSpec(spec, plugin.host, nil)
    
    	devicePath, err := plugin.getDeviceMountPath(spec)
    	if err != nil {
    		return newSize, err
    	}
    	call.Append(devicePath)
    	call.Append(strconv.FormatInt(newSize.Value(), 10))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 14:21:44 UTC 2019
    - 2.2K bytes
    - Viewed (0)
  3. pkg/volume/flexvolume/driver-call.go

    	}
    }
    
    // Append appends arg into driver call argument list
    func (dc *DriverCall) Append(arg string) {
    	dc.args = append(dc.args, arg)
    }
    
    // AppendSpec appends volume spec to driver call argument list
    func (dc *DriverCall) AppendSpec(spec *volume.Spec, host volume.VolumeHost, extraOptions map[string]string) error {
    	optionsForDriver, err := NewOptionsForDriver(spec, host, extraOptions)
    	if err != nil {
    		return err
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 25 02:39:55 UTC 2021
    - 7.5K bytes
    - Viewed (0)
  4. pkg/volume/flexvolume/mounter.go

    		os.Remove(dir)
    		return err
    	}
    
    	// Implicit parameters
    	if mounterArgs.FsGroup != nil {
    		extraOptions[optionFSGroup] = strconv.FormatInt(int64(*mounterArgs.FsGroup), 10)
    	}
    
    	call.AppendSpec(f.spec, f.plugin.host, extraOptions)
    
    	_, err = call.Run()
    	if isCmdNotSupportedErr(err) {
    		err = (*mounterDefaults)(f).SetUpAt(dir, mounterArgs)
    	}
    
    	if err != nil {
    		os.Remove(dir)
    		return err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 03 19:34:37 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  5. pkg/volume/flexvolume/plugin.go

    }
    
    // GetVolumeName is part of the volume.VolumePlugin interface.
    func (plugin *flexVolumePlugin) GetVolumeName(spec *volume.Spec) (string, error) {
    	call := plugin.NewDriverCall(getVolumeNameCmd)
    	call.AppendSpec(spec, plugin.host, nil)
    
    	_, err := call.Run()
    	if isCmdNotSupportedErr(err) {
    		return (*pluginDefaults)(plugin).GetVolumeName(spec)
    	} else if err != nil {
    		return "", err
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 9.7K bytes
    - Viewed (0)
Back to top