Code Monkey home page Code Monkey logo

rust-zookeeper's Introduction

zookeeper-async

Version build status

Async Zookeeper client written 100% in Rust, based on tokio.

This library is intended to be equivalent with the official (low-level) ZooKeeper client which ships with the official ZK distribution.

Some Curator recipes are available in the recipes directory.

Examples

Check the examples directory

Features and Bugs

If you find a bug or would like to see a feature implemented please raise an issue or send a pull-request.

Running tests

cd zk-test-cluster
mvn clean package
cd ..
cargo test

Contributing

All contributions are welcome! If you need some inspiration, please take a look at the currently open issues.

rust-zookeeper's People

Contributors

bonifaido avatar cmsd2 avatar d-e-s-o avatar davidwilemski avatar dependabot[bot] avatar drusellers avatar ekmartin avatar inphi avatar jonhoo avatar jwilm avatar krojew avatar maximfischuk avatar rgs1 avatar sakateka avatar serprex avatar szqh97 avatar tgockel avatar tsxiaofang avatar unlawfulmonad avatar

Stargazers

avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar

Watchers

avatar

Forkers

sebosp standardgalactic tsxiaofang maximfischuk

rust-zookeeper's Issues

Handle leakage during reconnection

2023-06-15 10:57:44.995837137 INFO zookeeper_async::io - Establishing Zk connection
2023-06-15 10:57:44.995838749 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:326 Zk session timeout
2023-06-15 10:57:44.995841665 INFO zookeeper_async::io - Connecting to new server 127.0.0.1:11100
2023-06-15 10:57:44.996068131 INFO upload::zkdubbo - stat_handler: NotConnected
2023-06-15 10:57:44.996077542 INFO upload::zkdubbo - stat_handler: Connecting
2023-06-15 10:57:44.996091156 INFO zookeeper_async::io - Started connecting to 127.0.0.1:11100
2023-06-15 10:57:44.996118924 INFO zookeeper_async::io - Started connecting to 127.0.0.1:11100
2023-06-15 10:57:44.996154065 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:504 Connection closed: read
2023-06-15 10:57:44.996156177 INFO zookeeper_async::io - Establishing Zk connection
2023-06-15 10:57:44.996158083 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:326 Zk session timeout
2023-06-15 10:57:44.996161094 INFO zookeeper_async::io - Connecting to new server 127.0.0.1:11100
2023-06-15 10:57:44.996203262 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:504 Connection closed: read
2023-06-15 10:57:44.996205489 INFO zookeeper_async::io - Establishing Zk connection
2023-06-15 10:57:44.996207351 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:326 Zk session timeout
2023-06-15 10:57:44.996211345 INFO zookeeper_async::io - Connecting to new server 127.0.0.1:11100
2023-06-15 10:57:44.997407499 INFO zookeeper_async::io - Started connecting to 127.0.0.1:11100
2023-06-15 10:57:44.997455799 INFO zookeeper_async::io - Started connecting to 127.0.0.1:11100
2023-06-15 10:57:44.997504533 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:504 Connection closed: read
2023-06-15 10:57:44.997506323 INFO zookeeper_async::io - Establishing Zk connection
2023-06-15 10:57:44.997508066 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:326 Zk session timeout
2023-06-15 10:57:44.997510504 INFO zookeeper_async::io - Connecting to new server 127.0.0.1:11100
2023-06-15 10:57:44.997554477 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:504 Connection closed: read
2023-06-15 10:57:44.997556461 INFO zookeeper_async::io - Establishing Zk connection
2023-06-15 10:57:44.997558612 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:326 Zk session timeout
2023-06-15 10:57:44.997562128 INFO zookeeper_async::io - Connecting to new server 127.0.0.1:11100
2023-06-15 10:57:45.002352373 INFO zookeeper_async::io - Started connecting to 127.0.0.1:11100
2023-06-15 10:57:45.002473841 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:504 Connection closed: read
2023-06-15 10:57:45.002476545 INFO zookeeper_async::io - Establishing Zk connection
2023-06-15 10:57:45.002479218 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:326 Zk session timeout
2023-06-15 10:57:45.00248305 INFO zookeeper_async::io - Connecting to new server 127.0.0.1:11100
2023-06-15 10:57:45.003910311 INFO zookeeper_async::io - Started connecting to 127.0.0.1:11100
2023-06-15 10:57:45.003926622 INFO zookeeper_async::io - Started connecting to 127.0.0.1:11100
2023-06-15 10:57:45.004042306 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:504 Connection closed: read
2023-06-15 10:57:45.004044615 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:504 Connection closed: read
2023-06-15 10:57:45.004065603 INFO zookeeper_async::io - Establishing Zk connection
2023-06-15 10:57:45.004068017 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:326 Zk session timeout
2023-06-15 10:57:45.004072465 INFO zookeeper_async::io - Connecting to new server 127.0.0.1:11100
2023-06-15 10:57:45.004091104 INFO zookeeper_async::io - Establishing Zk connection
2023-06-15 10:57:45.00409343 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:326 Zk session timeout
2023-06-15 10:57:45.004102486 INFO zookeeper_async::io - Connecting to new server 127.0.0.1:11100
2023-06-15 10:57:45.004283162 INFO zookeeper_async::io - Started connecting to 127.0.0.1:11100
2023-06-15 10:57:45.004382261 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:504 Connection closed: read
2023-06-15 10:57:45.004389526 INFO zookeeper_async::io - Establishing Zk connection
2023-06-15 10:57:45.00439151 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:326 Zk session timeout
2023-06-15 10:57:45.004395472 INFO zookeeper_async::io - Connecting to new server 127.0.0.1:11100
2023-06-15 10:57:45.004782919 INFO zookeeper_async::io - Started connecting to 127.0.0.1:11100
2023-06-15 10:57:45.004884841 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:504 Connection closed: read
2023-06-15 10:57:45.004897201 INFO zookeeper_async::io - Establishing Zk connection
2023-06-15 10:57:45.00489958 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:326 Zk session timeout
2023-06-15 10:57:45.004904453 INFO zookeeper_async::io - Connecting to new server 127.0.0.1:11100
2023-06-15 10:57:45.004933371 INFO zookeeper_async::io - Started connecting to 127.0.0.1:11100
2023-06-15 10:57:45.005019585 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:504 Connection closed: read
2023-06-15 10:57:45.005021493 INFO zookeeper_async::io - Establishing Zk connection
2023-06-15 10:57:45.005023164 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:326 Zk session timeout
2023-06-15 10:57:45.005025981 INFO zookeeper_async::io - Connecting to new server 127.0.0.1:11100
2023-06-15 10:57:45.011898607 INFO zookeeper_async::io - Started connecting to 127.0.0.1:11100
2023-06-15 10:57:45.011913133 INFO zookeeper_async::io - Started connecting to 127.0.0.1:11100
2023-06-15 10:57:45.012032197 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:504 Connection closed: read
2023-06-15 10:57:45.012032532 WARN /root/.cargo/registry/src/rsproxy.cn-8f6827c7555bfaf8/zookeeper-async-4.1.1/src/io.rs:504 Connection closed: read
2023-06-15 10:57:45.012047159 INFO zookeeper_async::io - Establishing Zk connection

panic when disable and enable network card

src/io.rs
let conn_resp = match ConnectResponse::read_from(&mut data) {
Ok(conn_resp) => conn_resp,
Err(e) => {
221 panic!("Failed to parse ConnectResponse {:?}", e);
// self.reconnect();
// return
}
};

Recommend Projects

  • React photo React

    A declarative, efficient, and flexible JavaScript library for building user interfaces.

  • Vue.js photo Vue.js

    🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.

  • Typescript photo Typescript

    TypeScript is a superset of JavaScript that compiles to clean JavaScript output.

  • TensorFlow photo TensorFlow

    An Open Source Machine Learning Framework for Everyone

  • Django photo Django

    The Web framework for perfectionists with deadlines.

  • D3 photo D3

    Bring data to life with SVG, Canvas and HTML. 📊📈🎉

Recommend Topics

  • javascript

    JavaScript (JS) is a lightweight interpreted programming language with first-class functions.

  • web

    Some thing interesting about web. New door for the world.

  • server

    A server is a program made to process requests and deliver data to clients.

  • Machine learning

    Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.

  • Game

    Some thing interesting about game, make everyone happy.

Recommend Org

  • Facebook photo Facebook

    We are working to build community through open source technology. NB: members must have two-factor auth.

  • Microsoft photo Microsoft

    Open source projects and samples from Microsoft.

  • Google photo Google

    Google ❤️ Open Source for everyone.

  • D3 photo D3

    Data-Driven Documents codes.