diff --git a/modules/core/src/main/scala/dev/profunktor/redis4cats/connection/RedisClusterClient.scala b/modules/core/src/main/scala/dev/profunktor/redis4cats/connection/RedisClusterClient.scala index 8121ce0f7..7409e6243 100644 --- a/modules/core/src/main/scala/dev/profunktor/redis4cats/connection/RedisClusterClient.scala +++ b/modules/core/src/main/scala/dev/profunktor/redis4cats/connection/RedisClusterClient.scala @@ -105,7 +105,6 @@ object RedisClusterClient { .topologyRefreshOptions( ClusterTopologyRefreshOptions .builder() - .enableAllAdaptiveRefreshTriggers() // Use implicit duration converters from scala 2.13 once 2.12 support is removed .adaptiveRefreshTriggersTimeout(Duration.ofMillis(timeout.toMillis)) .build() @@ -124,7 +123,6 @@ object RedisClusterClient { ClusterTopologyRefreshOptions .builder() .enablePeriodicRefresh(Duration.ofMillis(interval.toMillis)) - .enableAllAdaptiveRefreshTriggers() .adaptiveRefreshTriggersTimeout(Duration.ofMillis(timeout.toMillis)) .build() ) diff --git a/modules/effects/src/main/scala/dev/profunktor/redis4cats/redis.scala b/modules/effects/src/main/scala/dev/profunktor/redis4cats/redis.scala index 069c4fe5e..fd3b29781 100644 --- a/modules/effects/src/main/scala/dev/profunktor/redis4cats/redis.scala +++ b/modules/effects/src/main/scala/dev/profunktor/redis4cats/redis.scala @@ -66,6 +66,7 @@ import org.typelevel.keypool.KeyPool import java.time.Instant import java.util import java.util.concurrent.TimeUnit +import scala.annotation.nowarn import scala.concurrent.duration._ object Redis { @@ -1493,8 +1494,9 @@ private[redis4cats] class BaseRedis[F[_]: FutureLift: MonadThrow: Log, K, V]( override def flushDb(mode: FlushMode): F[Unit] = async.flatMap(_.flushdb(mode.asJava).futureLift.void) + @nowarn() override def keys(key: K): F[List[K]] = - async.flatMap(_.keys(key).futureLift.map(_.asScala.toList)) + async.flatMap(_.keysLegacy(key).futureLift.map(_.asScala.toList)) private def parseInfo(info: String): F[Map[String, String]] = FutureLift[F].delay( diff --git a/project/Dependencies.scala b/project/Dependencies.scala index cdec107a7..5e6cfc893 100644 --- a/project/Dependencies.scala +++ b/project/Dependencies.scala @@ -10,7 +10,7 @@ object Dependencies { val log4cats = "2.7.1" val keyPool = "0.4.10" - val lettuce = "6.8.1.RELEASE" + val lettuce = "7.2.0.RELEASE" val logback = "1.5.22"