Add consistent hashing to the client

Cargo.toml

@@ -2,7 +2,7 @@
 name = "async-memcached"
 version = "0.2.0"
 authors = ["Toby Lawrence <[email protected]>"]
-edition = "2018"
+edition = "2021"
 readme = "README.md"
 license = "MIT"
 description = "An Tokio-based memcached client for Rust."
@@ -18,14 +18,18 @@ dsn = "1.0"
 btoi = "0.4"
 pin-project = "1.0"
 futures = "0.3"
-tokio = { version = "1.26", default-features = false, features = ["io-util"] }
+tokio = { version = "1.26", default-features = false, features = ["net", "io-util"] }
 async-stream = "0.3"
 url = "2.5.2"
+crc32fast = "1.4.2"
+blake3 = "1.5.1"
+itertools = "0.13.0"
 
 [dev-dependencies]
 lazy_static = "1.4"
 tokio = { version = "1.26", features = ["full"] }
 rand = "0.8"
+ctor = "0.2.8"
 
 [features]
 default = []

examples/tcp.rs

@@ -2,7 +2,7 @@ use async_memcached::Client;
 
 #[tokio::main]
 async fn main() {
-    let mut client = Client::new("localhost:11211")
+    let mut client = Client::new(vec!["localhost:11211"])
         .await
         .expect("failed to create client");
 
@@ -30,7 +30,7 @@ async fn main() {
     match client.stats().await {
         Ok(stats) => {
             println!("got {} stat entries!", stats.len());
-            println!("curr items: {:?}", stats.get("curr_items"));
+            println!("curr items: {:?}", stats[0].get("curr_items"));
         }
         Err(e) => println!("error while getting stats: {:?}", e),
     }

examples/unix.rs

@@ -2,7 +2,7 @@ use async_memcached::Client;
 
 #[tokio::main]
 async fn main() {
-    let mut client = Client::new("unix:///tmp/memcached.sock")
+    let mut client = Client::new(vec!["unix:///tmp/memcached.sock"])
         .await
         .expect("failed to create client");
 

src/collectible_result.rs

@@ -0,0 +1,57 @@
+use crate::error::Error;
+
+pub(crate) struct CollectibleResult<T> {
+    pub inner: Result<Vec<T>, Error>,
+}
+
+impl<T> Default for CollectibleResult<T> {
+    fn default() -> Self {
+        CollectibleResult {
+            inner: Ok(Vec::<T>::new()),
+        }
+    }
+}
+
+impl<T> Extend<Result<Vec<T>, Error>> for CollectibleResult<T> {
+    fn extend<I>(&mut self, iter: I)
+    where
+        I: IntoIterator<Item = Result<Vec<T>, Error>>,
+    {
+        if self.inner.is_err() {
+            return;
+        }
+
+        let result = self.inner.as_mut().unwrap();
+        for item in iter {
+            match item {
+                Ok(mut vec) => result.append(&mut vec),
+                Err(e) => {
+                    self.inner = Err(e);
+                    return;
+                }
+            }
+        }
+    }
+}
+
+impl<T> Extend<Result<T, Error>> for CollectibleResult<T> {
+    fn extend<I>(&mut self, iter: I)
+    where
+        I: IntoIterator<Item = Result<T, Error>>,
+    {
+        if self.inner.is_err() {
+            return;
+        }
+
+        let result = self.inner.as_mut().unwrap();
+        for item in iter {
+            match item {
+                Ok(val) => result.push(val),
+                Err(e) => {
+                    self.inner = Err(e);
+                    return;
+                }
+            }
+        }
+    }
+}