DCB

[DavidBadura]

Implement Dynamic Consistency Boundary according to https://dcb.events/.

The following examples were partially implemented:

• Course subscription
• Invoice number

There are still some questions open:

•  How do we handle the different streams? It should be possible to use different streams for different bounded contexts. Currently, this is not reflected in the API. -> implemented
•  The EventTagExtractor must handle value objects. The current implementation requires PHP's Stringable interface, which requires a __toString() method. Since this can lead to problems, we need an alternative. -> use Identifier component
•  Filtering event types is not yet implemented. -> implemented
• Is archiving still possible? Is it necessary? Can this possibly be implemented with tags? -> for DCB: no
• The Projection API isn't fully developed yet. Returning QueryComponent instead of tags directly? Apply should be converted to Attributes. -> done

[github-actions]

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 () | 3.456ms (±0.00%)   | 3.481ms (±0.00%)   | -0.70%    | 36.355mb        | 36.297mb   | +0.16%      |
| benchSave10000Events () | 514.049ms (±0.00%) | 536.971ms (±0.00%) | -4.27%    | 36.425mb        | 35.897mb   | +1.47%      |
+-------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

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

+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
|                                        | time (kde mode)                                     | memory                                     |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| subject                                | Tag: <current>     | Tag: base          | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| benchLoad1Event ()                     | 1.070ms (±0.00%)   | 1.201ms (±0.00%)   | -10.84%   | 35.799mb        | 35.799mb   | +0.00%      |
| benchLoad10000Events ()                | 106.364ms (±0.00%) | 107.852ms (±0.00%) | -1.38%    | 35.799mb        | 35.799mb   | +0.00%      |
| benchSave1Event ()                     | 1.888ms (±0.00%)   | 1.884ms (±0.00%)   | +0.18%    | 35.799mb        | 35.799mb   | +0.00%      |
| benchSave10000Events ()                | 323.101ms (±0.00%) | 337.012ms (±0.00%) | -4.13%    | 35.801mb        | 35.801mb   | +0.00%      |
| benchSave10000Aggregates ()            | 12.396s (±0.00%)   | 12.351s (±0.00%)   | +0.36%    | 35.799mb        | 35.799mb   | +0.00%      |
| benchSave10000AggregatesTransaction () | 9.493s (±0.00%)    | 9.515s (±0.00%)    | -0.24%    | 36.040mb        | 36.039mb   | +0.00%      |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

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

+---------------------------+-----------------+-----------------+-----------+-----------------+------------+-------------+
|                           | time (kde mode)                               | memory                                     |
+---------------------------+-----------------+-----------------+-----------+-----------------+------------+-------------+
| subject                   | Tag: <current>  | Tag: base       | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+---------------------------+-----------------+-----------------+-----------+-----------------+------------+-------------+
| benchHandle10000Events () | 3.292s (±0.00%) | 3.283s (±0.00%) | +0.28%    | 48.287mb        | 48.287mb   | +0.00%      |
+---------------------------+-----------------+-----------------+-----------+-----------------+------------+-------------+

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

+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
|                                        | time (kde mode)                                     | memory                                     |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| subject                                | Tag: <current>     | Tag: base          | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| benchLoad1Event ()                     | 1.106ms (±0.00%)   | 1.167ms (±0.00%)   | -5.21%    | 35.136mb        | 35.136mb   | +0.00%      |
| benchLoad10000Events ()                | 68.033ms (±0.00%)  | 66.815ms (±0.00%)  | +1.82%    | 35.136mb        | 35.136mb   | +0.00%      |
| benchSave1Event ()                     | 1.354ms (±0.00%)   | 1.268ms (±0.00%)   | +6.82%    | 35.136mb        | 35.136mb   | +0.00%      |
| benchSave10000Events ()                | 298.341ms (±0.00%) | 294.186ms (±0.00%) | +1.41%    | 35.136mb        | 35.136mb   | +0.00%      |
| benchSave10000Aggregates ()            | 8.183s (±0.00%)    | 8.026s (±0.00%)    | +1.97%    | 35.136mb        | 35.136mb   | +0.00%      |
| benchSave10000AggregatesTransaction () | 5.233s (±0.00%)    | 5.207s (±0.00%)    | +0.51%    | 35.136mb        | 35.136mb   | +0.00%      |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

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

+----------------------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
|                                        | time (kde mode)                                   | memory                                     |
+----------------------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| subject                                | Tag: <current>    | Tag: base         | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| benchLoad10000EventsMissingSnapshot () | 70.093ms (±0.00%) | 69.103ms (±0.00%) | +1.43%    | 35.206mb        | 35.206mb   | +0.00%      |
| benchLoad10000Events ()                | 1.112ms (±0.00%)  | 1.054ms (±0.00%)  | +5.53%    | 35.206mb        | 35.206mb   | +0.00%      |
+----------------------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+

SimpleSetupTaggableStoreBench
=============================

+----------------------------------------+--------------------+-----------+-----------------+-------------+
|                                        | time (kde mode)                | memory                        |
+----------------------------------------+--------------------+-----------+-----------------+-------------+
| subject                                | Tag: <current>     | time-diff | Tag: <current>  | memory-diff |
+----------------------------------------+--------------------+-----------+-----------------+-------------+
| benchLoad1Event ()                     | 1.349ms (±0.00%)   | +0.00%    | 36.301mb        | +0.00%      |
| benchLoad10000Events ()                | 71.637ms (±0.00%)  | +0.00%    | 36.302mb        | +0.00%      |
| benchSave1Event ()                     | 1.373ms (±0.00%)   | +0.00%    | 36.301mb        | +0.00%      |
| benchSave10000Events ()                | 343.079ms (±0.00%) | +0.00%    | 36.356mb        | +0.00%      |
| benchSave10000Aggregates ()            | 8.166s (±0.00%)    | +0.00%    | 36.302mb        | +0.00%      |
| benchSave10000AggregatesTransaction () | 5.281s (±0.00%)    | +0.00%    | 36.302mb        | +0.00%      |
| benchAppend1Event ()                   | 1.609ms (±0.00%)   | +0.00%    | 36.302mb        | +0.00%      |
| benchAppend100Events ()                | 7.783ms (±0.00%)   | +0.00%    | 36.302mb        | +0.00%      |
+----------------------------------------+--------------------+-----------+-----------------+-------------+

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

+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
|                           | time (kde mode)                                   | memory                                     |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| subject                   | Tag: <current>    | Tag: base         | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| benchHandle10000Events () | 90.878ms (±0.00%) | 90.107ms (±0.00%) | +0.86%    | 35.715mb        | 35.715mb   | +0.00%      |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+

This comment gets update everytime a new commit comes in!