This is an automated email from the ASF dual-hosted git repository.
pingww pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git
from 0d8ecf3 Merge pull request #115 from ChangingFond/tls-server
new 316c30e fix bug dependency
new 0660867 add counter example in raft module
new 390a286 manager multi raft group
new c0d5df3 change store log for raft: each group a raft uri
new 6494a2e init commit for jraft with grpc
new dcb27ce delete kv
new 2a37ed2 delete blot rpc
new 75c043b fix ci
new afd1302 Merge pull request #122 from DongyuanPan/raft_state_machine
The 140 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
conf/meta.conf | 4 +-
meta/pom.xml | 104 +--
.../apache/rocketmq/mqtt/meta/config/MetaConf.java | 52 +-
.../apache/rocketmq/mqtt/meta/core/MetaClient.java | 948 ---------------------
.../apache/rocketmq/mqtt/meta/core/MetaServer.java | 97 ---
.../org/apache/rocketmq/mqtt/meta/core/Node.java | 48 --
.../rocketmq/mqtt/meta/raft/FailoverClosure.java | 16 +-
.../rocketmq/mqtt/meta/raft/MqttClosure.java | 154 ++++
.../rocketmq/mqtt/meta/raft/MqttRaftServer.java | 306 +++++++
.../rocketmq/mqtt/meta/raft/MqttStateMachine.java | 157 ++++
.../rocketmq/mqtt/meta/raft/RaftGroupHolder.java | 60 ++
.../meta/raft/processor/AbstractRpcProcessor.java | 153 ++++
.../mqtt/meta/raft/processor/Constants.java | 14 +-
.../meta/raft/processor/CounterStateProcessor.java | 69 ++
.../meta/raft/processor/MqttReadRpcProcessor.java | 46 +
.../meta/raft/processor/MqttWriteRpcProcessor.java | 27 +-
.../mqtt/meta/raft/processor/StateProcessor.java | 25 +-
.../rocketmq/mqtt/meta/raft/CounterClient.java | 133 +++
.../apache/rocketmq/mqtt/meta/util/IpUtilTest.java | 4 +-
mqtt-common/pom.xml | 44 +
.../model/StoreResult.java => proto/request.proto} | 40 +-
.../rocketmq/mqtt/ds/config/ServiceConf.java | 45 -
pom.xml | 65 +-
23 files changed, 1305 insertions(+), 1306 deletions(-)
delete mode 100644
meta/src/main/java/org/apache/rocketmq/mqtt/meta/core/MetaClient.java
delete mode 100644
meta/src/main/java/org/apache/rocketmq/mqtt/meta/core/MetaServer.java
delete mode 100644
meta/src/main/java/org/apache/rocketmq/mqtt/meta/core/Node.java
copy
mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/TrieMethod.java
=> meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/FailoverClosure.java
(73%)
create mode 100644
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttClosure.java
create mode 100644
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttRaftServer.java
create mode 100644
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttStateMachine.java
create mode 100644
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/RaftGroupHolder.java
create mode 100644
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/AbstractRpcProcessor.java
copy
mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel/ChannelCloseFrom.java
=>
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/Constants.java
(80%)
create mode 100644
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/CounterStateProcessor.java
create mode 100644
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/MqttReadRpcProcessor.java
copy
mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/collector/SubSystem.java
=>
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/MqttWriteRpcProcessor.java
(53%)
copy
mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/collector/SubSystem.java
=>
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/StateProcessor.java
(61%)
create mode 100644
meta/src/test/java/org/apache/rocketmq/mqtt/meta/raft/CounterClient.java
copy
mqtt-common/src/main/{java/org/apache/rocketmq/mqtt/common/model/StoreResult.java
=> proto/request.proto} (61%)
