Crates.io | rocketmq-namesrv |
lib.rs | rocketmq-namesrv |
version | 0.2.0 |
source | src |
created_at | 2024-01-28 01:53:46.847394 |
updated_at | 2024-06-04 15:39:57.684164 |
description | Rust implementation of Apache rocketmq name sever |
homepage | https://github.com/mxsm/rocketmq-rust |
repository | https://github.com/mxsm/rocketmq-rust |
max_upload_size | |
id | 1117275 |
size | 157,379 |
Here is the rust implementation of the name server for Apache RocketMQ.
Feature list:
Not support: :broken_heart: :x:
Base support: :heart: :white_check_mark:
Perfect support: :sparkling_heart: :white_check_mark:
Feature | request code | Support | remark |
---|---|---|---|
Put KV Config | 100 | :sparkling_heart: :white_check_mark: | |
Get KV Config | 101 | :sparkling_heart: :white_check_mark: | |
Delete KV Config | 102 | :sparkling_heart: :white_check_mark: | |
Get kv list by namespace | 219 | :sparkling_heart: :white_check_mark: | |
Query Data Version | 322 | :sparkling_heart: :white_check_mark: | |
Register Broker | 103 | :sparkling_heart: :white_check_mark: | |
Unregister Broker | 104 | :sparkling_heart: :white_check_mark: | |
Broker Heartbeat | 904 | :sparkling_heart: :white_check_mark: | |
Get broker member_group | 901 | :sparkling_heart: :white_check_mark: | |
Get broker cluster info | 106 | :sparkling_heart: :white_check_mark: | |
Wipe write perm of boker | 205 | :sparkling_heart: :white_check_mark: | |
Add write perm of brober | 327 | :sparkling_heart: :white_check_mark: | |
Get all topic list from name server | 206 | :sparkling_heart: :white_check_mark: | |
Delete topic in name server | 216 | :sparkling_heart: :white_check_mark: | |
Register topic in name server | 217 | :sparkling_heart: :white_check_mark: | |
Get topics by cluster | 224 | :sparkling_heart: :white_check_mark: | |
Get system topic list from name server | 304 | :sparkling_heart: :white_check_mark: | |
Get unit topic list | 311 | :sparkling_heart: :white_check_mark: | |
Get has unit sub topic list | 312 | :sparkling_heart: :white_check_mark: | |
Get has unit sub ununit topic list | 313 | :sparkling_heart: :white_check_mark: | |
Update name server config | 318 | :broken_heart: :x: | |
Get name server config | 319 | :broken_heart: :x: |
Run the following command to see usageļ¼
windows platform
cargo run --bin rocketmq-namesrv-rust -- --help
RocketMQ Name server(Rust)
Usage: rocketmq-namesrv-rust.exe [OPTIONS]
Options:
-p, --port <PORT> rocketmq name server port [default: 9876]
-i, --ip <IP> rocketmq name server ip [default: 127.0.0.1]
-h, --help Print help
-V, --version Print version
Linux platform
$ cargo run --bin rocketmq-namesrv-rust -- --help
RocketMQ Name server(Rust)
Usage: rocketmq-namesrv-rust [OPTIONS]
Options:
-p, --port <PORT> rocketmq name server port [default: 9876]
-i, --ip <IP> rocketmq name server ip [default: 127.0.0.1]
-h, --help Print help
-V, --version Print version
Run the following command to start the name server
cargo run --bin rocketmq-namesrv-rust