Ilya Averyanov
|
08f70e4a25
|
feat(queue): move ds shared sub dependent test to emqx_ds_shared_sub app
|
2024-07-30 14:19:39 +03:00 |
|
Ilya Averyanov
|
e408804efb
|
feat(queue): fix dialyzer issues
|
2024-07-30 13:01:48 +03:00 |
|
Ilya Averyanov
|
e294d35703
|
feat(queue): add schema descriptions
|
2024-07-30 13:01:48 +03:00 |
|
Ilya Averyanov
|
303ff95e10
|
feat(queue): add stub for CRUD API
|
2024-07-30 13:01:48 +03:00 |
|
Ilya Averyanov
|
f0dd1bc4f4
|
feat(queue): add shared sub support to the management API
|
2024-07-30 13:01:20 +03:00 |
|
Ilya Averyanov
|
9b30320ddb
|
feat(queue): simplify progress report on disconnect
|
2024-07-30 13:01:20 +03:00 |
|
Ilya Averyanov
|
cae27293a5
|
feat(queue): move route registration to sessions
|
2024-07-30 13:01:19 +03:00 |
|
Ilya Averyanov
|
9307a82004
|
feat(queue): rearrange leader's code
|
2024-07-30 13:01:19 +03:00 |
|
Ilya Averyanov
|
a97a0d6400
|
feat(queue): fix dialyzer issues
|
2024-07-30 13:01:18 +03:00 |
|
Ilya Averyanov
|
8705956cdc
|
feat(queue): update docs
|
2024-07-30 13:01:18 +03:00 |
|
Ilya Averyanov
|
f213569460
|
feat(queue): clarify naming; identify shared subs by full topic filter
|
2024-07-30 13:01:18 +03:00 |
|
Ilya Averyanov
|
9e5e7a23c5
|
feat(queue): remove unnecessary acked flag
|
2024-07-30 13:01:17 +03:00 |
|
Ilya Averyanov
|
c569625dd1
|
feat(queue): handle partially unacked ranges
|
2024-07-30 13:01:16 +03:00 |
|
Ilya Averyanov
|
7daab1ab23
|
feat(queue): move replay progress to a separate data structure
|
2024-07-30 13:01:16 +03:00 |
|
Ilya Averyanov
|
077ee38530
|
feat(queue): add config
|
2024-07-30 13:01:15 +03:00 |
|
Ilya Averyanov
|
649cf88042
|
feat(queue): kick agents that do not return to the replaying state for long
|
2024-07-30 13:01:15 +03:00 |
|
Ilya Averyanov
|
1496f7f778
|
feat(queue): add leader_rank_progress test
|
2024-07-30 13:01:15 +03:00 |
|
Ilya Averyanov
|
91dd1183ad
|
feat(queue): fix dialyzer issues
|
2024-07-30 13:01:14 +03:00 |
|
Ilya Averyanov
|
65ab81ff74
|
feat(queue): fix quick resubscription
|
2024-07-30 13:01:14 +03:00 |
|
Ilya Averyanov
|
53d4cd3174
|
feat(queue): rename leader' stream_progresses to stream_states
|
2024-07-30 13:01:14 +03:00 |
|
Ilya Averyanov
|
7d004b37da
|
feat(queue): implement stream finalization
|
2024-07-30 13:01:13 +03:00 |
|
Ilya Averyanov
|
e5547005eb
|
feat(queue): implement resubscribe test
|
2024-07-30 13:01:13 +03:00 |
|
Ilya Averyanov
|
b4a010d63b
|
feat(queue): implement unsubscribe
|
2024-07-30 13:01:13 +03:00 |
|
Ilya Averyanov
|
9bde981c44
|
feat(queue): fix static check issues
|
2024-07-30 13:01:12 +03:00 |
|
Ilya Averyanov
|
7658e081c5
|
feat(queue): move design docs to the EIP
|
2024-07-30 13:01:12 +03:00 |
|
Ilya Averyanov
|
8dce530d15
|
feat(queue): fix progress reporting and more tests
We test reassignment during the intensive replay
|
2024-07-30 13:01:12 +03:00 |
|
Ilya Averyanov
|
a20d262327
|
feat(queue): send progress before fetching new messages
|
2024-07-30 13:01:11 +03:00 |
|
Ilya Averyanov
|
d32f282feb
|
feat(queue): add graceful disconnect
|
2024-07-30 13:01:11 +03:00 |
|
Ilya Averyanov
|
1d728a05b2
|
feat(queue): send metadata with agent when connecting to leader
It will be used to attach agent taints to improve stream assignment.
|
2024-07-30 13:01:11 +03:00 |
|
Ilya Averyanov
|
49bff5c08a
|
feat(queue): wrap remote calls in a proto
|
2024-07-30 13:01:10 +03:00 |
|
Ilya Averyanov
|
61eda0ff31
|
feat(queue): identify agents by SessionId in tests
|
2024-07-30 13:01:10 +03:00 |
|
Ilya Averyanov
|
8f0d807c00
|
feat(queue): add new test scenarios
|
2024-07-30 13:01:10 +03:00 |
|
Ilya Averyanov
|
bceb5d43ed
|
feat(queue): fix stream rebalancing issues, update tests
|
2024-07-30 13:01:10 +03:00 |
|
Ilya Averyanov
|
03fea34962
|
feat(queue): document protocol between agent and leader
Document leader's states
|
2024-07-30 13:01:09 +03:00 |
|
Ilya Averyanov
|
082514f557
|
feat(queue): implement full protocol between agent and leader
|
2024-07-30 13:01:09 +03:00 |
|
Ilya Averyanov
|
c831f0772f
|
feat(queue): handle renew_lease_timeout
|
2024-07-30 13:01:09 +03:00 |
|
Thales Macedo Garitezi
|
420493deb4
|
chore: add missing mix files to new apps
|
2024-07-04 10:27:59 -03:00 |
|
ieQu1
|
c0472a06f1
|
test(ds): Set initial conditions in repl. suite explicitly
|
2024-06-22 02:55:05 +02:00 |
|
Ilya Averyanov
|
db28a042d5
|
feat(queue): handle renew_lease_timeout
|
2024-06-21 15:18:37 +03:00 |
|
Ilya Averyanov
|
2096755ad6
|
feat(queue): reorganize group sm callbacks and methods
|
2024-06-21 13:01:38 +03:00 |
|
Ilya Averyanov
|
b9c5911883
|
feat(queue): implement find_leader_timeout event and so the connecting group_sm state
|
2024-06-21 12:22:17 +03:00 |
|
Ilya Averyanov
|
1205e34650
|
feat(queue): remove too useless header file
|
2024-06-20 20:48:56 +03:00 |
|
Ilya Averyanov
|
be175d205c
|
feat(queue): add JIRA task links for TODOs
|
2024-06-20 15:38:16 +03:00 |
|
Ilya Averyanov
|
a9c976b6c1
|
feat(queue): fix notes about the usage of agent<->leader protocol-related data structures
|
2024-06-20 15:24:25 +03:00 |
|
Ilya Averyanov
|
d0cff63ed6
|
feat(queue): remove unused hrl-guard
|
2024-06-20 15:18:47 +03:00 |
|
Ilya Averyanov
|
6da10036dc
|
feat(queue): fix dialyzer issues
|
2024-06-19 22:25:53 +03:00 |
|
Ilya Averyanov
|
a4bbab4aa2
|
feat(queue): document general entity layout
|
2024-06-19 22:24:20 +03:00 |
|
Ilya Averyanov
|
2b0146663a
|
feat(queue): add smoke test for ds shared subs
|
2024-06-19 19:32:23 +03:00 |
|
Ilya Averyanov
|
e3c4816035
|
feat(queue): move group subscription state machine to its own module
|
2024-06-19 19:22:10 +03:00 |
|
Ilya Averyanov
|
bca743054b
|
feat(queue): implement backbones of queue agent, leader and leader registry
|
2024-06-18 21:03:51 +03:00 |
|