diff options
| author | jason | 2015-11-17 18:51:35 -0700 |
|---|---|---|
| committer | jason | 2015-11-17 18:51:35 -0700 |
| commit | 88bb176d02ce54aa6e34ccc2e560484b60f8b1b7 (patch) | |
| tree | bbc153d54473c67384d6648d227b18ac382a135b /docs | |
| parent | 5b382d406227329f5a875f408fc1c7d429b23d59 (diff) | |
| download | eventmq-88bb176d02ce54aa6e34ccc2e560484b60f8b1b7.tar.gz eventmq-88bb176d02ce54aa6e34ccc2e560484b60f8b1b7.zip | |
update documentation and theme
Diffstat (limited to 'docs')
| -rw-r--r-- | docs/conf.py | 4 | ||||
| -rw-r--r-- | docs/index.rst | 6 | ||||
| -rw-r--r-- | docs/protocol.rst | 40 | ||||
| -rw-r--r-- | docs/receiver.rst | 2 | ||||
| -rw-r--r-- | docs/router.rst | 3 |
5 files changed, 45 insertions, 10 deletions
diff --git a/docs/conf.py b/docs/conf.py index d031524..864bbcf 100644 --- a/docs/conf.py +++ b/docs/conf.py | |||
| @@ -113,8 +113,8 @@ todo_include_todos = False | |||
| 113 | 113 | ||
| 114 | # The theme to use for HTML and HTML Help pages. See the documentation for | 114 | # The theme to use for HTML and HTML Help pages. See the documentation for |
| 115 | # a list of builtin themes. | 115 | # a list of builtin themes. |
| 116 | html_theme = 'classic' | 116 | # html_theme = 'classic' |
| 117 | 117 | html_theme = 'sphinx_rtd_theme' | |
| 118 | # Theme options are theme-specific and customize the look and feel of a theme | 118 | # Theme options are theme-specific and customize the look and feel of a theme |
| 119 | # further. For a list of options available for each theme, see the | 119 | # further. For a list of options available for each theme, see the |
| 120 | # documentation. | 120 | # documentation. |
diff --git a/docs/index.rst b/docs/index.rst index 80569bc..6c9d065 100644 --- a/docs/index.rst +++ b/docs/index.rst | |||
| @@ -1,13 +1,17 @@ | |||
| 1 | Welcome to EventMQ's documentation! | 1 | Welcome to EventMQ's documentation! |
| 2 | =================================== | 2 | =================================== |
| 3 | 3 | ||
| 4 | :doc:`protocol` | ||
| 5 | |||
| 4 | Contents: | 6 | Contents: |
| 5 | 7 | ||
| 6 | .. toctree:: | 8 | .. toctree:: |
| 7 | :maxdepth: 2 | 9 | :maxdepth: 2 |
| 8 | 10 | ||
| 11 | jobmanager | ||
| 9 | receiver | 12 | receiver |
| 10 | router | 13 | router |
| 14 | sender | ||
| 11 | 15 | ||
| 12 | 16 | ||
| 13 | Indices and tables | 17 | Indices and tables |
diff --git a/docs/protocol.rst b/docs/protocol.rst index 48dcacc..ea01cf3 100644 --- a/docs/protocol.rst +++ b/docs/protocol.rst | |||
| @@ -54,7 +54,7 @@ FRAME Value Description | |||
| 54 | ====== ============== =========== | 54 | ====== ============== =========== |
| 55 | 0 _EMPTY_ leave empty | 55 | 0 _EMPTY_ leave empty |
| 56 | 1 eMQP/1.0 Protocol version | 56 | 1 eMQP/1.0 Protocol version |
| 57 | 2 READY Command | 57 | 2 READY command |
| 58 | 3 _MSGID_ A unique id for the msg | 58 | 3 _MSGID_ A unique id for the msg |
| 59 | 4 _QUEUE_NAME_ the name of the queue the worker belongs to | 59 | 4 _QUEUE_NAME_ the name of the queue the worker belongs to |
| 60 | 5 _HEADERS_ dictionary of headers. can be an empty set | 60 | 5 _HEADERS_ dictionary of headers. can be an empty set |
| @@ -70,9 +70,9 @@ FRAME Value Description | |||
| 70 | ====== ============== =========== | 70 | ====== ============== =========== |
| 71 | 0 _EMPTY_ leave empty | 71 | 0 _EMPTY_ leave empty |
| 72 | 1 eMQP/1.0 Protocol version | 72 | 1 eMQP/1.0 Protocol version |
| 73 | 2 INFORM | 73 | 2 INFORM command |
| 74 | 3 _MSGID_ A unique id for the msg | 74 | 3 _MSGID_ A unique id for the msg |
| 75 | 4 _QUEUE_NAME_ the name of the queue the worker belongs to | 75 | 4 _QUEUE_NAME_ csv seperated names of queue the worker belongs to |
| 76 | ====== ============== =========== | 76 | ====== ============== =========== |
| 77 | 77 | ||
| 78 | A **READY** frame consists of a 4-frame multipart message, formatted as follows. | 78 | A **READY** frame consists of a 4-frame multipart message, formatted as follows. |
| @@ -82,7 +82,7 @@ FRAME Value Description | |||
| 82 | ====== ============== =========== | 82 | ====== ============== =========== |
| 83 | 0 _EMPTY_ leave empty | 83 | 0 _EMPTY_ leave empty |
| 84 | 1 eMQP/1.0 Protocol version | 84 | 1 eMQP/1.0 Protocol version |
| 85 | 2 READY | 85 | 2 READY command |
| 86 | 3 _MSGID_ A unique id for the msg | 86 | 3 _MSGID_ A unique id for the msg |
| 87 | ====== ============== =========== | 87 | ====== ============== =========== |
| 88 | 88 | ||
| @@ -93,7 +93,37 @@ FRAME Value Description | |||
| 93 | ====== ============== =========== | 93 | ====== ============== =========== |
| 94 | 0 _EMPTY_ leave empty | 94 | 0 _EMPTY_ leave empty |
| 95 | 1 eMQP/1.0 Protocol version | 95 | 1 eMQP/1.0 Protocol version |
| 96 | 2 REPLY | 96 | 2 REPLY command |
| 97 | 3 _MSGID_ A unique id for the msg | 97 | 3 _MSGID_ A unique id for the msg |
| 98 | 4 _MSG_ The reply to respond with | 98 | 4 _MSG_ The reply to respond with |
| 99 | ====== ============== =========== | 99 | ====== ============== =========== |
| 100 | |||
| 101 | A **HEARTBEAT** frame consists of a | ||
| 102 | |||
| 103 | ====== ============== =========== | ||
| 104 | FRAME Value Description | ||
| 105 | ====== ============== =========== | ||
| 106 | 0 _EMPTY_ leave empty | ||
| 107 | 1 eMQP/1.0 Protocol version | ||
| 108 | 2 HEARTBEAT command | ||
| 109 | 3 _MSGID_ A unique id for the msg | ||
| 110 | ====== ============== =========== | ||
| 111 | |||
| 112 | A **DISCONNECT** frame consists of | ||
| 113 | |||
| 114 | ====== ============== =========== | ||
| 115 | FRAME Value Description | ||
| 116 | ====== ============== =========== | ||
| 117 | 0 _EMPTY_ leave empty | ||
| 118 | 1 eMQP/1.0 Protocol version | ||
| 119 | 2 DISCONNECT command | ||
| 120 | 3 _MSGID_ A unique id for the msg | ||
| 121 | ====== ============== =========== | ||
| 122 | |||
| 123 | Heartbeating | ||
| 124 | ------------ | ||
| 125 | * HEARTBEAT commands are valid at any time after an INFORM command | ||
| 126 | * Any command except DISCONNECT act as a heartbeat. Peers SHOULD NOT send HEARTBEAT commands while sending other commands. | ||
| 127 | * Both worker and broker MUST send heartbeats at regular and agreed-upon intervals. | ||
| 128 | * If the worker detects that the broker disconnected it SHOULD restart the conversation. | ||
| 129 | * If the broker detects that a worker has disconnected it should stop sending it a message of any type. | ||
diff --git a/docs/receiver.rst b/docs/receiver.rst index 1b61f63..854349c 100644 --- a/docs/receiver.rst +++ b/docs/receiver.rst | |||
| @@ -1,3 +1,3 @@ | |||
| 1 | .. automodule:: receiver | 1 | .. automodule:: eventmq.receiver |
| 2 | :members: | 2 | :members: |
| 3 | :special-members: | 3 | :special-members: |
diff --git a/docs/router.rst b/docs/router.rst index 8e17e12..9f7f576 100644 --- a/docs/router.rst +++ b/docs/router.rst | |||
| @@ -1,2 +1,3 @@ | |||
| 1 | .. automodule:: router | 1 | .. automodule:: eventmq.router |
| 2 | :members: | 2 | :members: |
| 3 | :special-members: | ||