Struct zookeeper::ZooKeeper

pub struct ZooKeeper {
    // some fields omitted
}

Methods

impl ZooKeeper

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<()>

Trait Implementations

impl Drop for ZooKeeper

fn drop(&mut self)

A method called when the value goes out of scope.

impl ZooKeeperExt for ZooKeeper

fn ensure_path(&self, path: &str) -> ZkResult<()>