1 unstable release
0.1.0 | Dec 15, 2022 |
---|
#1433 in #web
49KB
1K
SLoC
洛书客户端
安装洛书
cargo install luoshu
运行洛书
不开放管理web接口
luoshu
开放管理web接口
luoshu --web
洛书客户端使用
引入洛书客户端
[workspace.dependencies]
# ...
luoshu_rust_client = "0.1.0"
# ...
订阅配置信息,并注册服务到洛书并编写业务代码
use std::thread::sleep;
use luoshu_rust_client::LuoshuClient;
#[derive(Debug, Serialize, Deserialize, Clone)]
struct Config {
test1: String,
test2: Vec<usize>,
}
#[tokio::test]
async fn it_works() -> LuoshuClientResult<()> {
let mut client = LuoshuClient::new(15666, "test_rust_server".to_string(), None).await;
client
.subscribe_config(
"test_config2".to_string(),
|config: Config| println!("config changed:{:#?}", config),
None,
)
.await?;
tokio::spawn(async move {
client.registry().await.expect("TODO: panic message");
});
// 此处使用无限循环模拟服务的持续运行
loop {
println!("sleep");
sleep(Duration::from_secs(10))
}
}
Dependencies
~23–38MB
~652K SLoC