rocketmq-namesrv

Crates.iorocketmq-namesrv
lib.rsrocketmq-namesrv
version
sourcesrc
created_at2024-01-28 01:53:46.847394
updated_at2024-11-17 15:04:31.906684
descriptionRust implementation of Apache rocketmq name sever
homepagehttps://github.com/mxsm/rocketmq-rust
repositoryhttps://github.com/mxsm/rocketmq-rust
max_upload_size
id1117275
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`
size0
mxsm (mxsm)

documentation

README

The Rust Implementation of Apache RocketMQ Name server

Overview

Here is the rust implementation of the name server for Apache RocketMQ.

Feature

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:

Getting Started

Requirements

  1. rust toolchain MSRV is 1.75.(stable,nightly)

Run name server

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
Commit count: 763

cargo fmt