package varlinkapi import ( "github.com/containers/libpod/cmd/podman/varlink" "github.com/containers/libpod/libpod" ) // VolumeCreate creates a libpod volume based on input from a varlink connection func (i *LibpodAPI) VolumeCreate(call iopodman.VarlinkCall, options iopodman.VolumeCreateOpts) error { var volumeOptions []libpod.VolumeCreateOption if len(options.VolumeName) > 0 { volumeOptions = append(volumeOptions, libpod.WithVolumeName(options.VolumeName)) } if len(options.Driver) > 0 { volumeOptions = append(volumeOptions, libpod.WithVolumeDriver(options.Driver)) } if len(options.Labels) > 0 { volumeOptions = append(volumeOptions, libpod.WithVolumeLabels(options.Labels)) } if len(options.Options) > 0 { volumeOptions = append(volumeOptions, libpod.WithVolumeOptions(options.Options)) } newVolume, err := i.Runtime.NewVolume(getContext(), volumeOptions...) if err != nil { return call.ReplyErrorOccurred(err.Error()) } return call.ReplyVolumeCreate(newVolume.Name()) } // VolumeRemove removes volumes by options.All or options.Volumes func (i *LibpodAPI) VolumeRemove(call iopodman.VarlinkCall, options iopodman.VolumeRemoveOpts) error { deletedVolumes, err := i.Runtime.RemoveVolumes(getContext(), options.Volumes, options.All, options.Force) if err != nil { return call.ReplyErrorOccurred(err.Error()) } return call.ReplyVolumeRemove(deletedVolumes) } // GetVolumes returns all the volumes known to the remote system func (i *LibpodAPI) GetVolumes(call iopodman.VarlinkCall, args []string, all bool) error { var ( err error reply []*libpod.Volume volumes []iopodman.Volume ) if all { reply, err = i.Runtime.GetAllVolumes() } else { for _, v := range args { vol, err := i.Runtime.GetVolume(v) if err != nil { return err } reply = append(reply, vol) } } if err != nil { return call.ReplyErrorOccurred(err.Error()) } // Build the iopodman.volume struct for the return for _, v := range reply { newVol := iopodman.Volume{ Driver: v.Driver(), Labels: v.Labels(), MountPoint: v.MountPoint(), Name: v.Name(), Options: v.Options(), Scope: v.Scope(), } volumes = append(volumes, newVol) } return call.ReplyGetVolumes(volumes) }