1 files changed, 74 insertions, 0 deletions
diff --git a/pkg/varlinkapi/volumes.go b/pkg/varlinkapi/volumes.go
new file mode 100644
index 000000000..d41b07065
--- /dev/null
+++ b/pkg/varlinkapi/volumes.go
@@ -0,0 +1,74 @@
+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)
+}