Add VDO feature to gdeploy

* VDO can be created and deleted from gdeploy

examples/vdo-create-with-size.conf

@@ -0,0 +1,14 @@
+# gdeploy -c vdo-create.conf
+# Creates vdo with
+#     disk => /dev/vdb and name => test_vol_1 and size => 50G
+#     disk => /dev/vdd and name => test_vol_2 and size => 100G
+# If logicalsize is omitted, entire disk is used
+
+[hosts]
+10.70.42.220
+
+[vdo]
+action=create
+devices=/dev/vdb,/dev/vdd
+names=test_vol_1,test_vol_2
+logicalsize=50G,100G

examples/vdo-create.conf

@@ -0,0 +1,14 @@
+# gdeploy -c vdo-create.conf
+# Creates vdo with
+#     disk => /dev/vdb and name => test_vol_1
+#     disk => /dev/vdd and name => test_vol_2
+# vdo is created on entire disk
+
+[hosts]
+10.70.42.220
+
+[vdo]
+action=create
+devices=/dev/vdb,/dev/vdd
+names=test_vol_1,test_vol_2
+

examples/vdo-delete.conf

@@ -0,0 +1,10 @@
+# gdeploy -c vdo-delete.conf
+# Delete the vdos test_vol_1 and test_vol_2
+
+[hosts]
+10.70.42.220
+
+[vdo]
+action=delete
+names=test_vol_1,test_vol_2
+

gdeployfeatures/__init__.py

@@ -19,3 +19,4 @@
 import vg
 import lv
 import openshift_ctl
+import vdo

gdeployfeatures/vdo/__init__.py

@@ -0,0 +1 @@
+import vdo

gdeployfeatures/vdo/vdo.json

@@ -0,0 +1,112 @@
+{
+  "vdo": {
+    "action": {
+      "create": {
+        "options": [
+          {
+            "required": "false",
+            "name": "names"
+          },
+          {
+            "required": "true",
+            "name": "devices"
+          },
+          {
+            "required": "false",
+            "name": "activate",
+            "default": "yes"
+          },
+          {
+            "required": "false",
+            "name": "run",
+            "default": "yes"
+          },
+          {
+            "required": "false",
+            "name": "logicalsize"
+          },
+          {
+            "required": "false",
+            "name": "compression",
+            "default": "enabled"
+          },
+          {
+            "required": "no",
+            "name": "blockmapcachesize"
+          },
+          {
+            "required": "no",
+            "name": "readcache",
+            "default": "enabled"
+          },
+          {
+            "name": "readcachesize",
+            "required": "false"
+          },
+          {
+            "name": "emulate512",
+            "required": "false",
+            "default": "disabled"
+          },
+          {
+            "name": "slabsize",
+            "required": "no"
+          },
+          {
+            "name": "writepolicy",
+            "required": "false"
+          },
+          {
+            "name": "indexmem",
+            "required": "false"
+          },
+          {
+            "name": "indexmode",
+            "required": "false"
+          },
+          {
+            "required": "false",
+            "name": "ackthreads"
+          },
+          {
+            "required": "false",
+            "name": "biothreads"
+          },
+          {
+            "required": "false",
+            "name": "cputhreads"
+          },
+          {
+            "required": "false",
+            "name": "logicalthreads"
+          },
+          {
+            "required": "false",
+            "name": "physicalthreads"
+          },
+          {
+            "required": "false",
+            "name": "mkfs",
+            "default": "xfs"
+          },
+          {
+            "name": "mkfs-opts",
+            "required": "false"
+          },
+          {
+            "required": "false",
+            "name": "mount"
+          }
+        ]
+      },
+      "delete": {
+        "options": [
+          {
+            "name": "names",
+            "required": "true"
+          }
+        ]
+      }
+    }
+  }
+}

gdeployfeatures/vdo/vdo.py

@@ -0,0 +1,62 @@
+"""
+Add functions corresponding to each of the actions in the json file.
+The function should be named as follows <feature name>_<action_name>
+"""
+from gdeploylib import defaults, Helpers, Global
+helpers = Helpers()
+
+def vdo_create(section_dict):
+    global helpers
+
+    section_dict['state'] = 'present'
+    disks = helpers.correct_brick_format(
+        helpers.listify(section_dict['devices']))
+    vdonames = helpers.listify(section_dict.get('names'))
+    lsize = helpers.listify(section_dict.get('logicalsize'))
+
+    # Zero-fill the lszie so that logicalsize defaults to disk size if not
+    # provided.
+    for fi in range(len(vdonames) - len(lsize)):
+        lsize.append('')
+
+    vdolist = []
+    for d, n, lsize in zip(disks, vdonames, lsize):
+        v = {}
+        v['disk'] = d
+        v['name'] = n
+        v['logicalsize'] = lsize
+        vdolist.append(v)
+    section_dict['vdos'] = vdolist
+    activate = section_dict.get('activate')
+
+    if activate is None:
+        data_not_found(activate)
+    elif activate.lower() not in ['yes', 'no', 'true', 'false']:
+        log_yes_no_error(activate)
+    run = section_dict.get('run')
+    if run is None:
+        data_not_found(run)
+    elif run.lower() not in ['yes', 'no', 'true', 'false']:
+        log_yes_no_error(run)
+
+    Global.logger.info("Creating vdo volume(s) %s" % vdonames)
+    return section_dict, defaults.VDO_CREATE
+
+def vdo_delete(section_dict):
+    section_dict['state'] = 'absent'
+    section_dict['vdonames'] = helpers.listify(section_dict.get('names'))
+    Global.logger.info("Deleteing vdo volume(s) %s"% section_dict['vdonames'])
+    return section_dict, defaults.VDO_DELETE
+
+def data_not_found(item):
+    global helpers
+    msg = "Value for option %s not found." % item
+    print "Error: %s" % msg
+    Global.logger.error(msg)
+    helpers.cleanup_and_quit()
+
+def log_yes_no_error(key):
+    msg = "Error: invalid value for %s" % key
+    print msg
+    print "Possible values are 'yes', 'no', 'true', 'false'"
+    Global.logger.error(msg)

gdeploylib/defaults.py

@@ -20,9 +20,9 @@
 # ALL features
 
 feature_list = ['snapshot', 'quota', 'yum', 'geo_replication', 'ctdb',
-'firewalld', 'nfs_ganesha', 'service', 'rh_subscription', 'shell',
-'update_file', 'script', 'volume', 'peer', 'clients', 'pv', 'vg', 'lv',
-'openshift_ctl']
+                'firewalld', 'nfs_ganesha', 'service', 'rh_subscription', 'shell',
+                'update_file', 'script', 'volume', 'peer', 'clients', 'pv', 'vg', 'lv',
+                'openshift_ctl', 'vdo']
 # All the defaults values used in gdeploy
 
 
@@ -221,3 +221,7 @@
 
 # Replace brick
 REPLACE_BRICK = 'gluster-volume-replace-brick.yml'
+
+# VDO
+VDO_CREATE = 'vdo-create.yml'
+VDO_DELETE = 'vdo-delete.yml'