examples: Update to redis 1

Author: tottoto

Cargo.lock

@@ -6,7 +6,8 @@ publish = false
 
 [dependencies]
 axum = { path = "../../axum" }
-bb8-redis = "0.24"
+bb8 = "0.9"
+redis = { version = "=1.0.0-rc.3", default-features = false, features = ["tokio-comp", "bb8"] }
 tokio = { version = "1.0", features = ["full"] }
 tracing = "0.1"
 tracing-subscriber = { version = "0.3", features = ["env-filter"] }

examples/tokio-redis/Cargo.toml

@@ -10,11 +10,7 @@ use axum::{
     routing::get,
     Router,
 };
-use bb8_redis::{
-    bb8::{self, Pool, PooledConnection},
-    redis::AsyncCommands,
-    RedisConnectionManager,
-};
+use redis::AsyncCommands;
 use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};
 
 #[tokio::main]
@@ -28,8 +24,8 @@ async fn main() {
         .init();
 
     tracing::debug!("connecting to redis");
-    let manager = RedisConnectionManager::new("redis://localhost").unwrap();
-    let pool = bb8::Pool::builder().build(manager).await.unwrap();
+    let client = redis::Client::open("redis://localhost").unwrap();
+    let pool = bb8::Pool::builder().build(client).await.unwrap();
 
     {
         // ping the database before starting
@@ -56,7 +52,7 @@ async fn main() {
     axum::serve(listener, app).await.unwrap();
 }
 
-type ConnectionPool = Pool<RedisConnectionManager>;
+type ConnectionPool = bb8::Pool<redis::Client>;
 
 async fn using_connection_pool_extractor(
     State(pool): State<ConnectionPool>,
@@ -68,7 +64,7 @@ async fn using_connection_pool_extractor(
 
 // we can also write a custom extractor that grabs a connection from the pool
 // which setup is appropriate depends on your application
-struct DatabaseConnection(PooledConnection<'static, RedisConnectionManager>);
+struct DatabaseConnection(bb8::PooledConnection<'static, redis::Client>);
 
 impl<S> FromRequestParts<S> for DatabaseConnection
 where