fix(deps): update rust crate redis to 0.28.0 (#37)

* fix(deps): update rust crate redis to 0.28.0 * deps: updated redis to 0.28.1 & redis-test to 0.8.0 * fix: new version of redis requires Send trait --------- Co-authored-by: renovate[bot] <29139614+renovate[bot]@users.noreply.github.com> Co-authored-by: AH-dark <[email protected]>
AH-dark · Jan 12, 2025 · ac8e19f · ac8e19f
1 parent a791254
commit ac8e19f
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/Cargo.toml b/Cargo.toml
@@ -52,8 +52,8 @@ tokio = { version = "1", features = ["macros", "rt-multi-thread", "time", "sync"
 uuid = { version = "1", features = ["v4"] }
 
 etcd-client = { version = "0.14", optional = true }
-redis = { version = "0.27.6", optional = true, features = ["tokio-comp"] }
+redis = { version = "0.28.1", optional = true, features = ["tokio-comp"] }
 
 [dev-dependencies]
 pretty_env_logger = "0.5"
-redis-test = { version = "0.6.0", features = ["aio"] }
+redis-test = { version = "0.8.0", features = ["aio"] }
diff --git a/src/driver/redis.rs b/src/driver/redis.rs
@@ -139,11 +139,11 @@ where
 /// * `node_id` - The id of the node
 /// * `timeout` - The timeout of the node
 /// * `con` - The redis connection
-async fn register_node<C: ConnectionLike + Send>(
+async fn register_node<C: ConnectionLike + Send + Sync>(
     node_id: &str,
     timeout: u64,
     con: &mut C,
-) -> Result<(), Box<dyn std::error::Error>> {
+) -> Result<(), redis::RedisError> {
     con.set_ex(node_id, node_id, timeout).await?;
     Ok(())
 }
@@ -161,7 +161,7 @@ async fn register_node<C: ConnectionLike + Send>(
 /// # Returns
 ///
 /// * `Result<(), Box<dyn std::error::Error>` - The result of the function
-async fn heartbeat<C: ConnectionLike + Send>(
+async fn heartbeat<C: ConnectionLike + Send + Sync>(
     node_id: &str,
     timeout: u64,
     con: C,

diff --git a/src/driver/redis_zset.rs b/src/driver/redis_zset.rs
@@ -146,12 +146,12 @@ where
 /// * `node_id` - The id of the node
 /// * `con` - The redis connection
 /// * `time` - The time to register the node
-async fn register_node<C: ConnectionLike + Send>(
+async fn register_node<C: ConnectionLike + Send + Sync>(
     service_name: &str,
     node_id: &str,
     con: &mut C,
     time: i64,
-) -> Result<(), Box<dyn std::error::Error>> {
+) -> Result<(), redis::RedisError> {
     con.zadd(utils::get_zset_key(service_name), node_id, time).await?;
 
     Ok(())