You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2022/07/12 11:45:39 UTC
[GitHub] [rocketmq-mqtt] DongyuanPan opened a new pull request, #122: change meta to be a consistency module implemented by JRAFT
DongyuanPan opened a new pull request, #122:
URL: https://github.com/apache/rocketmq-mqtt/pull/122
#121
The framework of consistency module is preliminarily realized.This PR implements multi-raft group management with different business processors and linearly consistent reads. But there's a lot of work to be done.
1) A snapshot management module is also required to achieve fast recovery of the state machine.
2) Data fragmentation module. Implement automatic routing of data to the corresponding raft group.
3) The ability for new nodes to automatically join the original raft group. It means that the original raft node does not need to be restarted.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-mqtt] pingww merged pull request #122: change meta to be a consistency module implemented by JRAFT
Posted by GitBox <gi...@apache.org>.
pingww merged PR #122:
URL: https://github.com/apache/rocketmq-mqtt/pull/122
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-mqtt] codecov-commenter commented on pull request #122: change meta to be a consistency module implemented by JRAFT
Posted by GitBox <gi...@apache.org>.
codecov-commenter commented on PR #122:
URL: https://github.com/apache/rocketmq-mqtt/pull/122#issuecomment-1190966302
# [Codecov](https://codecov.io/gh/apache/rocketmq-mqtt/pull/122?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) Report
> Merging [#122](https://codecov.io/gh/apache/rocketmq-mqtt/pull/122?src=pr&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) (75c043b) into [develop](https://codecov.io/gh/apache/rocketmq-mqtt/commit/aba21659222527229e0ee775e4724b99d52b4163?el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) (aba2165) will **decrease** coverage by `2.40%`.
> The diff coverage is `0.00%`.
```diff
@@ Coverage Diff @@
## develop #122 +/- ##
===========================================
- Coverage 45.54% 43.13% -2.41%
===========================================
Files 106 114 +8
Lines 4514 4766 +252
Branches 673 697 +24
===========================================
Hits 2056 2056
- Misses 2104 2356 +252
Partials 354 354
```
| [Impacted Files](https://codecov.io/gh/apache/rocketmq-mqtt/pull/122?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) | Coverage Δ | |
|---|---|---|
| [...org/apache/rocketmq/mqtt/meta/config/MetaConf.java](https://codecov.io/gh/apache/rocketmq-mqtt/pull/122/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-bWV0YS9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvcm9ja2V0bXEvbXF0dC9tZXRhL2NvbmZpZy9NZXRhQ29uZi5qYXZh) | `0.00% <0.00%> (ø)` | |
| [...rg/apache/rocketmq/mqtt/meta/raft/MqttClosure.java](https://codecov.io/gh/apache/rocketmq-mqtt/pull/122/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-bWV0YS9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvcm9ja2V0bXEvbXF0dC9tZXRhL3JhZnQvTXF0dENsb3N1cmUuamF2YQ==) | `0.00% <0.00%> (ø)` | |
| [...apache/rocketmq/mqtt/meta/raft/MqttRaftServer.java](https://codecov.io/gh/apache/rocketmq-mqtt/pull/122/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-bWV0YS9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvcm9ja2V0bXEvbXF0dC9tZXRhL3JhZnQvTXF0dFJhZnRTZXJ2ZXIuamF2YQ==) | `0.00% <0.00%> (ø)` | |
| [...ache/rocketmq/mqtt/meta/raft/MqttStateMachine.java](https://codecov.io/gh/apache/rocketmq-mqtt/pull/122/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-bWV0YS9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvcm9ja2V0bXEvbXF0dC9tZXRhL3JhZnQvTXF0dFN0YXRlTWFjaGluZS5qYXZh) | `0.00% <0.00%> (ø)` | |
| [...pache/rocketmq/mqtt/meta/raft/RaftGroupHolder.java](https://codecov.io/gh/apache/rocketmq-mqtt/pull/122/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-bWV0YS9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvcm9ja2V0bXEvbXF0dC9tZXRhL3JhZnQvUmFmdEdyb3VwSG9sZGVyLmphdmE=) | `0.00% <0.00%> (ø)` | |
| [...mqtt/meta/raft/processor/AbstractRpcProcessor.java](https://codecov.io/gh/apache/rocketmq-mqtt/pull/122/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-bWV0YS9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvcm9ja2V0bXEvbXF0dC9tZXRhL3JhZnQvcHJvY2Vzc29yL0Fic3RyYWN0UnBjUHJvY2Vzc29yLmphdmE=) | `0.00% <0.00%> (ø)` | |
| [...e/rocketmq/mqtt/meta/raft/processor/Constants.java](https://codecov.io/gh/apache/rocketmq-mqtt/pull/122/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-bWV0YS9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvcm9ja2V0bXEvbXF0dC9tZXRhL3JhZnQvcHJvY2Vzc29yL0NvbnN0YW50cy5qYXZh) | `0.00% <0.00%> (ø)` | |
| [...qtt/meta/raft/processor/CounterStateProcessor.java](https://codecov.io/gh/apache/rocketmq-mqtt/pull/122/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-bWV0YS9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvcm9ja2V0bXEvbXF0dC9tZXRhL3JhZnQvcHJvY2Vzc29yL0NvdW50ZXJTdGF0ZVByb2Nlc3Nvci5qYXZh) | `0.00% <0.00%> (ø)` | |
| [...mqtt/meta/raft/processor/MqttReadRpcProcessor.java](https://codecov.io/gh/apache/rocketmq-mqtt/pull/122/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-bWV0YS9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvcm9ja2V0bXEvbXF0dC9tZXRhL3JhZnQvcHJvY2Vzc29yL01xdHRSZWFkUnBjUHJvY2Vzc29yLmphdmE=) | `0.00% <0.00%> (ø)` | |
| [...qtt/meta/raft/processor/MqttWriteRpcProcessor.java](https://codecov.io/gh/apache/rocketmq-mqtt/pull/122/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-bWV0YS9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvcm9ja2V0bXEvbXF0dC9tZXRhL3JhZnQvcHJvY2Vzc29yL01xdHRXcml0ZVJwY1Byb2Nlc3Nvci5qYXZh) | `0.00% <0.00%> (ø)` | |
| ... and [6 more](https://codecov.io/gh/apache/rocketmq-mqtt/pull/122/diff?src=pr&el=tree-more&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) | |
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org