Struct zookeeper::ZooKeeper
[−]
[src]
pub struct ZooKeeper { // some fields omitted }
pub struct ZooKeeper { // some fields omitted }
impl ZooKeeper
[src]fn connect<W>(connect_string: &str, timeout: Duration, watcher: W) -> ZkResult<ZooKeeper> where W: Watcher + 'static
fn add_auth(&self, scheme: &str, auth: Vec<u8>) -> ZkResult<()>
fn create(&self, path: &str, data: Vec<u8>, acl: Vec<Acl>, mode: CreateMode) -> ZkResult<String>
fn delete(&self, path: &str, version: i32) -> ZkResult<()>
fn exists(&self, path: &str, watch: bool) -> ZkResult<Option<Stat>>
fn exists_w<W: Fn(&WatchedEvent) + Send + 'static>(&self, path: &str, watcher: W) -> ZkResult<Stat>
fn get_acl(&self, path: &str) -> ZkResult<(Vec<Acl>, Stat)>
fn get_children_w<W: Fn(&WatchedEvent) + Send + 'static>(&self, path: &str, watcher: W) -> ZkResult<Vec<String>>
fn get_children(&self, path: &str, watch: bool) -> ZkResult<Vec<String>>
fn get_data(&self, path: &str, watch: bool) -> ZkResult<(Vec<u8>, Stat)>
fn get_data_w<W: Fn(&WatchedEvent) + Send + 'static>(&self, path: &str, watcher: W) -> ZkResult<(Vec<u8>, Stat)>
fn set_acl(&self, path: &str, acl: Vec<Acl>, version: i32) -> ZkResult<Stat>
fn set_data(&self, path: &str, data: Vec<u8>, version: i32) -> ZkResult<Stat>
fn add_listener<Listener: Fn(ZkState) + Send + 'static>(&self, listener: Listener) -> Subscription
fn remove_listener(&self, sub: Subscription)
fn close(&self) -> ZkResult<()>
impl Drop for ZooKeeper
[src]impl ZooKeeperExt for ZooKeeper
[src]fn ensure_path(&self, path: &str) -> ZkResult<()>