1 files changed, 46 insertions, 0 deletions
diff --git a/libkpod/pause.go b/libkpod/pause.go
new file mode 100644
index 000000000..29871d32b
--- /dev/null
+++ b/libkpod/pause.go
@@ -0,0 +1,46 @@
+package libkpod
+
+import (
+	"github.com/kubernetes-incubator/cri-o/oci"
+	"github.com/pkg/errors"
+)
+
+// ContainerPause pauses a running container.
+func (c *ContainerServer) ContainerPause(container string) (string, error) {
+	ctr, err := c.LookupContainer(container)
+	if err != nil {
+		return "", errors.Wrapf(err, "failed to find container %s", container)
+	}
+
+	cStatus := c.runtime.ContainerStatus(ctr)
+	if cStatus.Status != oci.ContainerStatePaused {
+		if err := c.runtime.PauseContainer(ctr); err != nil {
+			return "", errors.Wrapf(err, "failed to pause container %s", ctr.ID())
+		}
+		c.ContainerStateToDisk(ctr)
+	} else {
+		return "", errors.Wrapf(err, "container %s is already paused", ctr.ID())
+	}
+
+	return ctr.ID(), nil
+}
+
+// ContainerUnpause unpauses a running container with a grace period (i.e., timeout).
+func (c *ContainerServer) ContainerUnpause(container string) (string, error) {
+	ctr, err := c.LookupContainer(container)
+	if err != nil {
+		return "", errors.Wrapf(err, "failed to find container %s", container)
+	}
+
+	cStatus := c.runtime.ContainerStatus(ctr)
+	if cStatus.Status == oci.ContainerStatePaused {
+		if err := c.runtime.UnpauseContainer(ctr); err != nil {
+			return "", errors.Wrapf(err, "failed to unpause container %s", ctr.ID())
+		}
+		c.ContainerStateToDisk(ctr)
+	} else {
+		return "", errors.Wrapf(err, "the container %s is not paused", ctr.ID())
+	}
+
+	return ctr.ID(), nil
+}