Added redis cluster support (redis-rs#239)

This adds basic redis cluster support.

Author: mitsuhiko

Cargo.toml

@@ -27,13 +27,14 @@ futures-executor = "0.3.0"
 pin-project-lite = "0.1"
 tokio-util = { version = "0.2", features = ["codec"] }
 tokio = { version = "0.2", features = ["tcp", "uds", "io-util", "sync", "stream"] }
+crc16 = { version = "0.4.0", optional = true }
+rand = { version = "0.7.0", optional = true }
 
 [features]
-default = [ "geospatial" ]
-
+default = ["geospatial"]
 tokio-rt-core = ["tokio/rt-core"]
-
 geospatial = []
+cluster = ["crc16", "rand"]
 
 [dev-dependencies]
 rand = "0.7"
@@ -45,8 +46,6 @@ criterion = "0.3"
 partial-io = { version = "0.3", features = ["tokio", "quickcheck"] }
 quickcheck = "0.6"
 tokio = { version = "0.2", features = ["rt-core", "macros"] }
-# End of dev-dependencies
-
 
 [[test]]
 name = "test_async"

LICENSE

@@ -1,4 +1,6 @@
-Copyright (c) 2013 by Armin Ronacher.
+Copyright (c) 2013-2019 by Armin Ronacher, Jan-Erik Rediger.
+
+Redis cluster code in parts copyright (c) 2018 by Atsushi Koge.
 
 Some rights reserved.
 

Makefile

@@ -12,7 +12,7 @@ test:
 	@echo "===================================================================="
 	@echo "Testing Connection Type UNIX SOCKETS"
 	@echo "===================================================================="
-	@REDISRS_SERVER_TYPE=unix cargo test --all-features
+	@REDISRS_SERVER_TYPE=unix cargo test --all-features -- --skip test_cluster
 
 test-single: RUST_TEST_THREADS=1
 test-single: test

src/client.rs

@@ -106,4 +106,20 @@ impl ConnectionLike for Client {
     fn get_db(&self) -> i64 {
         self.connection_info.db
     }
+
+    fn check_connection(&mut self) -> bool {
+        if let Ok(mut conn) = self.get_connection() {
+            conn.check_connection()
+        } else {
+            false
+        }
+    }
+
+    fn is_open(&self) -> bool {
+        if let Ok(conn) = self.get_connection() {
+            conn.is_open()
+        } else {
+            false
+        }
+    }
 }