Closed 847850277 closed 1 month ago
The recent changes significantly enhance the RocketMQ broker's functionality and organization. Notable updates include improved handling of runtime information in the AdminBrokerProcessor
, new capabilities for tracking statistics, and refined message store configurations. These modifications aim to create a more robust framework for effectively monitoring and managing broker operations.
Files | Change Summary |
---|---|
rocketmq-broker/src/broker_runtime.rs , rocketmq-broker/src/processor/admin_broker_processor.rs |
Enhanced initialization in BrokerRuntime ; updated AdminBrokerProcessor to include message storage and stats. |
rocketmq-broker/src/processor/admin_broker_processor/broker_config_request_handler.rs |
Added get_broker_runtime_info async method for runtime info handling. |
rocketmq-broker/src/schedule/schedule_message_service.rs |
Introduced build_running_stats method for tracking scheduled message statistics. |
rocketmq-common/src/common.rs , rocketmq-common/src/common/running.rs |
Added new running and system_clock modules for improved functionality. |
rocketmq-common/src/common/broker/broker_config.rs , rocketmq-store/src/config/message_store_config.rs |
New methods for enhanced configuration access. |
rocketmq-common/src/common/mq_version.rs |
Introduced CURRENT_VERSION constant and formatted display traits for logging. |
rocketmq-common/src/common/running/running_stats.rs |
Defined RunningStats enum for various performance metrics. |
rocketmq-common/src/common/system_clock.rs |
New SystemClock struct for retrieving system time. |
rocketmq-store/src/base/store_stats_service.rs |
Enhanced with new fields and methods for performance metrics retrieval. |
rocketmq-store/src/log_file.rs , rocketmq-store/src/log_file/commit_log.rs , rocketmq-store/src/message_store/default_message_store.rs |
Added methods for runtime metrics and performance monitoring. |
Objective | Addressed | Explanation |
---|---|---|
Support AdminBrokerProcessor get_broker_runtime_info (860) |
โ | |
Enhance message store statistics tracking | โ | |
Improve runtime information handling | โ |
In the land of bytes and bits,
A rabbit hops, where logic fits.
With new stats and info bright,
The broker glows, a splendid sight!
So letโs cheer for changes made,
In RabbitMQ, progress won't fade! ๐โจ
Thank you for using CodeRabbit. We offer it for free to the OSS community and would appreciate your support in helping us grow. If you find it useful, would you consider giving us a shout-out on your favorite social media?
๐Thanks for your contribution๐. CodeRabbit(AI) will review your code first๐ฅ
๐Thanks for your contribution๐. CodeRabbit(AI) will review your code first๐ฅ
Attention: Patch coverage is 0%
with 368 lines
in your changes missing coverage. Please review.
Project coverage is 25.05%. Comparing base (
306b435
) to head (b1e1fd7
).
:umbrella: View full report in Codecov by Sentry.
:loudspeaker: Have feedback on the report? Share it here.
Support AdminBrokerProcessor get_broker_runtime_info part#1
Which Issue(s) This PR Fixes(Closes)
Fixes #860
Brief Description
How Did You Test This Change?
Summary by CodeRabbit
New Features
Bug Fixes
Documentation