pub mod with_zk;
pub mod zk_client;
pub use with_zk::*;
pub use zk_client::*;
#[derive(serde::Deserialize, Clone)]
pub struct ZookeeperSettings {
pub server: Option<String>,
}
impl Default for ZookeeperSettings {
fn default() -> Self {
Self {
server: Some("127.0.0.1:2181".to_string()),
}
}
}
impl ZookeeperSettings {
pub fn servers(&self) -> String {
self.server.clone().unwrap()
}
pub fn get(settings: &Option<ZookeeperSettings>) -> Self {
let _default = Self::default();
if settings.is_some() {
let mut s = settings.clone().unwrap();
if s.server.is_none() {
s.server = _default.server;
}
s
} else {
_default
}
}
}