diff options
Diffstat (limited to 'jobmanager.html')
| -rw-r--r-- | jobmanager.html | 41 |
1 files changed, 40 insertions, 1 deletions
diff --git a/jobmanager.html b/jobmanager.html index 5f3da63..638acd6 100644 --- a/jobmanager.html +++ b/jobmanager.html | |||
| @@ -182,6 +182,38 @@ HEARTBEAT</p> | |||
| 182 | </dd></dl> | 182 | </dd></dl> |
| 183 | 183 | ||
| 184 | <dl class="method"> | 184 | <dl class="method"> |
| 185 | <dt id="eventmq.jobmanager.JobManager.on_request"> | ||
| 186 | <code class="descname">on_request</code><span class="sig-paren">(</span><em>msgid</em>, <em>msg</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.jobmanager.JobManager.on_request" title="Permalink to this definition">¶</a></dt> | ||
| 187 | <dd><p>Handles a REQUEST command</p> | ||
| 188 | <p>Messages are formatted like this: | ||
| 189 | [subcmd(str), {</p> | ||
| 190 | <blockquote> | ||
| 191 | <div>...options...</div></blockquote> | ||
| 192 | <p>}]</p> | ||
| 193 | <dl class="docutils"> | ||
| 194 | <dt>Subcommands:</dt> | ||
| 195 | <dd><dl class="first last docutils"> | ||
| 196 | <dt>run - run some callable. Options:</dt> | ||
| 197 | <dd><dl class="first docutils"> | ||
| 198 | <dt>{</dt> | ||
| 199 | <dd><p class="first">‘callable’: func or method name (eg. walk), | ||
| 200 | ‘path’: module path (eg. os.path), | ||
| 201 | ‘args’: (optional) list of args, | ||
| 202 | ‘kwargs’: (optional) dict of kwargs, | ||
| 203 | ‘class_args’: (optional) list of args for class</p> | ||
| 204 | <blockquote> | ||
| 205 | <div>instantiation,</div></blockquote> | ||
| 206 | <p class="last">‘class_kwargs’: (optional) dict of kwargs for class,</p> | ||
| 207 | </dd> | ||
| 208 | </dl> | ||
| 209 | <p class="last">}</p> | ||
| 210 | </dd> | ||
| 211 | </dl> | ||
| 212 | </dd> | ||
| 213 | </dl> | ||
| 214 | </dd></dl> | ||
| 215 | |||
| 216 | <dl class="method"> | ||
| 185 | <dt id="eventmq.jobmanager.JobManager.process_message"> | 217 | <dt id="eventmq.jobmanager.JobManager.process_message"> |
| 186 | <code class="descname">process_message</code><span class="sig-paren">(</span><em>msg</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.jobmanager.JobManager.process_message" title="Permalink to this definition">¶</a></dt> | 218 | <code class="descname">process_message</code><span class="sig-paren">(</span><em>msg</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.jobmanager.JobManager.process_message" title="Permalink to this definition">¶</a></dt> |
| 187 | <dd><p>Processes a message</p> | 219 | <dd><p>Processes a message</p> |
| @@ -204,11 +236,18 @@ Processing takes form of calling an <cite>on_COMMAND</cite> method.</td> | |||
| 204 | 236 | ||
| 205 | <dl class="method"> | 237 | <dl class="method"> |
| 206 | <dt id="eventmq.jobmanager.JobManager.send_inform"> | 238 | <dt id="eventmq.jobmanager.JobManager.send_inform"> |
| 207 | <code class="descname">send_inform</code><span class="sig-paren">(</span><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.jobmanager.JobManager.send_inform" title="Permalink to this definition">¶</a></dt> | 239 | <code class="descname">send_inform</code><span class="sig-paren">(</span><em>queue=None</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.jobmanager.JobManager.send_inform" title="Permalink to this definition">¶</a></dt> |
| 208 | <dd><p>Send an INFORM command</p> | 240 | <dd><p>Send an INFORM command</p> |
| 209 | </dd></dl> | 241 | </dd></dl> |
| 210 | 242 | ||
| 211 | <dl class="method"> | 243 | <dl class="method"> |
| 244 | <dt id="eventmq.jobmanager.JobManager.send_ready"> | ||
| 245 | <code class="descname">send_ready</code><span class="sig-paren">(</span><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.jobmanager.JobManager.send_ready" title="Permalink to this definition">¶</a></dt> | ||
| 246 | <dd><p>send the READY command upstream to indicate that JobManager is ready | ||
| 247 | for another REQUEST message.</p> | ||
| 248 | </dd></dl> | ||
| 249 | |||
| 250 | <dl class="method"> | ||
| 212 | <dt id="eventmq.jobmanager.JobManager.start"> | 251 | <dt id="eventmq.jobmanager.JobManager.start"> |
| 213 | <code class="descname">start</code><span class="sig-paren">(</span><em>addr='tcp://127.0.0.1:47291'</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.jobmanager.JobManager.start" title="Permalink to this definition">¶</a></dt> | 252 | <code class="descname">start</code><span class="sig-paren">(</span><em>addr='tcp://127.0.0.1:47291'</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.jobmanager.JobManager.start" title="Permalink to this definition">¶</a></dt> |
| 214 | <dd><p>Connect to <cite>addr</cite> and begin listening for job requests</p> | 253 | <dd><p>Connect to <cite>addr</cite> and begin listening for job requests</p> |