You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2023/05/30 06:18:07 UTC
[rocketmq] branch develop updated (40ada807b3 -> 529976f8fb)
This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from 40ada807b3 [ISSUE #6828] return the number of assignments equal to the number of messageQueues for order consumer (#6829)
add 529976f8fb [ISSUE #6777] Support metric in controller (#6778)
No new revisions were added by this update.
Summary of changes:
.../broker/metrics/BrokerMetricsManager.java | 19 +-
.../org/apache/rocketmq/common/BrokerConfig.java | 35 +-
.../apache/rocketmq/common/ControllerConfig.java | 104 ++++++
.../java/org/apache/rocketmq/common/UtilAll.java | 27 ++
.../common/metrics/MetricsExporterType.java | 36 +-
.../org/apache/rocketmq/common/UtilAllTest.java | 61 ++++
controller/pom.xml | 4 +
.../controller/BrokerHeartbeatManager.java | 7 +
.../rocketmq/controller/ControllerManager.java | 4 +
.../controller/impl/DLedgerController.java | 56 ++-
.../heartbeat/DefaultBrokerHeartbeatManager.java | 17 +-
.../metrics/ControllerMetricsConstant.java | 148 ++++++++
.../metrics/ControllerMetricsManager.java | 383 +++++++++++++++++++++
.../processor/ControllerRequestProcessor.java | 40 +++
.../apache/rocketmq/proxy/config/ProxyConfig.java | 12 +-
.../proxy/metrics/ProxyMetricsManager.java | 22 +-
16 files changed, 898 insertions(+), 77 deletions(-)
copy remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestSource.java => common/src/main/java/org/apache/rocketmq/common/metrics/MetricsExporterType.java (62%)
create mode 100644 controller/src/main/java/org/apache/rocketmq/controller/metrics/ControllerMetricsConstant.java
create mode 100644 controller/src/main/java/org/apache/rocketmq/controller/metrics/ControllerMetricsManager.java