diff options
| author | jason | 2017-01-23 20:18:42 -0700 |
|---|---|---|
| committer | jason | 2017-01-23 20:18:42 -0700 |
| commit | f3c64b9a0837dd03584b67179267e1e0ca8edadd (patch) | |
| tree | 4b282f228902334e13415547f9d3ff8e9889d0d4 /router.html | |
| parent | 4780da086a62543c2bfbf0b98cabc181c4420244 (diff) | |
| download | eventmq-f3c64b9a0837dd03584b67179267e1e0ca8edadd.tar.gz eventmq-f3c64b9a0837dd03584b67179267e1e0ca8edadd.zip | |
update docs
Diffstat (limited to 'router.html')
| -rwxr-xr-x[-rw-r--r--] | router.html | 68 |
1 files changed, 32 insertions, 36 deletions
diff --git a/router.html b/router.html index 805edec..0db5b9e 100644..100755 --- a/router.html +++ b/router.html | |||
| @@ -30,6 +30,9 @@ | |||
| 30 | 30 | ||
| 31 | 31 | ||
| 32 | 32 | ||
| 33 | <link rel="index" title="Index" | ||
| 34 | href="genindex.html"/> | ||
| 35 | <link rel="search" title="Search" href="search.html"/> | ||
| 33 | <link rel="top" title="EventMQ 0 documentation" href="index.html"/> | 36 | <link rel="top" title="EventMQ 0 documentation" href="index.html"/> |
| 34 | <link rel="up" title="API Documentation" href="api.html"/> | 37 | <link rel="up" title="API Documentation" href="api.html"/> |
| 35 | <link rel="next" title="sender – Sender" href="sender.html"/> | 38 | <link rel="next" title="sender – Sender" href="sender.html"/> |
| @@ -61,7 +64,7 @@ | |||
| 61 | 64 | ||
| 62 | 65 | ||
| 63 | <div class="version"> | 66 | <div class="version"> |
| 64 | 0.2.7.1 | 67 | 0.3-rc8 |
| 65 | </div> | 68 | </div> |
| 66 | 69 | ||
| 67 | 70 | ||
| @@ -90,7 +93,7 @@ | |||
| 90 | <li class="toctree-l2"><a class="reference internal" href="jobmanager.html"><code class="docutils literal"><span class="pre">jobmanager</span></code> – Job Manager</a></li> | 93 | <li class="toctree-l2"><a class="reference internal" href="jobmanager.html"><code class="docutils literal"><span class="pre">jobmanager</span></code> – Job Manager</a></li> |
| 91 | <li class="toctree-l2"><a class="reference internal" href="poller.html"><code class="docutils literal"><span class="pre">poller</span></code> – Poller</a></li> | 94 | <li class="toctree-l2"><a class="reference internal" href="poller.html"><code class="docutils literal"><span class="pre">poller</span></code> – Poller</a></li> |
| 92 | <li class="toctree-l2"><a class="reference internal" href="receiver.html"><code class="docutils literal"><span class="pre">receiver</span></code> – Receiver</a></li> | 95 | <li class="toctree-l2"><a class="reference internal" href="receiver.html"><code class="docutils literal"><span class="pre">receiver</span></code> – Receiver</a></li> |
| 93 | <li class="toctree-l2 current"><a class="current reference internal" href=""><code class="docutils literal"><span class="pre">router</span></code> – Router</a></li> | 96 | <li class="toctree-l2 current"><a class="current reference internal" href="#"><code class="docutils literal"><span class="pre">router</span></code> – Router</a></li> |
| 94 | <li class="toctree-l2"><a class="reference internal" href="sender.html"><code class="docutils literal"><span class="pre">sender</span></code> – Sender</a></li> | 97 | <li class="toctree-l2"><a class="reference internal" href="sender.html"><code class="docutils literal"><span class="pre">sender</span></code> – Sender</a></li> |
| 95 | <li class="toctree-l2"><a class="reference internal" href="utils/index.html"><code class="docutils literal"><span class="pre">utils</span></code> – Utilities</a></li> | 98 | <li class="toctree-l2"><a class="reference internal" href="utils/index.html"><code class="docutils literal"><span class="pre">utils</span></code> – Utilities</a></li> |
| 96 | </ul> | 99 | </ul> |
| @@ -118,7 +121,7 @@ | |||
| 118 | <div class="rst-content"> | 121 | <div class="rst-content"> |
| 119 | 122 | ||
| 120 | 123 | ||
| 121 | 124 | ||
| 122 | 125 | ||
| 123 | 126 | ||
| 124 | 127 | ||
| @@ -132,7 +135,7 @@ | |||
| 132 | <li class="wy-breadcrumbs-aside"> | 135 | <li class="wy-breadcrumbs-aside"> |
| 133 | 136 | ||
| 134 | 137 | ||
| 135 | <a href="_sources/router.txt" rel="nofollow"> View page source</a> | 138 | <a href="_sources/router.rst.txt" rel="nofollow"> View page source</a> |
| 136 | 139 | ||
| 137 | 140 | ||
| 138 | </li> | 141 | </li> |
| @@ -157,7 +160,7 @@ | |||
| 157 | <col class="field-name" /> | 160 | <col class="field-name" /> |
| 158 | <col class="field-body" /> | 161 | <col class="field-body" /> |
| 159 | <tbody valign="top"> | 162 | <tbody valign="top"> |
| 160 | <tr class="field-odd field"><th class="field-name">Parameters:</th><td class="field-body"><strong>scheduler_id</strong> (<a class="reference external" href="https://docs.python.org/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – unique id of the scheduler to add</td> | 163 | <tr class="field-odd field"><th class="field-name">Parameters:</th><td class="field-body"><strong>scheduler_id</strong> (<a class="reference external" href="https://docs.python.org/2/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – unique id of the scheduler to add</td> |
| 161 | </tr> | 164 | </tr> |
| 162 | </tbody> | 165 | </tbody> |
| 163 | </table> | 166 | </table> |
| @@ -172,7 +175,7 @@ | |||
| 172 | <col class="field-body" /> | 175 | <col class="field-body" /> |
| 173 | <tbody valign="top"> | 176 | <tbody valign="top"> |
| 174 | <tr class="field-odd field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first last simple"> | 177 | <tr class="field-odd field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first last simple"> |
| 175 | <li><strong>worker_id</strong> (<a class="reference external" href="https://docs.python.org/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – unique id of the worker to add</li> | 178 | <li><strong>worker_id</strong> (<a class="reference external" href="https://docs.python.org/2/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – unique id of the worker to add</li> |
| 176 | <li><strong>queues</strong> – queue or queues this worker should be a member of</li> | 179 | <li><strong>queues</strong> – queue or queues this worker should be a member of</li> |
| 177 | </ul> | 180 | </ul> |
| 178 | </td> | 181 | </td> |
| @@ -212,15 +215,13 @@ queue.</p> | |||
| 212 | <col class="field-name" /> | 215 | <col class="field-name" /> |
| 213 | <col class="field-body" /> | 216 | <col class="field-body" /> |
| 214 | <tbody valign="top"> | 217 | <tbody valign="top"> |
| 215 | <tr class="field-odd field"><th class="field-name">Parameters:</th><td class="field-body"><p class="first"><strong>queue_name</strong> (<a class="reference external" href="https://docs.python.org/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – Name of the queue</p> | 218 | <tr class="field-odd field"><th class="field-name">Parameters:</th><td class="field-body"><p class="first"><strong>queue_name</strong> (<a class="reference external" href="https://docs.python.org/2/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – Name of the queue</p> |
| 216 | </td> | 219 | </td> |
| 217 | </tr> | 220 | </tr> |
| 218 | <tr class="field-even field"><th class="field-name">Raises:</th><td class="field-body"><ul class="first simple"> | 221 | <tr class="field-even field"><th class="field-name">Raises:</th><td class="field-body"><ul class="first simple"> |
| 219 | <li><code class="xref py py-exc docutils literal"><span class="pre">NoAvailableWorkerSlotsError</span></code> – | 222 | <li><code class="xref py py-exc docutils literal"><span class="pre">NoAvailableWorkerSlotsError</span></code> – Raised when there are no available</li> |
| 220 | Raised when there are no available</li> | 223 | <li>slots in any the job managers.</li> |
| 221 | <li><strong>slots in any the job managers.</strong> –</li> | 224 | <li><code class="xref py py-exc docutils literal"><span class="pre">UnknownQueueError</span></code> – Raised when <code class="docutils literal"><span class="pre">queue_name</span></code> is not found in |
| 222 | <li><code class="xref py py-exc docutils literal"><span class="pre">UnknownQueueError</span></code> – | ||
| 223 | Raised when <code class="docutils literal"><span class="pre">queue_name</span></code> is not found in | ||
| 224 | self.queues</li> | 225 | self.queues</li> |
| 225 | </ul> | 226 | </ul> |
| 226 | </td> | 227 | </td> |
| @@ -228,7 +229,7 @@ self.queues</li> | |||
| 228 | <tr class="field-odd field"><th class="field-name">Returns:</th><td class="field-body"><p class="first">uuid of the job manager with an available worker slot</p> | 229 | <tr class="field-odd field"><th class="field-name">Returns:</th><td class="field-body"><p class="first">uuid of the job manager with an available worker slot</p> |
| 229 | </td> | 230 | </td> |
| 230 | </tr> | 231 | </tr> |
| 231 | <tr class="field-even field"><th class="field-name">Return type:</th><td class="field-body"><p class="first last">(str)</p> | 232 | <tr class="field-even field"><th class="field-name">Return type:</th><td class="field-body"><p class="first last">(<a class="reference external" href="https://docs.python.org/2/library/functions.html#str" title="(in Python v2.7)">str</a>)</p> |
| 232 | </td> | 233 | </td> |
| 233 | </tr> | 234 | </tr> |
| 234 | </tbody> | 235 | </tbody> |
| @@ -238,14 +239,10 @@ self.queues</li> | |||
| 238 | <dl class="method"> | 239 | <dl class="method"> |
| 239 | <dt id="eventmq.router.Router.get_status"> | 240 | <dt id="eventmq.router.Router.get_status"> |
| 240 | <code class="descname">get_status</code><span class="sig-paren">(</span><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.router.Router.get_status" title="Permalink to this definition">¶</a></dt> | 241 | <code class="descname">get_status</code><span class="sig-paren">(</span><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.router.Router.get_status" title="Permalink to this definition">¶</a></dt> |
| 241 | <dd><table class="docutils field-list" frame="void" rules="none"> | 242 | <dd><dl class="docutils"> |
| 242 | <col class="field-name" /> | 243 | <dt>Return</dt> |
| 243 | <col class="field-body" /> | 244 | <dd>(str) Serialized information about the current state of the router.</dd> |
| 244 | <tbody valign="top"> | 245 | </dl> |
| 245 | <tr class="field-odd field"><th class="field-name">Returns:</th><td class="field-body">(str) Serialized information about the current state of the router.</td> | ||
| 246 | </tr> | ||
| 247 | </tbody> | ||
| 248 | </table> | ||
| 249 | </dd></dl> | 246 | </dd></dl> |
| 250 | 247 | ||
| 251 | <dl class="attribute"> | 248 | <dl class="attribute"> |
| @@ -287,8 +284,8 @@ and announces itself.</p> | |||
| 287 | <col class="field-body" /> | 284 | <col class="field-body" /> |
| 288 | <tbody valign="top"> | 285 | <tbody valign="top"> |
| 289 | <tr class="field-odd field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first last simple"> | 286 | <tr class="field-odd field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first last simple"> |
| 290 | <li><strong>sender</strong> (<a class="reference external" href="https://docs.python.org/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – The id of the sender</li> | 287 | <li><strong>sender</strong> (<a class="reference external" href="https://docs.python.org/2/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – The id of the sender</li> |
| 291 | <li><strong>msgid</strong> (<a class="reference external" href="https://docs.python.org/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – Unique identifier for this message</li> | 288 | <li><strong>msgid</strong> (<a class="reference external" href="https://docs.python.org/2/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – Unique identifier for this message</li> |
| 292 | <li><strong>msg</strong> – The actual message that was sent</li> | 289 | <li><strong>msg</strong> – The actual message that was sent</li> |
| 293 | </ul> | 290 | </ul> |
| 294 | </td> | 291 | </td> |
| @@ -316,7 +313,7 @@ measurements</p> | |||
| 316 | <li><strong>sender</strong> – </li> | 313 | <li><strong>sender</strong> – </li> |
| 317 | <li><strong>msgid</strong> – </li> | 314 | <li><strong>msgid</strong> – </li> |
| 318 | <li><strong>msgid</strong> – </li> | 315 | <li><strong>msgid</strong> – </li> |
| 319 | <li><strong>depth</strong> (<a class="reference external" href="https://docs.python.org/library/functions.html#int" title="(in Python v2.7)"><em>int</em></a>) – The recusion depth in retrying when PeerGoneAwayError | 316 | <li><strong>depth</strong> (<a class="reference external" href="https://docs.python.org/2/library/functions.html#int" title="(in Python v2.7)"><em>int</em></a>) – The recusion depth in retrying when PeerGoneAwayError |
| 320 | is raised.</li> | 317 | is raised.</li> |
| 321 | </ul> | 318 | </ul> |
| 322 | </td> | 319 | </td> |
| @@ -333,11 +330,11 @@ is raised.</li> | |||
| 333 | <col class="field-name" /> | 330 | <col class="field-name" /> |
| 334 | <col class="field-body" /> | 331 | <col class="field-body" /> |
| 335 | <tbody valign="top"> | 332 | <tbody valign="top"> |
| 336 | <tr class="field-odd field"><th class="field-name">Parameters:</th><td class="field-body"><strong>unprioritized_iterable</strong> (<a class="reference external" href="https://docs.python.org/library/functions.html#iter" title="(in Python v2.7)"><em>iter</em></a>) – Any list, tuple, etc where the | 333 | <tr class="field-odd field"><th class="field-name">Parameters:</th><td class="field-body"><strong>unprioritized_iterable</strong> (<a class="reference external" href="https://docs.python.org/2/library/functions.html#iter" title="(in Python v2.7)"><em>iter</em></a>) – Any list, tuple, etc where the |
| 337 | 0-index key is an integer to use as priority. Largest numbers | 334 | 0-index key is an integer to use as priority. Largest numbers |
| 338 | come first.</td> | 335 | come first.</td> |
| 339 | </tr> | 336 | </tr> |
| 340 | <tr class="field-even field"><th class="field-name">Raises:</th><td class="field-body"><strong>IndexError - There was no 0-index element.</strong> –</td> | 337 | <tr class="field-even field"><th class="field-name">Raises:</th><td class="field-body">IndexError - There was no 0-index element.</td> |
| 341 | </tr> | 338 | </tr> |
| 342 | <tr class="field-odd field"><th class="field-name">Returns:</th><td class="field-body">decsending order list. E.g. ((20, ‘a’), (14, ‘b’), (12, ‘c’))</td> | 339 | <tr class="field-odd field"><th class="field-name">Returns:</th><td class="field-body">decsending order list. E.g. ((20, ‘a’), (14, ‘b’), (12, ‘c’))</td> |
| 343 | </tr> | 340 | </tr> |
| @@ -359,8 +356,7 @@ called. This is used to short circuit message retry attempts.</li> | |||
| 359 | </ul> | 356 | </ul> |
| 360 | </td> | 357 | </td> |
| 361 | </tr> | 358 | </tr> |
| 362 | <tr class="field-even field"><th class="field-name">Raises:</th><td class="field-body"><p class="first last"><code class="xref py py-exc docutils literal"><span class="pre">InvalidMessageError</span></code> – | 359 | <tr class="field-even field"><th class="field-name">Raises:</th><td class="field-body"><p class="first last"><code class="xref py py-exc docutils literal"><span class="pre">InvalidMessageError</span></code> – Unable to parse the message</p> |
| 363 | Unable to parse the message</p> | ||
| 364 | </td> | 360 | </td> |
| 365 | </tr> | 361 | </tr> |
| 366 | </tbody> | 362 | </tbody> |
| @@ -421,7 +417,7 @@ worker slot, so you may see duplicate addresses.</p> | |||
| 421 | <dl class="attribute"> | 417 | <dl class="attribute"> |
| 422 | <dt id="eventmq.router.Router.scheduler_queue"> | 418 | <dt id="eventmq.router.Router.scheduler_queue"> |
| 423 | <code class="descname">scheduler_queue</code><em class="property"> = None</em><a class="headerlink" href="#eventmq.router.Router.scheduler_queue" title="Permalink to this definition">¶</a></dt> | 419 | <code class="descname">scheduler_queue</code><em class="property"> = None</em><a class="headerlink" href="#eventmq.router.Router.scheduler_queue" title="Permalink to this definition">¶</a></dt> |
| 424 | <dd><p>Queue for schedulers to use:</p> | 420 | <dd><p><em>Queue for schedulers to use</em></p> |
| 425 | </dd></dl> | 421 | </dd></dl> |
| 426 | 422 | ||
| 427 | <dl class="attribute"> | 423 | <dl class="attribute"> |
| @@ -449,8 +445,8 @@ Contains dictionaries:</p> | |||
| 449 | <col class="field-body" /> | 445 | <col class="field-body" /> |
| 450 | <tbody valign="top"> | 446 | <tbody valign="top"> |
| 451 | <tr class="field-odd field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first simple"> | 447 | <tr class="field-odd field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first simple"> |
| 452 | <li><strong>socket</strong> (<a class="reference external" href="https://docs.python.org/library/socket.html#module-socket" title="(in Python v2.7)"><em>socket</em></a>) – The socket to use for this ack</li> | 448 | <li><strong>socket</strong> (<a class="reference external" href="https://docs.python.org/2/library/socket.html#module-socket" title="(in Python v2.7)"><em>socket</em></a>) – The socket to use for this ack</li> |
| 453 | <li><strong>recipient</strong> (<a class="reference external" href="https://docs.python.org/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – The recipient id for the ack</li> | 449 | <li><strong>recipient</strong> (<a class="reference external" href="https://docs.python.org/2/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – The recipient id for the ack</li> |
| 454 | <li><strong>msgid</strong> – The unique id that we are acknowledging</li> | 450 | <li><strong>msgid</strong> – The unique id that we are acknowledging</li> |
| 455 | </ul> | 451 | </ul> |
| 456 | </td> | 452 | </td> |
| @@ -475,8 +471,8 @@ needed when building messages</p> | |||
| 475 | <col class="field-body" /> | 471 | <col class="field-body" /> |
| 476 | <tbody valign="top"> | 472 | <tbody valign="top"> |
| 477 | <tr class="field-odd field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first simple"> | 473 | <tr class="field-odd field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first simple"> |
| 478 | <li><strong>socket</strong> (<a class="reference external" href="https://docs.python.org/library/socket.html#module-socket" title="(in Python v2.7)"><em>socket</em></a>) – the socket to send the heartbeat with</li> | 474 | <li><strong>socket</strong> (<a class="reference external" href="https://docs.python.org/2/library/socket.html#module-socket" title="(in Python v2.7)"><em>socket</em></a>) – the socket to send the heartbeat with</li> |
| 479 | <li><strong>recipient</strong> (<a class="reference external" href="https://docs.python.org/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – Worker I</li> | 475 | <li><strong>recipient</strong> (<a class="reference external" href="https://docs.python.org/2/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – Worker I</li> |
| 480 | </ul> | 476 | </ul> |
| 481 | </td> | 477 | </td> |
| 482 | </tr> | 478 | </tr> |
| @@ -518,9 +514,9 @@ process receives a SIGHUP from the system.</p> | |||
| 518 | <col class="field-body" /> | 514 | <col class="field-body" /> |
| 519 | <tbody valign="top"> | 515 | <tbody valign="top"> |
| 520 | <tr class="field-odd field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first last simple"> | 516 | <tr class="field-odd field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first last simple"> |
| 521 | <li><strong>frontend_addr</strong> (<a class="reference external" href="https://docs.python.org/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – connection string to listen for requests</li> | 517 | <li><strong>frontend_addr</strong> (<a class="reference external" href="https://docs.python.org/2/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – connection string to listen for requests</li> |
| 522 | <li><strong>backend_addr</strong> (<a class="reference external" href="https://docs.python.org/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – connection string to listen for workers</li> | 518 | <li><strong>backend_addr</strong> (<a class="reference external" href="https://docs.python.org/2/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – connection string to listen for workers</li> |
| 523 | <li><strong>administrative_addr</strong> (<a class="reference external" href="https://docs.python.org/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – connection string to listen for emq-cli | 519 | <li><strong>administrative_addr</strong> (<a class="reference external" href="https://docs.python.org/2/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) – connection string to listen for emq-cli |
| 524 | commands on.</li> | 520 | commands on.</li> |
| 525 | </ul> | 521 | </ul> |
| 526 | </td> | 522 | </td> |