Struct tokio_zookeeper::WatchGlobally

pub struct WatchGlobally<'a>(/* private fields */);

Proxy for ZooKeeper that adds watches for initiated operations.

Triggered watches produce events on the global watcher stream.

Implementations

impl<'a> WatchGlobally<'a>

pub async fn exists(&self, path: &str) -> Result<Option<Stat>, 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 is 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 node’s data. When the watch triggers, an event is sent to the global watcher stream.

pub async fn get_children( &self, path: &str ) -> Result<Option<Vec<String>>, 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. When the watch triggers, an event is sent to the global watcher stream.

pub async fn get_data( &self, path: &str ) -> Result<Option<(Vec<u8>, Stat)>, 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. When the watch triggers, an event is sent to the global watcher stream.

Trait Implementations

impl<'a> Clone for WatchGlobally<'a>

fn clone(&self) -> WatchGlobally<'a>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for WatchGlobally<'a>

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

Formats the value using the given formatter.