rust-zookeeper
rust-zookeeper copied to clipboard
bonifaido
Pure Rust library for Apache ZooKeeper built on MIO
# leader.rs fn start let latch = self.clone(); // this step ,while LeaderLatch has field zk,zookeeper has ref self let subscription = self.zk.add_listener(move |x| handle_state_change(&latch, x)); # leader.rs fn stop...
With the 2021 edition "coming soon", @bonifaido WDYT of upgrading to the 2018 edition to ease the future switch to the 2021 edition when released?
There seems to be an error that shows up when dropping `ZooKeeper` after previously closing the connection with `ZooKeeper::close`. I believe this is because `ZooKeeper::drop` will try to close the...
When trying to connect to a zk server using a ipv6 address, the connection fails with `Failed to read socket: Os { code: 10049, kind: AddrNotAvailable`.
https://zookeeper.apache.org/doc/r3.1.2/recipes.html section 'Locks' gives an example on how to do locking. I see an open issue also has something to do with locking: https://github.com/bonifaido/rust-zookeeper/issues/17. I can write some rust code...
I don't have any ZooKeeper server running, but `ZooKeeper::connect` will not throw an error. My expectation is that if it can not connect, it notifies me. Furthermore, take this code:...
After session timeouts (for example by moving the process to the background), the connection isn't reestablished. Operations end with "error sending request: Disconnected".
For the mio-0.6 changes, many components were deprecated and moved to the [mio-more](https://github.com/carllerche/mio-more) package. Unfortunately, this does not yet exist on crates.io and might not ever exist there -- the...
