[rocketmq-mqtt] branch develop updated (0d8ecf3 -> afd1302)

[pi...@apache.org]

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%)