use zero4rs::core::zookeeper::ZookeeperSettings;
#[tokio::main]
async fn main() {
std::env::set_var("RUST_LOG", "info");
env_logger::init();
let settings = ZookeeperSettings {
server: Some("127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183".to_string()),
};
if let Ok(_client) = zero4rs::core::zookeeper::create_client(&settings).await {
_client.try_lock("/app/locks", "_lock1/ff").await;
let mut i = 0;
loop {
tokio::time::sleep(std::time::Duration::from_secs(2)).await;
log::info!("i: {}", i);
i += 1;
}
}
}