feat(queue): document protocol between agent and leader

Document leader's states
This commit is contained in:
Ilya Averyanov 2024-06-26 17:51:08 +03:00
parent 082514f557
commit 03fea34962
2 changed files with 11 additions and 1 deletions

View File

@ -7,7 +7,17 @@ This application makes durable session capable to cooperatively replay messages
![General layout](docs/images/ds_shared_subs.png)
* The nesting reflects nesting/ownership of entity states.
* The bold arrow represent the [most complex interaction](https://github.com/emqx/eip/blob/main/active/0028-durable-shared-subscriptions.md#shared-subscription-session-handler), between session-side group subscription state machine and the shared subscription leader.
* The bold arrow represent the [most complex interaction](https://github.com/emqx/eip/blob/main/active/0028-durable-shared-subscriptions.md#shared-subscription-session-handler), between session-side group subscription state machine (**GroupSM**) and the shared subscription leader (**Leader**).
# GroupSM and Leader communication
The target state of GroupSM and its representation in Leader is `replaying`. That is, when the GroupSM and the Leader agree on the leased streams, Leader sends lease confirmations to the GroupSM, the GroupSM sends iteration updates.
Other states are used to gracefully reassign streams to the GroupSM.
Below is the sequence diagram of the interaction.
![GroupSM and Leader communication](docs/images/groupsm_leader_communication.png)
# Contributing

Binary file not shown.

After

Width:  |  Height:  |  Size: 320 KiB