TheR1sing3un c5f80713be [ISSUE #4813] Add elect policy for controller (#4809) ...

* feat(controller): add elect policy

1. add epoch and maxOffset in heartbeat.
2. refactor elect logic, now we
elect a new master by elect policy(can expand).
3. add some unit tests

* refactor(controller): refactor some code and format some code

1. refactor some code and format some code

* fix typo in ReplicasInfoManager

1. fix typo in ReplicasInfoManager

* fix wrong method call in ReplicasManagerTest#before

1.fix wrong method call in ReplicasManagerTest#before

* fix wrong call in ReplicasManagerTest#before

1. fix wrong call in ReplicasManagerTest#before

* fix(controller): fix the bug about ReElectMaster

1. fix the bug about ReElectMaster
2. fix some typo

* style(controller): fix typo by checkstyle

1. fix typo by checkstyle

* test(broker): fix invalid usage of "any()" in DLedegerControllerTest#before

1. fix invalid usage of "any()" in DLedegerControllerTest#before

* fix(controller): fix some wrong usage in test

1. fix some wrong usage in test
2. refactor some field type to avoid NPE

2022-08-16 08:41:51 +08:00

..

src

[ISSUE #4813] Add elect policy for controller (#4809)

2022-08-16 08:41:51 +08:00

pom.xml

Change rocketmq version to 5.0.0-SNAPSHOT in controller pom.xml

2022-07-12 14:46:18 +08:00