Add deleteScanCount to improve performance on wildcard invalidation o…

…f caches.
dave08 · Jun 4, 2024 · cc0da5a · cc0da5a
1 parent 66d4ddf
commit cc0da5a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/build.gradle.kts b/build.gradle.kts
@@ -3,7 +3,7 @@ plugins {
 }
 
 group = "org.github.dave08.kacheable"
-version = "0.1.2"
+version = "0.1.4"
 
 kotlin {
     jvmToolchain(11)

diff --git a/kacheable-lettuce/src/main/kotlin/com/github/dave08/kacheable/RedisKacheableStore.kt b/kacheable-lettuce/src/main/kotlin/com/github/dave08/kacheable/RedisKacheableStore.kt
@@ -13,6 +13,7 @@ import kotlin.time.Duration
 class RedisKacheableStore(
     private val conn: StatefulRedisConnection<String, String>,
     private val deleteFromPatternInChunksOf: Int = 20,
+    private val deleteScanCount: Long = 1000, 
 ) : KacheableStore {
 
     override suspend fun delete(key: String) {
@@ -21,7 +22,7 @@ class RedisKacheableStore(
         else withContext(Dispatchers.IO) {
             val commands = conn.sync()
 
-            ScanIterator.scan(commands, ScanArgs().match(key)).asSequence()
+            ScanIterator.scan(commands, ScanArgs().match(key).limit(deleteScanCount)).asSequence()
                 .chunked(deleteFromPatternInChunksOf)
                 .forEach { keys ->
                     if (keys.isNotEmpty()) commands.del(*(keys.toTypedArray()))