qrush_engine/utils/
rdconfig.rs

1// src/utils/rdconfig.rs
2use redis::{aio::MultiplexedConnection, Client}; // Keep MultiplexedConnection
3use crate::config::get_redis_url;
4
5pub async fn get_redis_connection() -> redis::RedisResult<MultiplexedConnection> {
6    let redis_url = get_redis_url();
7    let client = Client::open(redis_url)?;
8    client.get_multiplexed_async_connection().await
9}