Struct joyent_tokio_zookeeper::WithWatcher

pub struct WithWatcher(_);

Proxy for ZooKeeper that adds non-global watches for initiated operations.

Events from triggered watches are yielded through returned oneshot channels. All events are also produced on the global watcher stream.

Implementations

impl WithWatcher

pub fn exists(
    self,
    path: &str
) -> impl Future<Item = (ZooKeeper, Receiver<WatchedEvent>, Option<Stat>), Error = Error>

Return the Stat of the node of the given path, or None if the node does not exist.

If no errors occur, a watch will be left on the node at the given path. The watch is triggered by any successful operation that creates or deletes the node, or sets the data on the node, and in turn causes the included oneshot::Receiver to resolve.

pub fn get_children(
    self,
    path: &str
) -> impl Future<Item = (ZooKeeper, Option<(Receiver<WatchedEvent>, Vec<String>)>), Error = Error>

Return the names of the children of the node at the given path, or None if the node does not exist.

The returned list of children is not sorted and no guarantee is provided as to its natural or lexical order.

If no errors occur, a watch is left on the node at the given path. The watch is triggered by any successful operation that deletes the node at the given path, or creates or deletes a child of that node, and in turn causes the included oneshot::Receiver to resolve.

pub fn get_data(
    self,
    path: &str
) -> impl Future<Item = (ZooKeeper, Option<(Receiver<WatchedEvent>, Vec<u8>, Stat)>), Error = Error>

Return the data and the Stat of the node at the given path, or None if it does not exist.

If no errors occur, a watch is left on the node at the given path. The watch is triggered by any successful operation that sets the node's data, or deletes it, and in turn causes the included oneshot::Receiver to resolve.

Trait Implementations

impl Clone for WithWatcher

fn clone(&self) -> WithWatcher

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WithWatcher

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.