Crates.io | rocketmq-namesrv |
lib.rs | rocketmq-namesrv |
version | |
source | src |
created_at | 2024-01-28 01:53:46.847394 |
updated_at | 2024-11-17 15:04:31.906684 |
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 |
Cargo.toml error: | TOML parse error at line 18, column 1 | 18 | autolib = false | ^^^^^^^ unknown field `autolib`, expected one of `name`, `version`, `edition`, `authors`, `description`, `readme`, `license`, `repository`, `homepage`, `documentation`, `build`, `resolver`, `links`, `default-run`, `default_dash_run`, `rust-version`, `rust_dash_version`, `rust_version`, `license-file`, `license_dash_file`, `license_file`, `licenseFile`, `license_capital_file`, `forced-target`, `forced_dash_target`, `autobins`, `autotests`, `autoexamples`, `autobenches`, `publish`, `metadata`, `keywords`, `categories`, `exclude`, `include` |
size | 0 |
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 remoting_server(Rust)
Usage: rocketmq-namesrv-rust [OPTIONS]
Options:
-p, --port <PORT> rocketmq name remoting_server port [default: 9876]
-i, --ip <IP> rocketmq name remoting_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