aboutsummaryrefslogtreecommitdiffstats
path: root/router.html
diff options
context:
space:
mode:
authorjason2017-01-23 20:18:42 -0700
committerjason2017-01-23 20:18:42 -0700
commitf3c64b9a0837dd03584b67179267e1e0ca8edadd (patch)
tree4b282f228902334e13415547f9d3ff8e9889d0d4 /router.html
parent4780da086a62543c2bfbf0b98cabc181c4420244 (diff)
downloadeventmq-f3c64b9a0837dd03584b67179267e1e0ca8edadd.tar.gz
eventmq-f3c64b9a0837dd03584b67179267e1e0ca8edadd.zip
update docs
Diffstat (limited to 'router.html')
-rwxr-xr-x[-rw-r--r--]router.html68
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> &#8211; 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> &#8211; 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> &#8211; 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> &#8211; 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> &#8211; 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> &#8211; 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> &#8211; 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> &#8211; 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> &#8211; 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> &#8211; 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> &#8211; 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> &#8211; 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>) &#8211; 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>) &#8211; 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>) &#8211; 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>) &#8211; unique id of the worker to add</li>
176<li><strong>queues</strong> &#8211; queue or queues this worker should be a member of</li> 179<li><strong>queues</strong> &#8211; 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>) &#8211; 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>) &#8211; 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> &#8211; 222<li><code class="xref py py-exc docutils literal"><span class="pre">NoAvailableWorkerSlotsError</span></code> &#8211; Raised when there are no available</li>
220Raised 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> &#8211;</li> 224<li><code class="xref py py-exc docutils literal"><span class="pre">UnknownQueueError</span></code> &#8211; 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> &#8211;
223Raised when <code class="docutils literal"><span class="pre">queue_name</span></code> is not found in
224self.queues</li> 225self.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>) &#8211; 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>) &#8211; 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>) &#8211; 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>) &#8211; Unique identifier for this message</li>
292<li><strong>msg</strong> &#8211; The actual message that was sent</li> 289<li><strong>msg</strong> &#8211; 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> &#8211; </li> 313<li><strong>sender</strong> &#8211; </li>
317<li><strong>msgid</strong> &#8211; </li> 314<li><strong>msgid</strong> &#8211; </li>
318<li><strong>msgid</strong> &#8211; </li> 315<li><strong>msgid</strong> &#8211; </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>) &#8211; 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>) &#8211; The recusion depth in retrying when PeerGoneAwayError
320is raised.</li> 317is 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>) &#8211; 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>) &#8211; Any list, tuple, etc where the
3370-index key is an integer to use as priority. Largest numbers 3340-index key is an integer to use as priority. Largest numbers
338come first.</td> 335come 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> &#8211;</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, &#8216;a&#8217;), (14, &#8216;b&#8217;), (12, &#8216;c&#8217;))</td> 339<tr class="field-odd field"><th class="field-name">Returns:</th><td class="field-body">decsending order list. E.g. ((20, &#8216;a&#8217;), (14, &#8216;b&#8217;), (12, &#8216;c&#8217;))</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> &#8211; 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> &#8211; Unable to parse the message</p>
363Unable 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>) &#8211; 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>) &#8211; 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>) &#8211; 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>) &#8211; The recipient id for the ack</li>
454<li><strong>msgid</strong> &#8211; The unique id that we are acknowledging</li> 450<li><strong>msgid</strong> &#8211; 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>) &#8211; 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>) &#8211; 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>) &#8211; 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>) &#8211; 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>) &#8211; 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>) &#8211; 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>) &#8211; 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>) &#8211; 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>) &#8211; 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>) &#8211; connection string to listen for emq-cli
524commands on.</li> 520commands on.</li>
525</ul> 521</ul>
526</td> 522</td>