Consider a connection issue a transient one

Kuadrant · Apr 22, 2024 · 3b346a2 · 3b346a2
1 parent 9d5eed7
commit 3b346a2
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/limitador/src/storage/redis/mod.rs b/limitador/src/storage/redis/mod.rs
@@ -24,7 +24,10 @@ impl From<RedisError> for StorageErr {
  fn from(e: RedisError) -> Self {
  Self {
  msg: e.to_string(),
- transient: e.is_timeout() || e.is_connection_dropped() || e.is_cluster_error(),
+ transient: e.is_timeout()
+ || e.is_connection_dropped()
+ || e.is_cluster_error()
+ || e.is_connection_refusal(),
  }
  }
 }

diff --git a/limitador/src/storage/redis/redis_cached.rs b/limitador/src/storage/redis/redis_cached.rs
@@ -220,9 +220,10 @@ impl CachedRedisStorage {
  .expect("This couldn't fail in the past, yet now it did somehow!"),
  2,
  100,
- 6,
+ 1,
  response_timeout,
- Duration::from_secs(5),
+ // TLS handshake might result in an additional 2 RTTs to Redis, adding some headroom as well
+ (response_timeout * 3) + Duration::from_millis(50),
  )
  .await?;