1 files changed, 132 insertions, 1 deletions
diff --git a/cinderclient/v3/consistencygroups.py b/cinderclient/v3/consistencygroups.py
index a29fd83..13bc2ee 100644
--- a/cinderclient/v3/consistencygroups.py
+++ b/cinderclient/v3/consistencygroups.py
@@ -15,4 +15,135 @@
 
 """Consistencygroup interface (v3 extension)."""
 
-from cinderclient.v2.consistencygroups import *  # noqa
+from cinderclient.apiclient import base as common_base
+from cinderclient import base
+from cinderclient import utils
+
+
+class Consistencygroup(base.Resource):
+    """A Consistencygroup of volumes."""
+    def __repr__(self):
+        return "<Consistencygroup: %s>" % self.id
+
+    def delete(self, force='False'):
+        """Delete this consistency group."""
+        return self.manager.delete(self, force)
+
+    def update(self, **kwargs):
+        """Update the name or description for this consistency group."""
+        return self.manager.update(self, **kwargs)
+
+
+class ConsistencygroupManager(base.ManagerWithFind):
+    """Manage :class:`Consistencygroup` resources."""
+    resource_class = Consistencygroup
+
+    def create(self, volume_types, name=None,
+               description=None, user_id=None,
+               project_id=None, availability_zone=None):
+        """Creates a consistency group.
+
+        :param name: Name of the ConsistencyGroup
+        :param description: Description of the ConsistencyGroup
+        :param volume_types: Types of volume
+        :param user_id: User id derived from context
+        :param project_id: Project id derived from context
+        :param availability_zone: Availability Zone to use
+        :rtype: :class:`Consistencygroup`
+       """
+
+        body = {'consistencygroup': {'name': name,
+                                     'description': description,
+                                     'volume_types': volume_types,
+                                     'user_id': user_id,
+                                     'project_id': project_id,
+                                     'availability_zone': availability_zone,
+                                     'status': "creating",
+                                     }}
+
+        return self._create('/consistencygroups', body, 'consistencygroup')
+
+    def create_from_src(self, cgsnapshot_id, source_cgid, name=None,
+                        description=None, user_id=None,
+                        project_id=None):
+        """Creates a consistency group from a cgsnapshot or a source CG.
+
+        :param cgsnapshot_id: UUID of a CGSnapshot
+        :param source_cgid: UUID of a source CG
+        :param name: Name of the ConsistencyGroup
+        :param description: Description of the ConsistencyGroup
+        :param user_id: User id derived from context
+        :param project_id: Project id derived from context
+        :rtype: A dictionary containing Consistencygroup metadata
+        """
+        body = {'consistencygroup-from-src': {'name': name,
+                                              'description': description,
+                                              'cgsnapshot_id': cgsnapshot_id,
+                                              'source_cgid': source_cgid,
+                                              'user_id': user_id,
+                                              'project_id': project_id,
+                                              'status': "creating",
+                                              }}
+
+        self.run_hooks('modify_body_for_update', body,
+                       'consistencygroup-from-src')
+        resp, body = self.api.client.post(
+            "/consistencygroups/create_from_src", body=body)
+        return common_base.DictWithMeta(body['consistencygroup'], resp)
+
+    def get(self, group_id):
+        """Get a consistency group.
+
+        :param group_id: The ID of the consistency group to get.
+        :rtype: :class:`Consistencygroup`
+        """
+        return self._get("/consistencygroups/%s" % group_id,
+                         "consistencygroup")
+
+    def list(self, detailed=True, search_opts=None):
+        """Lists all consistency groups.
+
+        :rtype: list of :class:`Consistencygroup`
+        """
+
+        query_string = utils.build_query_param(search_opts)
+
+        detail = ""
+        if detailed:
+            detail = "/detail"
+
+        return self._list("/consistencygroups%s%s" % (detail, query_string),
+                          "consistencygroups")
+
+    def delete(self, consistencygroup, force=False):
+        """Delete a consistency group.
+
+        :param Consistencygroup: The :class:`Consistencygroup` to delete.
+        """
+        body = {'consistencygroup': {'force': force}}
+        self.run_hooks('modify_body_for_action', body, 'consistencygroup')
+        url = '/consistencygroups/%s/delete' % base.getid(consistencygroup)
+        resp, body = self.api.client.post(url, body=body)
+        return common_base.TupleWithMeta((resp, body), resp)
+
+    def update(self, consistencygroup, **kwargs):
+        """Update the name or description for a consistency group.
+
+        :param Consistencygroup: The :class:`Consistencygroup` to update.
+        """
+        if not kwargs:
+            return
+
+        body = {"consistencygroup": kwargs}
+
+        return self._update("/consistencygroups/%s" %
+                            base.getid(consistencygroup), body)
+
+    def _action(self, action, consistencygroup, info=None, **kwargs):
+        """Perform a consistency group "action."
+        """
+        body = {action: info}
+        self.run_hooks('modify_body_for_action', body, **kwargs)
+        url = '/consistencygroups/%s/action' % base.getid(consistencygroup)
+        resp, body = self.api.client.post(url, body=body)
+        return common_base.TupleWithMeta((resp, body), resp)