Skip to content

Commit 250ba3e

Browse files
Deployed e7fd295 to v0.6-dev with MkDocs 1.6.1 and mike 2.1.3
1 parent 57f03ee commit 250ba3e

File tree

5 files changed

+142
-22
lines changed

5 files changed

+142
-22
lines changed
0 Bytes
Binary file not shown.

v0.6-dev/reference/frequenz/dispatch/index.html

Lines changed: 78 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -4741,7 +4741,15 @@ <h4 id="frequenz.dispatch.Dispatcher" class="doc doc-heading">
47414741
<span class="normal"><a href="#__codelineno-0-234">234</a></span>
47424742
<span class="normal"><a href="#__codelineno-0-235">235</a></span>
47434743
<span class="normal"><a href="#__codelineno-0-236">236</a></span>
4744-
<span class="normal"><a href="#__codelineno-0-237">237</a></span></pre></div></td><td class="code"><div><pre><span></span><code><span id="__span-0-15"><a id="__codelineno-0-15" name="__codelineno-0-15"></a><span class="k">class</span><span class="w"> </span><span class="nc">Dispatcher</span><span class="p">:</span>
4744+
<span class="normal"><a href="#__codelineno-0-237">237</a></span>
4745+
<span class="normal"><a href="#__codelineno-0-238">238</a></span>
4746+
<span class="normal"><a href="#__codelineno-0-239">239</a></span>
4747+
<span class="normal"><a href="#__codelineno-0-240">240</a></span>
4748+
<span class="normal"><a href="#__codelineno-0-241">241</a></span>
4749+
<span class="normal"><a href="#__codelineno-0-242">242</a></span>
4750+
<span class="normal"><a href="#__codelineno-0-243">243</a></span>
4751+
<span class="normal"><a href="#__codelineno-0-244">244</a></span>
4752+
<span class="normal"><a href="#__codelineno-0-245">245</a></span></pre></div></td><td class="code"><div><pre><span></span><code><span id="__span-0-15"><a id="__codelineno-0-15" name="__codelineno-0-15"></a><span class="k">class</span><span class="w"> </span><span class="nc">Dispatcher</span><span class="p">:</span>
47454753
</span><span id="__span-0-16"><a id="__codelineno-0-16" name="__codelineno-0-16"></a><span class="w"> </span><span class="sd">&quot;&quot;&quot;A highlevel interface for the dispatch API.</span>
47464754
</span><span id="__span-0-17"><a id="__codelineno-0-17" name="__codelineno-0-17"></a>
47474755
</span><span id="__span-0-18"><a id="__codelineno-0-18" name="__codelineno-0-18"></a><span class="sd"> This class provides a highlevel interface to the dispatch API.</span>
@@ -4929,7 +4937,7 @@ <h4 id="frequenz.dispatch.Dispatcher" class="doc doc-heading">
49294937
</span><span id="__span-0-200"><a id="__codelineno-0-200" name="__codelineno-0-200"></a> <span class="k">return</span> <span class="bp">self</span><span class="o">.</span><span class="n">_bg_service</span><span class="o">.</span><span class="n">new_lifecycle_events_receiver</span><span class="p">(</span><span class="n">dispatch_type</span><span class="p">)</span>
49304938
</span><span id="__span-0-201"><a id="__codelineno-0-201" name="__codelineno-0-201"></a>
49314939
</span><span id="__span-0-202"><a id="__codelineno-0-202" name="__codelineno-0-202"></a> <span class="k">async</span> <span class="k">def</span><span class="w"> </span><span class="nf">new_running_state_event_receiver</span><span class="p">(</span>
4932-
</span><span id="__span-0-203"><a id="__codelineno-0-203" name="__codelineno-0-203"></a> <span class="bp">self</span><span class="p">,</span> <span class="n">dispatch_type</span><span class="p">:</span> <span class="nb">str</span>
4940+
</span><span id="__span-0-203"><a id="__codelineno-0-203" name="__codelineno-0-203"></a> <span class="bp">self</span><span class="p">,</span> <span class="n">dispatch_type</span><span class="p">:</span> <span class="nb">str</span><span class="p">,</span> <span class="o">*</span><span class="p">,</span> <span class="n">unify_running_intervals</span><span class="p">:</span> <span class="nb">bool</span> <span class="o">=</span> <span class="kc">True</span>
49334941
</span><span id="__span-0-204"><a id="__codelineno-0-204" name="__codelineno-0-204"></a> <span class="p">)</span> <span class="o">-&gt;</span> <span class="n">Receiver</span><span class="p">[</span><span class="n">Dispatch</span><span class="p">]:</span>
49344942
</span><span id="__span-0-205"><a id="__codelineno-0-205" name="__codelineno-0-205"></a><span class="w"> </span><span class="sd">&quot;&quot;&quot;Return running state event receiver.</span>
49354943
</span><span id="__span-0-206"><a id="__codelineno-0-206" name="__codelineno-0-206"></a>
@@ -4957,13 +4965,21 @@ <h4 id="frequenz.dispatch.Dispatcher" class="doc doc-heading">
49574965
</span><span id="__span-0-228"><a id="__codelineno-0-228" name="__codelineno-0-228"></a><span class="sd"> - The payload changed</span>
49584966
</span><span id="__span-0-229"><a id="__codelineno-0-229" name="__codelineno-0-229"></a><span class="sd"> - The dispatch was deleted</span>
49594967
</span><span id="__span-0-230"><a id="__codelineno-0-230" name="__codelineno-0-230"></a>
4960-
</span><span id="__span-0-231"><a id="__codelineno-0-231" name="__codelineno-0-231"></a><span class="sd"> Args:</span>
4961-
</span><span id="__span-0-232"><a id="__codelineno-0-232" name="__codelineno-0-232"></a><span class="sd"> dispatch_type: The type of the dispatch to listen for.</span>
4962-
</span><span id="__span-0-233"><a id="__codelineno-0-233" name="__codelineno-0-233"></a>
4963-
</span><span id="__span-0-234"><a id="__codelineno-0-234" name="__codelineno-0-234"></a><span class="sd"> Returns:</span>
4964-
</span><span id="__span-0-235"><a id="__codelineno-0-235" name="__codelineno-0-235"></a><span class="sd"> A new receiver for dispatches whose running status changed.</span>
4965-
</span><span id="__span-0-236"><a id="__codelineno-0-236" name="__codelineno-0-236"></a><span class="sd"> &quot;&quot;&quot;</span>
4966-
</span><span id="__span-0-237"><a id="__codelineno-0-237" name="__codelineno-0-237"></a> <span class="k">return</span> <span class="k">await</span> <span class="bp">self</span><span class="o">.</span><span class="n">_bg_service</span><span class="o">.</span><span class="n">new_running_state_event_receiver</span><span class="p">(</span><span class="n">dispatch_type</span><span class="p">)</span>
4968+
</span><span id="__span-0-231"><a id="__codelineno-0-231" name="__codelineno-0-231"></a><span class="sd"> If `unify_running_intervals` is True, running intervals from multiple</span>
4969+
</span><span id="__span-0-232"><a id="__codelineno-0-232" name="__codelineno-0-232"></a><span class="sd"> dispatches of the same type are considered as one continuous running</span>
4970+
</span><span id="__span-0-233"><a id="__codelineno-0-233" name="__codelineno-0-233"></a><span class="sd"> period. In this mode, any stop events are ignored as long as at least</span>
4971+
</span><span id="__span-0-234"><a id="__codelineno-0-234" name="__codelineno-0-234"></a><span class="sd"> one dispatch remains active.</span>
4972+
</span><span id="__span-0-235"><a id="__codelineno-0-235" name="__codelineno-0-235"></a>
4973+
</span><span id="__span-0-236"><a id="__codelineno-0-236" name="__codelineno-0-236"></a><span class="sd"> Args:</span>
4974+
</span><span id="__span-0-237"><a id="__codelineno-0-237" name="__codelineno-0-237"></a><span class="sd"> dispatch_type: The type of the dispatch to listen for.</span>
4975+
</span><span id="__span-0-238"><a id="__codelineno-0-238" name="__codelineno-0-238"></a><span class="sd"> unify_running_intervals: Whether to unify running intervals.</span>
4976+
</span><span id="__span-0-239"><a id="__codelineno-0-239" name="__codelineno-0-239"></a>
4977+
</span><span id="__span-0-240"><a id="__codelineno-0-240" name="__codelineno-0-240"></a><span class="sd"> Returns:</span>
4978+
</span><span id="__span-0-241"><a id="__codelineno-0-241" name="__codelineno-0-241"></a><span class="sd"> A new receiver for dispatches whose running status changed.</span>
4979+
</span><span id="__span-0-242"><a id="__codelineno-0-242" name="__codelineno-0-242"></a><span class="sd"> &quot;&quot;&quot;</span>
4980+
</span><span id="__span-0-243"><a id="__codelineno-0-243" name="__codelineno-0-243"></a> <span class="k">return</span> <span class="k">await</span> <span class="bp">self</span><span class="o">.</span><span class="n">_bg_service</span><span class="o">.</span><span class="n">new_running_state_event_receiver</span><span class="p">(</span>
4981+
</span><span id="__span-0-244"><a id="__codelineno-0-244" name="__codelineno-0-244"></a> <span class="n">dispatch_type</span><span class="p">,</span> <span class="n">unify_running_intervals</span><span class="o">=</span><span class="n">unify_running_intervals</span>
4982+
</span><span id="__span-0-245"><a id="__codelineno-0-245" name="__codelineno-0-245"></a> <span class="p">)</span>
49674983
</span></code></pre></div></td></tr></table></div>
49684984
</details>
49694985

@@ -5236,7 +5252,9 @@ <h6 id="frequenz.dispatch.Dispatcher.new_running_state_event_receiver" class="do
52365252
<a href="#frequenz.dispatch.Dispatcher.new_running_state_event_receiver" class="headerlink" title="Permanent link">¤</a></h6>
52375253
<div class="language-python doc-signature highlight"><pre><span></span><code><span id="__span-0-1"><a id="__codelineno-0-1" name="__codelineno-0-1" href="#__codelineno-0-1"></a><span class="nf">new_running_state_event_receiver</span><span class="p">(</span>
52385254
</span><span id="__span-0-2"><a id="__codelineno-0-2" name="__codelineno-0-2" href="#__codelineno-0-2"></a> <span class="n">dispatch_type</span><span class="p">:</span> <span class="n"><a class="autorefs autorefs-external" href="https://docs.python.org/3/library/stdtypes.html#str">str</a></span><span class="p">,</span>
5239-
</span><span id="__span-0-3"><a id="__codelineno-0-3" name="__codelineno-0-3" href="#__codelineno-0-3"></a><span class="p">)</span> <span class="o">-&gt;</span> <span class="n"><a class="autorefs autorefs-external" title="frequenz.channels.Receiver" href="https://frequenz-floss.github.io/frequenz-channels-python/v1.0/reference/frequenz/channels/#frequenz.channels.Receiver">Receiver</a></span><span class="p">[</span><span class="n"><a class="autorefs autorefs-internal" title="frequenz.dispatch._dispatch.Dispatch" href="#frequenz.dispatch.Dispatch">Dispatch</a></span><span class="p">]</span>
5255+
</span><span id="__span-0-3"><a id="__codelineno-0-3" name="__codelineno-0-3" href="#__codelineno-0-3"></a> <span class="o">*</span><span class="p">,</span>
5256+
</span><span id="__span-0-4"><a id="__codelineno-0-4" name="__codelineno-0-4" href="#__codelineno-0-4"></a> <span class="n">unify_running_intervals</span><span class="p">:</span> <span class="n"><a class="autorefs autorefs-external" href="https://docs.python.org/3/library/functions.html#bool">bool</a></span> <span class="o">=</span> <span class="kc">True</span>
5257+
</span><span id="__span-0-5"><a id="__codelineno-0-5" name="__codelineno-0-5" href="#__codelineno-0-5"></a><span class="p">)</span> <span class="o">-&gt;</span> <span class="n"><a class="autorefs autorefs-external" title="frequenz.channels.Receiver" href="https://frequenz-floss.github.io/frequenz-channels-python/v1.0/reference/frequenz/channels/#frequenz.channels.Receiver">Receiver</a></span><span class="p">[</span><span class="n"><a class="autorefs autorefs-internal" title="frequenz.dispatch._dispatch.Dispatch" href="#frequenz.dispatch.Dispatch">Dispatch</a></span><span class="p">]</span>
52405258
</span></code></pre></div>
52415259

52425260
<div class="doc doc-contents ">
@@ -5266,7 +5284,11 @@ <h6 id="frequenz.dispatch.Dispatcher.new_running_state_event_receiver" class="do
52665284
<li>The payload changed</li>
52675285
<li>The dispatch was deleted</li>
52685286
</ul>
5269-
</details>
5287+
</details> <p>If <code>unify_running_intervals</code> is True, running intervals from multiple
5288+
dispatches of the same type are considered as one continuous running
5289+
period. In this mode, any stop events are ignored as long as at least
5290+
one dispatch remains active.</p>
5291+
52705292

52715293
<table>
52725294
<thead>
@@ -5292,6 +5314,26 @@ <h6 id="frequenz.dispatch.Dispatcher.new_running_state_event_receiver" class="do
52925314
</p>
52935315
</td>
52945316
</tr>
5317+
<tr class="doc-section-item">
5318+
<td>
5319+
<code>unify_running_intervals</code>
5320+
</td>
5321+
<td class="doc-param-details">
5322+
<div class="doc-md-description">
5323+
<p>Whether to unify running intervals.</p>
5324+
</div>
5325+
<p>
5326+
<span class="doc-param-annotation">
5327+
<b>TYPE:</b>
5328+
<code><a class="autorefs autorefs-external" href="https://docs.python.org/3/library/functions.html#bool">bool</a></code>
5329+
</span>
5330+
<span class="doc-param-default">
5331+
<b>DEFAULT:</b>
5332+
<code>True</code>
5333+
</span>
5334+
</p>
5335+
</td>
5336+
</tr>
52955337
</tbody>
52965338
</table>
52975339

@@ -5356,8 +5398,16 @@ <h6 id="frequenz.dispatch.Dispatcher.new_running_state_event_receiver" class="do
53565398
<span class="normal"><a href="#__codelineno-0-234">234</a></span>
53575399
<span class="normal"><a href="#__codelineno-0-235">235</a></span>
53585400
<span class="normal"><a href="#__codelineno-0-236">236</a></span>
5359-
<span class="normal"><a href="#__codelineno-0-237">237</a></span></pre></div></td><td class="code"><div><pre><span></span><code><span id="__span-0-202"><a id="__codelineno-0-202" name="__codelineno-0-202"></a><span class="k">async</span> <span class="k">def</span><span class="w"> </span><span class="nf">new_running_state_event_receiver</span><span class="p">(</span>
5360-
</span><span id="__span-0-203"><a id="__codelineno-0-203" name="__codelineno-0-203"></a> <span class="bp">self</span><span class="p">,</span> <span class="n">dispatch_type</span><span class="p">:</span> <span class="nb">str</span>
5401+
<span class="normal"><a href="#__codelineno-0-237">237</a></span>
5402+
<span class="normal"><a href="#__codelineno-0-238">238</a></span>
5403+
<span class="normal"><a href="#__codelineno-0-239">239</a></span>
5404+
<span class="normal"><a href="#__codelineno-0-240">240</a></span>
5405+
<span class="normal"><a href="#__codelineno-0-241">241</a></span>
5406+
<span class="normal"><a href="#__codelineno-0-242">242</a></span>
5407+
<span class="normal"><a href="#__codelineno-0-243">243</a></span>
5408+
<span class="normal"><a href="#__codelineno-0-244">244</a></span>
5409+
<span class="normal"><a href="#__codelineno-0-245">245</a></span></pre></div></td><td class="code"><div><pre><span></span><code><span id="__span-0-202"><a id="__codelineno-0-202" name="__codelineno-0-202"></a><span class="k">async</span> <span class="k">def</span><span class="w"> </span><span class="nf">new_running_state_event_receiver</span><span class="p">(</span>
5410+
</span><span id="__span-0-203"><a id="__codelineno-0-203" name="__codelineno-0-203"></a> <span class="bp">self</span><span class="p">,</span> <span class="n">dispatch_type</span><span class="p">:</span> <span class="nb">str</span><span class="p">,</span> <span class="o">*</span><span class="p">,</span> <span class="n">unify_running_intervals</span><span class="p">:</span> <span class="nb">bool</span> <span class="o">=</span> <span class="kc">True</span>
53615411
</span><span id="__span-0-204"><a id="__codelineno-0-204" name="__codelineno-0-204"></a><span class="p">)</span> <span class="o">-&gt;</span> <span class="n">Receiver</span><span class="p">[</span><span class="n">Dispatch</span><span class="p">]:</span>
53625412
</span><span id="__span-0-205"><a id="__codelineno-0-205" name="__codelineno-0-205"></a><span class="w"> </span><span class="sd">&quot;&quot;&quot;Return running state event receiver.</span>
53635413
</span><span id="__span-0-206"><a id="__codelineno-0-206" name="__codelineno-0-206"></a>
@@ -5385,13 +5435,21 @@ <h6 id="frequenz.dispatch.Dispatcher.new_running_state_event_receiver" class="do
53855435
</span><span id="__span-0-228"><a id="__codelineno-0-228" name="__codelineno-0-228"></a><span class="sd"> - The payload changed</span>
53865436
</span><span id="__span-0-229"><a id="__codelineno-0-229" name="__codelineno-0-229"></a><span class="sd"> - The dispatch was deleted</span>
53875437
</span><span id="__span-0-230"><a id="__codelineno-0-230" name="__codelineno-0-230"></a>
5388-
</span><span id="__span-0-231"><a id="__codelineno-0-231" name="__codelineno-0-231"></a><span class="sd"> Args:</span>
5389-
</span><span id="__span-0-232"><a id="__codelineno-0-232" name="__codelineno-0-232"></a><span class="sd"> dispatch_type: The type of the dispatch to listen for.</span>
5390-
</span><span id="__span-0-233"><a id="__codelineno-0-233" name="__codelineno-0-233"></a>
5391-
</span><span id="__span-0-234"><a id="__codelineno-0-234" name="__codelineno-0-234"></a><span class="sd"> Returns:</span>
5392-
</span><span id="__span-0-235"><a id="__codelineno-0-235" name="__codelineno-0-235"></a><span class="sd"> A new receiver for dispatches whose running status changed.</span>
5393-
</span><span id="__span-0-236"><a id="__codelineno-0-236" name="__codelineno-0-236"></a><span class="sd"> &quot;&quot;&quot;</span>
5394-
</span><span id="__span-0-237"><a id="__codelineno-0-237" name="__codelineno-0-237"></a> <span class="k">return</span> <span class="k">await</span> <span class="bp">self</span><span class="o">.</span><span class="n">_bg_service</span><span class="o">.</span><span class="n">new_running_state_event_receiver</span><span class="p">(</span><span class="n">dispatch_type</span><span class="p">)</span>
5438+
</span><span id="__span-0-231"><a id="__codelineno-0-231" name="__codelineno-0-231"></a><span class="sd"> If `unify_running_intervals` is True, running intervals from multiple</span>
5439+
</span><span id="__span-0-232"><a id="__codelineno-0-232" name="__codelineno-0-232"></a><span class="sd"> dispatches of the same type are considered as one continuous running</span>
5440+
</span><span id="__span-0-233"><a id="__codelineno-0-233" name="__codelineno-0-233"></a><span class="sd"> period. In this mode, any stop events are ignored as long as at least</span>
5441+
</span><span id="__span-0-234"><a id="__codelineno-0-234" name="__codelineno-0-234"></a><span class="sd"> one dispatch remains active.</span>
5442+
</span><span id="__span-0-235"><a id="__codelineno-0-235" name="__codelineno-0-235"></a>
5443+
</span><span id="__span-0-236"><a id="__codelineno-0-236" name="__codelineno-0-236"></a><span class="sd"> Args:</span>
5444+
</span><span id="__span-0-237"><a id="__codelineno-0-237" name="__codelineno-0-237"></a><span class="sd"> dispatch_type: The type of the dispatch to listen for.</span>
5445+
</span><span id="__span-0-238"><a id="__codelineno-0-238" name="__codelineno-0-238"></a><span class="sd"> unify_running_intervals: Whether to unify running intervals.</span>
5446+
</span><span id="__span-0-239"><a id="__codelineno-0-239" name="__codelineno-0-239"></a>
5447+
</span><span id="__span-0-240"><a id="__codelineno-0-240" name="__codelineno-0-240"></a><span class="sd"> Returns:</span>
5448+
</span><span id="__span-0-241"><a id="__codelineno-0-241" name="__codelineno-0-241"></a><span class="sd"> A new receiver for dispatches whose running status changed.</span>
5449+
</span><span id="__span-0-242"><a id="__codelineno-0-242" name="__codelineno-0-242"></a><span class="sd"> &quot;&quot;&quot;</span>
5450+
</span><span id="__span-0-243"><a id="__codelineno-0-243" name="__codelineno-0-243"></a> <span class="k">return</span> <span class="k">await</span> <span class="bp">self</span><span class="o">.</span><span class="n">_bg_service</span><span class="o">.</span><span class="n">new_running_state_event_receiver</span><span class="p">(</span>
5451+
</span><span id="__span-0-244"><a id="__codelineno-0-244" name="__codelineno-0-244"></a> <span class="n">dispatch_type</span><span class="p">,</span> <span class="n">unify_running_intervals</span><span class="o">=</span><span class="n">unify_running_intervals</span>
5452+
</span><span id="__span-0-245"><a id="__codelineno-0-245" name="__codelineno-0-245"></a> <span class="p">)</span>
53955453
</span></code></pre></div></td></tr></table></div>
53965454
</details>
53975455
</div>

v0.6-dev/search/search_index.json

Lines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.

v0.6-dev/sitemap.xml.gz

0 Bytes
Binary file not shown.

0 commit comments

Comments
 (0)