Struct zookeeper_client::PersistentWatcher

pub struct PersistentWatcher { /* private fields */ }

Watcher for persistent and recursive watch.

Implementations

impl PersistentWatcher

pub async fn changed(&mut self) -> WatchedEvent

Waits for next event which could be node event or session activities.

Panics

Panic after terminal session event received.

BUG

Events during reconnection could be lost due to ZOOKEEPER-4698, as events during connection loss are not delivered in auto watch reset. So, callers should rebuild their knowledge to avoid data inconsistency after SessionState::Disconnected and following SessionState::SyncConnected. See also OneshotWatcher::changed.

pub async fn remove(self) -> Result<(), Error>

Removes this watcher.

Cautions

It is a best effect as ZooKeper (ZOOKEEPER-4472) does not support persistent watch removing individually.

Trait Implementations

impl Debug for PersistentWatcher

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

Formats the value using the given formatter.