rapi: Add /2/nodes/[node_name]/migrate resource

Signed-off-by: Michael Hanselmann <hansmi@google.com>
Reviewed-by: Iustin Pop <iustin@google.com>

diff --git a/doc/rapi.rst b/doc/rapi.rst
index b14b8f2..6ec6c6d 100644 (file)
--- a/doc/rapi.rst
+++ b/doc/rapi.rst
@@ -480,6 +480,20 @@ parameters must be passed:
     evacuate?iallocator=[iallocator]
     evacuate?remote_node=[nodeX.example.com]
 
+``/2/nodes/[node_name]/migrate``
++++++++++++++++++++++++++++++++++
+
+Migrates all primary instances from a node.
+
+It supports the following commands: ``POST``.
+
+``POST``
+~~~~~~~~
+
+No parameters are required, but ``live`` can be set to a boolean value.
+
+    migrate?live=[0|1]
+
 ``/2/nodes/[node_name]/role``
 +++++++++++++++++++++++++++++
 

diff --git a/lib/rapi/connector.py b/lib/rapi/connector.py
index 1b9d646..83c1f2e 100644 (file)
--- a/lib/rapi/connector.py
+++ b/lib/rapi/connector.py
@@ -157,6 +157,8 @@ CONNECTOR.update({
   re.compile(r'^/2/nodes/([\w\._-]+)/role$'): rlib2.R_2_nodes_name_role,
   re.compile(r'^/2/nodes/([\w\._-]+)/evacuate$'):
       rlib2.R_2_nodes_name_evacuate,
+  re.compile(r'^/2/nodes/([\w\._-]+)/migrate$'):
+      rlib2.R_2_nodes_name_migrate,
   "/2/instances": rlib2.R_2_instances,
   re.compile(r'^/2/instances/([\w\._-]+)$'): rlib2.R_2_instances_name,
   re.compile(r'^/2/instances/([\w\._-]+)/tags$'): rlib2.R_2_instances_name_tags,

diff --git a/lib/rapi/rlib2.py b/lib/rapi/rlib2.py
index 9ef6247..0da39c1 100644 (file)
--- a/lib/rapi/rlib2.py
+++ b/lib/rapi/rlib2.py
@@ -280,6 +280,22 @@ class R_2_nodes_name_evacuate(baserlib.R_Generic):
     return baserlib.SubmitJob([op])
 
 
+class R_2_nodes_name_migrate(baserlib.R_Generic):
+  """/2/nodes/[node_name]/evacuate migrate.
+
+  """
+  def POST(self):
+    """Migrate all primary instances from a node.
+
+    """
+    node_name = self.items[0]
+    live = bool(self._checkIntVariable("live", default=1))
+
+    op = opcodes.OpMigrateNode(node_name=node_name, live=live)
+
+    return baserlib.SubmitJob([op])
+
+
 class R_2_instances(baserlib.R_Generic):
   """/2/instances resource.