- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for AppendSpec (0.25 sec)
-
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) -
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) -
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) -
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) -
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)