Closed mxsm closed 2 months ago
The recent updates to the RocketMQ codebase introduce new functionalities to the StoreStatsService
to manage message operation statistics, add the Clone
trait to BrokerIdentity
struct, and improve message store optimization mechanisms. These changes ensure efficient message tracking and enhanced pull message processing.
File Path | Change Summary |
---|---|
rocketmq-common/src/common/broker/broker_config.rs |
BrokerIdentity struct now implements Clone trait along with Debug , Default , and Deserialize . |
rocketmq-store/src/base/store_stats_service.rs |
Enhanced StoreStatsService struct with new fields, methods, and a new CallSnapshot struct for managing message statistics. |
rocketmq-store/src/consume_queue/mapped_file_queue.rs |
Removed the import of std::ptr within the tests module. |
rocketmq-store/src/message_store/default_message_store.rs |
Added store_stats_service field to DefaultMessageStore , initialized it in Clone implementation and new function, and used it for increments. |
Objective (Issue #733) | Addressed | Explanation |
---|---|---|
Optimize pull message | ✅ |
The broker's traits, they grew to clone,
With stats aplenty, data's throne.
Messages swift, they come and go,
As Rocket soars, with data in tow.
A rabbit's joy in code so fine,
Pull them fast, in seamless line.
🌟🚀🐇
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🔥
Which Issue(s) This PR Fixes(Closes)
Fixes #733
Brief Description
How Did You Test This Change?
Summary by CodeRabbit
New Features
StoreStatsService
with comprehensive statistics tracking for message operations.CallSnapshot
for calculating transactions per second (TPS).Enhancements
BrokerIdentity
struct now supports cloning.Bug Fixes
mapped_file_queue
tests module.Performance
DefaultMessageStore
with the newStoreStatsService
.