diff --git a/src/ingest_socket_server/mod.rs b/src/ingest_socket_server/mod.rs index cb607d5..b93a9c8 100644 --- a/src/ingest_socket_server/mod.rs +++ b/src/ingest_socket_server/mod.rs @@ -11,10 +11,10 @@ // } // } -use fred::prelude::RedisClient; +use fred::prelude::Client; use crate::cli::{Cli, SocketServerArgs}; -pub async fn socketserv_main(args: Cli, specific_args: SocketServerArgs, client: RedisClient) { +pub async fn socketserv_main(args: Cli, specific_args: SocketServerArgs, client: Client) { todo!() } diff --git a/src/main.rs b/src/main.rs index e739f91..26a4243 100644 --- a/src/main.rs +++ b/src/main.rs @@ -9,12 +9,9 @@ mod web_server; use clap::Parser; use cli::{Cli, MyCommand}; -use fred::{ - clients::RedisClient, - prelude::ClientLike, - types::{ - ConnectionConfig, PerformanceConfig, ReconnectPolicy, RedisConfig, Server, ServerConfig, - }, +use fred::prelude::{ + Client as RedisClient, ClientLike, Config as RedisConfig, ConnectionConfig, PerformanceConfig, + ReconnectPolicy, Server, ServerConfig, }; use ingest_socket_server::socketserv_main; diff --git a/src/web_server/mod.rs b/src/web_server/mod.rs index 35823f9..75149b9 100644 --- a/src/web_server/mod.rs +++ b/src/web_server/mod.rs @@ -28,7 +28,7 @@ use crate::Cli; use ntex::web; pub async fn server_main(args: Cli, specific_args: WebServerArgs, client: RedisClient) { - let asd: Str = client.ping().await.unwrap(); + let asd: Str = client.ping(None).await.unwrap(); println!("Ping result: {}", asd);