Struct tokio_zookeeper::ZooKeeperBuilder

pub struct ZooKeeperBuilder { /* private fields */ }

Builder that allows customizing options for ZooKeeper connections.

Implementations

impl ZooKeeperBuilder

pub async fn connect( self, addr: &SocketAddr ) -> Result<(ZooKeeper, impl Stream<Item = WatchedEvent>), Error>

Connect to a ZooKeeper server instance at the given address.

A ZooKeeper instance is returned, along with a “watcher” that will provide notifications of any changes in state.

If the connection to the server fails, the client will automatically try to re-connect. Only if re-connection fails is an error returned to the client. Requests that are in-flight during a disconnect may fail and have to be retried.

pub fn set_timeout(&mut self, t: Duration)

Set the ZooKeeper session expiry timeout.

The default timeout is dictated by the server.

pub fn set_logger(&mut self, l: Logger)

Set the logger that should be used internally in the ZooKeeper client.

By default, all logging is disabled. See also the slog documentation.

Trait Implementations

impl Clone for ZooKeeperBuilder

fn clone(&self) -> ZooKeeperBuilder

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ZooKeeperBuilder

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

Formats the value using the given formatter.

impl Default for ZooKeeperBuilder

fn default() -> Self

Returns the “default value” for a type.