Struct tokio_zookeeper::WatchGlobally
source · pub struct WatchGlobally(_);
Expand description
Proxy for ZooKeeper
that adds watches for initiated operations.
Triggered watches produce events on the global watcher stream.
Implementations§
source§impl WatchGlobally
impl WatchGlobally
sourcepub fn exists(
self,
path: &str
) -> impl Future<Item = (ZooKeeper, Option<Stat>), Error = Error>
pub fn exists(
self,
path: &str
) -> impl Future<Item = (ZooKeeper, 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 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.
sourcepub fn get_children(
self,
path: &str
) -> impl Future<Item = (ZooKeeper, Option<Vec<String>>), Error = Error>
pub fn get_children(
self,
path: &str
) -> impl Future<Item = (ZooKeeper, Option<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. When the watch triggers, an event is sent to the global
watcher stream.
sourcepub fn get_data(
self,
path: &str
) -> impl Future<Item = (ZooKeeper, Option<(Vec<u8>, Stat)>), Error = Error>
pub fn get_data(
self,
path: &str
) -> impl Future<Item = (ZooKeeper, Option<(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. When the watch
triggers, an event is sent to the global watcher stream.
Trait Implementations§
source§impl Clone for WatchGlobally
impl Clone for WatchGlobally
source§fn clone(&self) -> WatchGlobally
fn clone(&self) -> WatchGlobally
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read more