Skip to content

Commit 5011a0c

Browse files
committed
add properly DMS docs
1 parent ec25ac5 commit 5011a0c

5 files changed

Lines changed: 81 additions & 7 deletions

File tree

doc/source/cli/dms.rst

Lines changed: 36 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,36 @@
1+
=====================================================
2+
Distributed Message Service (DMS) command-line client
3+
=====================================================
4+
5+
The DMS client is the command-line interface (CLI) for
6+
the Distributed Message Service (DMS) API and its extensions.
7+
8+
For help on a specific `dms` command, enter:
9+
10+
.. code-block:: console
11+
12+
$ openstack dms help SUBCOMMAND
13+
14+
.. _dms_queue:
15+
16+
Queue operations
17+
----------------
18+
19+
.. autoprogram-cliff:: openstack.dms.v1
20+
:command: dms queue *
21+
22+
.. _dms_group:
23+
24+
Group operations
25+
----------------
26+
27+
.. autoprogram-cliff:: openstack.dms.v1
28+
:command: dms group *
29+
30+
.. _dms_quota:
31+
32+
Quota operations
33+
----------------
34+
35+
.. autoprogram-cliff:: openstack.dms.v1
36+
:command: dms quota *

doc/source/cli/index.rst

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,3 +7,4 @@
77
cce.rst
88
load_balancer.rst
99
volume_backup.rst
10+
dms.rst

doc/source/user/index.rst

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -125,6 +125,7 @@ control which services can be used.
125125
Key Management Service <proxies/kms>
126126
Cloud Container Engine <proxies/cce>
127127
Volume Backup Service <proxies/volume_backup>
128+
Distributed Message Service <proxies/dms>
128129

129130
Resource Interface
130131
~~~~~~~~~~~~~~~~~~

doc/source/user/proxies/dms.rst

Lines changed: 38 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,38 @@
1+
DMS API
2+
=======
3+
4+
.. automodule:: otcextensions.sdk.dms.v1._proxy
5+
6+
The Distributed Message Service Class
7+
-------------------------------------
8+
9+
The dms high-level interface is available through the ``dms``
10+
member of a :class:`~openstack.connection.Connection` object. The
11+
``dms`` member will only be added if the ``otcextensions.sdk.register_otc_extensions(conn)`` method is called.
12+
13+
Queue Operations
14+
^^^^^^^^^^^^^^^^
15+
16+
.. autoclass:: otcextensions.sdk.dms.v1._proxy.Proxy
17+
18+
.. automethod:: otcextensions.sdk.dms.v1._proxy.Proxy.queues
19+
.. automethod:: otcextensions.sdk.dms.v1._proxy.Proxy.create_queue
20+
.. automethod:: otcextensions.sdk.dms.v1._proxy.Proxy.get_queue
21+
.. automethod:: otcextensions.sdk.dms.v1._proxy.Proxy.delete_queue
22+
23+
24+
Message Group Operations
25+
^^^^^^^^^^^^^^^^^^^^^^^^
26+
27+
.. autoclass:: otcextensions.sdk.dms.v1._proxy.Proxy
28+
29+
.. automethod:: otcextensions.sdk.dms.v1._proxy.Proxy.groups
30+
.. automethod:: otcextensions.sdk.dms.v1._proxy.Proxy.create_group
31+
.. automethod:: otcextensions.sdk.dms.v1._proxy.Proxy.delete_group
32+
33+
DMS Quota Operations
34+
^^^^^^^^^^^^^^^^^^^^
35+
36+
.. autoclass:: otcextensions.sdk.dms.v1._proxy.Proxy
37+
38+
.. automethod:: otcextensions.sdk.dms.v1._proxy.Proxy.quotas

otcextensions/sdk/dms/v1/_proxy.py

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -26,15 +26,14 @@ def create_queue(self, **kwargs):
2626
2727
:param dict kwargs: Keyword arguments which will be used to overwrite a
2828
:class:`~otcextensions.sdk.dms.v1.queue.Queue`
29-
::rtype: :class:`~otcextensions.sdk.dms.v1.queue.Queue`
3029
"""
3130
return self._create(_queue.Queue, **kwargs)
3231

3332
def queues(self):
3433
"""List all queues
3534
36-
:returns: A generator of Queue object
37-
::rtype: :class:`~otcextensions.sdk.dms.v1.queue.Queue`
35+
:returns: A generator of Queue object of
36+
:class:`~otcextensions.sdk.dms.v1.queue.Queue`
3837
"""
3938
return self._list(_queue.Queue, paginated=False)
4039

@@ -45,7 +44,6 @@ def get_queue(self, queue):
4544
:class:`~otcextensions.sdk.dms.v1.queue.Queue`
4645
:returns: one object of class
4746
:class:`~otcextensions.sdk.dms.v1.queue.Queue`
48-
::rtype: :class:`~otcextensions.sdk.dms.v1.queue.Queue`
4947
"""
5048
return self._get(_queue.Queue, queue)
5149

@@ -57,7 +55,7 @@ def delete_queue(self, queue, ignore_missing=True):
5755
:param bool ignore_missing: When set to ``False``
5856
:class:`~otcextensions.sdk.exceptions.ResourceNotFound` will be
5957
raised when the queue does not exist.
60-
:returns: ``None``
58+
:returns: `None`
6159
"""
6260

6361
self._delete(_queue.Queue, queue, ignore_missing=ignore_missing)
@@ -89,7 +87,7 @@ def groups(self, queue, include_deadletter=False):
8987
:param queue: The queue id or an instance of
9088
:class:`~otcextensions.sdk.dms.v1.queue.Queue`
9189
:returns: A generator of Group object
92-
::rtype: :class:`~otcextensions.sdk.dms.v1.queue.Group`
90+
:rtype: :class:`~otcextensions.sdk.dms.v1.queue.Group`
9391
"""
9492
queue_id = queue
9593
if isinstance(queue, _queue.Queue):
@@ -170,6 +168,6 @@ def quotas(self):
170168
"""List quota
171169
172170
:returns: A generator of Quota object
173-
::rtype: :class:`~otcextensions.sdk.dms.v1.quota.Quota`
171+
:rtype: :class:`~otcextensions.sdk.dms.v1.quota.Quota`
174172
"""
175173
return self._list(_quota.Quota)

0 commit comments

Comments
 (0)