From 77dc34706ce4ee6aa410b8b6614dd125d955673b Mon Sep 17 00:00:00 2001
From: rallan <rallan@redhat.com>
Date: Mon, 11 Jun 2018 12:10:40 +0530
Subject: Pausing and resuming a geo-rep session

Change-Id: I4d2767acb4fff7ab972e11d13ef4c547914110d9
Signed-off-by: rallan <rallan@redhat.com>
---
 .../glustolibs/gluster/geo_rep_ops.py              | 63 ++++++++++++++++++++++
 1 file changed, 63 insertions(+)

(limited to 'glustolibs-gluster/glustolibs/gluster')

diff --git a/glustolibs-gluster/glustolibs/gluster/geo_rep_ops.py b/glustolibs-gluster/glustolibs/gluster/geo_rep_ops.py
index 4bb9ccd48..44a3174f8 100644
--- a/glustolibs-gluster/glustolibs/gluster/geo_rep_ops.py
+++ b/glustolibs-gluster/glustolibs/gluster/geo_rep_ops.py
@@ -108,3 +108,66 @@ def georep_create(mnode, mastervol, slaveip, slavevol, user=None, force=False):
             cmd = "gluster volume geo-replication %s %s::%s create \
                    push-pem" % (mastervol, slaveip, slavevol)
     return g.run(mnode, cmd)
+
+
+def georep_pause(mnode, mastervol, slaveip, slavevol, user=None):
+    """Pauses the geo-replication session
+    Args:
+        mnode (str): Node on which cmd is to be executed
+        mastervol (str):The name of the master volume
+        slaveip (str): SlaveIP
+        slavevol (str): The name of the slave volume
+    Kwargs:
+        user (str): If not set, the default is a root-user
+        If specified, non-root user participates in geo-rep
+        session
+    Returns:
+        tuple: Tuple containing three elements (ret, out, err).
+            The first element 'ret' is of type 'int' and is the return value
+            of command execution.
+
+            The second element 'out' is of type 'str' and is the stdout value
+            of the command execution.
+
+            The third element 'err' is of type 'str' and is the stderr value
+            of the command execution.
+    """
+    if user:
+        cmd = "gluster volume geo-replication %s %s@%s::%s \
+               pause" % (mastervol, user, slaveip, slavevol)
+    else:
+        cmd = "gluster volume geo-replication %s %s::%s \
+               pause" % (mastervol, slaveip, slavevol)
+    return g.run(mnode, cmd)
+
+
+def georep_resume(mnode, mastervol, slaveip, slavevol, user=None):
+    """Resumes the geo-replication session
+    Args:
+        mnode (str): Node on which cmd is to be executed
+        mastervol (str):The name of the master volume
+        slaveip (str): SlaveIP
+        slavevol (str): The name of the slave volume
+    Kwargs:
+        user (str): If not set, the default is a root-user
+        If specified, non-root user participates in geo-rep
+        session
+    Returns:
+        tuple: Tuple containing three elements (ret, out, err).
+            The first element 'ret' is of type 'int' and is the return value
+            of command execution.
+
+            The second element 'out' is of type 'str' and is the stdout value
+            of the command execution.
+
+            The third element 'err' is of type 'str' and is the stderr value
+            of the command execution.
+
+    """
+    if user:
+        cmd = "gluster volume geo-replication %s %s@%s::%s \
+               resume" % (mastervol, user, slaveip, slavevol)
+    else:
+        cmd = "gluster volume geo-replication %s %s::%s \
+               resume" % (mastervol, slaveip, slavevol)
+    return g.run(mnode, cmd)
-- 
cgit