mxsm/rocketmq-rust

Target Code Affected Cargo packages: rocketmq-proxy-cluster and rocketmq-proxy. File checklist: File Change rocketmq-proxy-cluster/src/remoting.rs Rename the struct, inherent implementation, and ProxyRemotingRequestHandler implementation; clarify the type's adapter role. rocketmq-proxy-cluster/src/lib.rs Replace the crate-root export with ClusterBrokerRemotingAdapter. rocketmq-proxy/src/cluster.rs Replace the facade module's export with the new name. rocketmq-proxy/src/bootstrap.rs Update the feature-gated import and Cluster-mode constructor call. rocketmq-proxy-cluster/README.md Update the component name and describe how it implements ProxyRemotingRequestHandler through the cluster client. Problems ClusterRemotingBackend does not clearly express the type's responsibility. It implements ProxyRemotingRequestHandler using a shared RocketmqClusterClient: it translates queue lock/unlock requests into client operations, forwards supported commands to a named Broker, select

Target Code Affected Cargo packages: rocketmq-broker and rocketmq-proxy-local. File checklist: File Change rocketmq-broker/src/proxy_facade.rs Rename the struct and inherent implementation; update type and constructor documentation to describe the embedded Broker. rocketmq-broker/src/lib.rs Replace the crate-root export with EmbeddedBroker. rocketmq-proxy-local/src/local.rs Update the import, construction, owned/shared/borrowed type references, and helper signatures. rocketmq-broker/README.md Update the architecture description and public API table. rocketmq-broker/README-zh_cn.md Keep the Chinese architecture description and public API table aligned with the English README. resources/rocketmq-broker-architecture.svg Update the component label and accessibility description. Problems ProxyBrokerFacade does not clearly express the component's full responsibility. It owns a BrokerRuntime, a local-request TaskGroup, and startup state. It provides configuration-based con

Target Code Affected Cargo packages: rocketmq-proxy-local and rocketmq-proxy. File checklist: File Change rocketmq-proxy-local/src/local.rs Rename the struct and inherent implementation; update all service/adapter fields, constructor parameters, helper signatures, component-factory return types, imports, and test references that name the type. Add a brief description of its command-gateway role. rocketmq-proxy-local/src/lib.rs Replace the crate-root export with LocalBrokerCommandGateway. rocketmq-proxy/src/local.rs Replace the facade module's export with the new name. rocketmq-proxy/src/lib.rs Replace the crate-root export, preserving its local-mode feature gate. rocketmq-proxy-local/README.md Update the public-export list and briefly describe the gateway's role. Problems LocalBrokerFacadeClient does not clearly express this type's responsibility. It converts Proxy operations into LocalBrokerCommand requests, applies count/byte admission budgets and deadline/cancellat

Target Code Affected Cargo packages: rocketmq-proxy-local and rocketmq-proxy. File checklist: File Change rocketmq-proxy-local/src/local.rs Rename the struct, inherent implementation, ProxyRemotingRequestHandler implementation, test import, and test construction. Add a brief description of the adapter's role. rocketmq-proxy-local/src/lib.rs Replace the crate-root export with LocalBrokerRemotingAdapter. rocketmq-proxy/src/local.rs Replace the facade module's export with the new name. rocketmq-proxy/src/lib.rs Update the crate-root export, preserving its local-mode feature gate. rocketmq-proxy/src/bootstrap.rs Update the gated import and the Local-mode adapter construction. rocketmq-proxy-local/README.md Update the public-export list. resources/proxy-architecture.svg Replace the component label with the new name and keep it readable within its box. Problems LocalRemotingBackend does not clearly describe this type's role. It implements ProxyRemotingRequestHandler by

Target Code rocketmq-controller/tests/controller_storage_faults.rs: the private FaultInjectingBackend test fixture, its inherent impl, its KeyValueStore impl, and all construction sites. There are 8 exact references in this single tracked file. The owning Cargo package is rocketmq-controller. Problems This fixture is an in-memory key-value store used by Controller durability tests. It stores string keys and byte values, can reject batch_put and write_batch with an injected storage error, and counts write_batch attempts. Tests use it to verify that failed persistence does not publish candidate state, votes, or log entries; its normal mode also supports reopen and incomplete-state scenarios. The suffix Backend does not describe the storage interface it implements. Rename the fixture to FaultInjectingKeyValueStore to make its key-value storage contract and controlled fault-injection role explicit. This is a small naming task suitable for a first contribution. Proposed Changes Rename Fa