diff --git a/doc/source/users/proxies/cluster.rst b/doc/source/users/proxies/cluster.rst
index d4072100..fe5c502e 100644
--- a/doc/source/users/proxies/cluster.rst
+++ b/doc/source/users/proxies/cluster.rst
@@ -156,3 +156,12 @@ Event Operations
 
    .. automethod:: openstack.cluster.v1._proxy.Proxy.get_event
    .. automethod:: openstack.cluster.v1._proxy.Proxy.events
+
+
+Helper Operations
+^^^^^^^^^^^^^^^^^
+
+.. autoclass:: openstack.cluster.v1._proxy.Proxy
+
+   .. automethod:: openstack.cluster.v1._proxy.Proxy.wait_for_delete
+   .. automethod:: openstack.cluster.v1._proxy.Proxy.wait_for_status
diff --git a/openstack/cluster/v1/_proxy.py b/openstack/cluster/v1/_proxy.py
index 9a517aeb..5621be5b 100644
--- a/openstack/cluster/v1/_proxy.py
+++ b/openstack/cluster/v1/_proxy.py
@@ -1042,3 +1042,43 @@ class Proxy(proxy2.BaseProxy):
         :returns: A generator of event instances.
         """
         return self._list(_event.Event, paginated=True, **query)
+
+    def wait_for_status(self, resource, status, failures=[], interval=2,
+                        wait=120):
+        """Wait for a resource to be in a particular status.
+
+        :param resource: The resource to wait on to reach the specified status.
+                         The resource must have a ``status`` attribute.
+        :type resource: A :class:`~openstack.resource2.Resource` object.
+        :param status: Desired status.
+        :param list failures: Statuses that would be interpreted as failures.
+        :param interval: Number of seconds to wait before to consecutive
+                         checks. Default to 2.
+        :param wait: Maximum number of seconds to wait before the change.
+                     Default to 120.
+        :returns: The resource is returned on success.
+        :raises: :class:`~openstack.exceptions.ResourceTimeout` if transition
+                 to the desired status failed to occur in specified seconds.
+        :raises: :class:`~openstack.exceptions.ResourceFailure` if the resource
+                 has transited to one of the failure statuses.
+        :raises: :class:`~AttributeError` if the resource does not have a
+                ``status`` attribute.
+        """
+        return resource2.wait_for_status(self._session, resource, status,
+                                         failures, interval, wait)
+
+    def wait_for_delete(self, resource, interval=2, wait=120):
+        """Wait for a resource to be deleted.
+
+        :param resource: The resource to wait on to be deleted.
+        :type resource: A :class:`~openstack.resource2.Resource` object.
+        :param interval: Number of seconds to wait before to consecutive
+                         checks. Default to 2.
+        :param wait: Maximum number of seconds to wait before the change.
+                     Default to 120.
+        :returns: The resource is returned on success.
+        :raises: :class:`~openstack.exceptions.ResourceTimeout` if transition
+                 to delete failed to occur in the specified seconds.
+        """
+        return resource2.wait_for_delete(self._session, resource, interval,
+                                         wait)
diff --git a/openstack/tests/unit/cluster/v1/test_proxy.py b/openstack/tests/unit/cluster/v1/test_proxy.py
index 10b7cae8..0e7992d3 100644
--- a/openstack/tests/unit/cluster/v1/test_proxy.py
+++ b/openstack/tests/unit/cluster/v1/test_proxy.py
@@ -497,3 +497,41 @@ class TestClusterProxy(test_proxy_base2.TestProxyBase):
                          paginated=True,
                          method_kwargs={'limit': 2},
                          expected_kwargs={'limit': 2})
+
+    @mock.patch("openstack.resource2.wait_for_status")
+    def test_wait_for(self, mock_wait):
+        mock_resource = mock.Mock()
+        mock_wait.return_value = mock_resource
+
+        self.proxy.wait_for_status(mock_resource, 'ACTIVE')
+
+        mock_wait.assert_called_once_with(self.session, mock_resource,
+                                          'ACTIVE', [], 2, 120)
+
+    @mock.patch("openstack.resource2.wait_for_status")
+    def test_wait_for_params(self, mock_wait):
+        mock_resource = mock.Mock()
+        mock_wait.return_value = mock_resource
+
+        self.proxy.wait_for_status(mock_resource, 'ACTIVE', ['ERROR'], 1, 2)
+
+        mock_wait.assert_called_once_with(self.session, mock_resource,
+                                          'ACTIVE', ['ERROR'], 1, 2)
+
+    @mock.patch("openstack.resource2.wait_for_delete")
+    def test_wait_for_delete(self, mock_wait):
+        mock_resource = mock.Mock()
+        mock_wait.return_value = mock_resource
+
+        self.proxy.wait_for_delete(mock_resource)
+
+        mock_wait.assert_called_once_with(self.session, mock_resource, 2, 120)
+
+    @mock.patch("openstack.resource2.wait_for_delete")
+    def test_wait_for_delete_params(self, mock_wait):
+        mock_resource = mock.Mock()
+        mock_wait.return_value = mock_resource
+
+        self.proxy.wait_for_delete(mock_resource, 1, 2)
+
+        mock_wait.assert_called_once_with(self.session, mock_resource, 1, 2)