Skip to content

Update docs: Gettings started (MesageLoader), Subscription worker usage#858

Merged
DanielBadura merged 1 commit into
3.20.xfrom
improve-docs-subscription-worker
Jun 12, 2026
Merged

Update docs: Gettings started (MesageLoader), Subscription worker usage#858
DanielBadura merged 1 commit into
3.20.xfrom
improve-docs-subscription-worker

Conversation

@DanielBadura

Copy link
Copy Markdown
Member

Add StoreMessageLoader in getting started, add more information about the worker and process

This is basically #854 with small adjustments from @Brammm

… the worker and process

This is basically #854 with small adjustments
@DanielBadura DanielBadura requested a review from DavidBadura June 12, 2026 11:55
@DanielBadura DanielBadura self-assigned this Jun 12, 2026
@DanielBadura

Copy link
Copy Markdown
Member Author

There a alot of space changes, most probably due to the recent new docs page release and the not executed make docs-format 🙈

@github-actions

Copy link
Copy Markdown

Hello 👋

here is the most recent benchmark result:

SplitStreamBench
================

+-------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
|                         | time (kde mode)                                     | memory                                     |
+-------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| subject                 | Tag: <current>     | Tag: base          | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+-------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| benchLoad10000Events () | 5.214ms (±0.00%)   | 5.413ms (±0.00%)   | -3.68%    | 35.584mb        | 36.102mb   | -1.43%      |
| benchSave10000Events () | 335.013ms (±0.00%) | 341.080ms (±0.00%) | -1.78%    | 35.651mb        | 35.651mb   | 0.00%       |
+-------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

SimpleSetupStreamStoreBench
===========================

+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
|                                        | time (kde mode)                                     | memory                                     |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| subject                                | Tag: <current>     | Tag: base          | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| benchLoad1Event ()                     | 1.122ms (±0.00%)   | 1.123ms (±0.00%)   | -0.12%    | 35.206mb        | 35.206mb   | 0.00%       |
| benchLoad10000Events ()                | 70.493ms (±0.00%)  | 67.868ms (±0.00%)  | +3.87%    | 35.206mb        | 35.206mb   | 0.00%       |
| benchSave1Event ()                     | 1.274ms (±0.00%)   | 1.304ms (±0.00%)   | -2.27%    | 35.206mb        | 35.206mb   | 0.00%       |
| benchSave10000Events ()                | 291.721ms (±0.00%) | 292.996ms (±0.00%) | -0.44%    | 35.206mb        | 35.206mb   | 0.00%       |
| benchSave10000Aggregates ()            | 9.008s (±0.00%)    | 9.006s (±0.00%)    | +0.03%    | 35.206mb        | 35.206mb   | 0.00%       |
| benchSave10000AggregatesTransaction () | 5.663s (±0.00%)    | 5.709s (±0.00%)    | -0.81%    | 35.206mb        | 35.206mb   | 0.00%       |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

SimpleSetupBench
================

+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
|                                        | time (kde mode)                                     | memory                                     |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| subject                                | Tag: <current>     | Tag: base          | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| benchLoad1Event ()                     | 1.004ms (±0.00%)   | 993.000μs (±0.00%) | +1.12%    | 34.979mb        | 34.979mb   | 0.00%       |
| benchLoad10000Events ()                | 63.580ms (±0.00%)  | 66.767ms (±0.00%)  | -4.77%    | 34.979mb        | 34.979mb   | 0.00%       |
| benchSave1Event ()                     | 1.276ms (±0.00%)   | 1.262ms (±0.00%)   | +1.09%    | 34.979mb        | 34.979mb   | 0.00%       |
| benchSave10000Events ()                | 224.593ms (±0.00%) | 225.054ms (±0.00%) | -0.20%    | 34.979mb        | 34.979mb   | 0.00%       |
| benchSave10000Aggregates ()            | 8.706s (±0.00%)    | 8.649s (±0.00%)    | +0.66%    | 34.979mb        | 34.979mb   | 0.00%       |
| benchSave10000AggregatesTransaction () | 5.543s (±0.00%)    | 5.551s (±0.00%)    | -0.15%    | 34.979mb        | 34.979mb   | 0.00%       |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

SubscriptionEngineBatchBench
============================

+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
|                           | time (kde mode)                                   | memory                                     |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| subject                   | Tag: <current>    | Tag: base         | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| benchHandle10000Events () | 83.758ms (±0.00%) | 84.838ms (±0.00%) | -1.27%    | 35.544mb        | 35.544mb   | 0.00%       |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+

NoopSubscriptionEngineBench
===========================

+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
|                           | time (kde mode)                                   | memory                                     |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| subject                   | Tag: <current>    | Tag: base         | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| benchHandle10000Events () | 81.266ms (±0.00%) | 83.494ms (±0.00%) | -2.67%    | 47.560mb        | 47.560mb   | 0.00%       |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+

SubscriptionEngineBench
=======================

+---------------------------+-----------------+-----------------+-----------+-----------------+------------+-------------+
|                           | time (kde mode)                               | memory                                     |
+---------------------------+-----------------+-----------------+-----------+-----------------+------------+-------------+
| subject                   | Tag: <current>  | Tag: base       | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+---------------------------+-----------------+-----------------+-----------+-----------------+------------+-------------+
| benchHandle10000Events () | 3.430s (±0.00%) | 3.416s (±0.00%) | +0.41%    | 47.560mb        | 47.560mb   | 0.00%       |
+---------------------------+-----------------+-----------------+-----------+-----------------+------------+-------------+

CommandToQueryBench
===================

+----------------+------------------+------------------+-----------+-----------------+------------+-------------+
|                | time (kde mode)                                 | memory                                     |
+----------------+------------------+------------------+-----------+-----------------+------------+-------------+
| subject        | Tag: <current>   | Tag: base        | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------+------------------+------------------+-----------+-----------------+------------+-------------+
| benchCreate () | 2.845ms (±0.00%) | 2.715ms (±0.00%) | +4.81%    | 5.090mb         | 5.090mb    | 0.00%       |
| benchUpdate () | 4.712ms (±0.00%) | 4.251ms (±0.00%) | +10.84%   | 5.026mb         | 5.026mb    | 0.00%       |
| benchBoth ()   | 7.189ms (±0.00%) | 7.100ms (±0.00%) | +1.26%    | 5.015mb         | 5.074mb    | -1.17%      |
+----------------+------------------+------------------+-----------+-----------------+------------+-------------+

PersonalDataBench
=================

+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
|                                        | time (kde mode)                                     | memory                                     |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| subject                                | Tag: <current>     | Tag: base          | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| benchLoad1Event ()                     | 1.232ms (±0.00%)   | 1.219ms (±0.00%)   | +1.09%    | 35.585mb        | 35.585mb   | 0.00%       |
| benchLoad10000Events ()                | 101.488ms (±0.00%) | 100.171ms (±0.00%) | +1.31%    | 35.585mb        | 35.585mb   | 0.00%       |
| benchSave1Event ()                     | 1.841ms (±0.00%)   | 1.799ms (±0.00%)   | +2.35%    | 35.585mb        | 35.585mb   | 0.00%       |
| benchSave10000Events ()                | 248.808ms (±0.00%) | 252.715ms (±0.00%) | -1.55%    | 35.586mb        | 35.586mb   | 0.00%       |
| benchSave10000Aggregates ()            | 13.551s (±0.00%)   | 13.503s (±0.00%)   | +0.36%    | 35.585mb        | 35.585mb   | 0.00%       |
| benchSave10000AggregatesTransaction () | 10.122s (±0.00%)   | 10.127s (±0.00%)   | -0.05%    | 36.044mb        | 36.044mb   | 0.00%       |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

SnapshotsBench
==============

+----------------------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
|                                        | time (kde mode)                                   | memory                                     |
+----------------------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| subject                                | Tag: <current>    | Tag: base         | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| benchLoad10000EventsMissingSnapshot () | 63.098ms (±0.00%) | 64.640ms (±0.00%) | -2.39%    | 35.049mb        | 35.049mb   | 0.00%       |
| benchLoad10000Events ()                | 1.201ms (±0.00%)  | 1.205ms (±0.00%)  | -0.32%    | 35.049mb        | 35.049mb   | 0.00%       |
+----------------------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+

This comment gets update everytime a new commit comes in!

@DanielBadura DanielBadura merged commit df672fc into 3.20.x Jun 12, 2026
38 of 39 checks passed
@DanielBadura DanielBadura added the documentation Improvements or additions to documentation label Jun 12, 2026
@DanielBadura DanielBadura added this to the 3.20.0 milestone Jun 12, 2026
@DanielBadura DanielBadura deleted the improve-docs-subscription-worker branch June 12, 2026 12:07
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

documentation Improvements or additions to documentation

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants