[multi-operations] redis: delete matched proto

lib/any_cache/adapters/redis.rb

@@ -45,7 +45,25 @@ def supported_driver?(driver)
                    :flushdb,
                    :exists,
                    :mapped_mget,
-                   :mapped_mset
+                   :mapped_mset,
+                   :scan
+
+    # @return [AnyCache::Adapters::Redis::DeleteMatchedHeavy]
+    attr_reader :delete_matched_heavy
+
+    # @return [AnyCache::Adapters::Redis::DeleteMatchedSoftly]
+    attr_reader :delete_matched_softly
+
+    # @param driver [Object]
+    # @return [void]
+    #
+    # @api private
+    # @since 0.3.0
+    def initialize(driver)
+      super
+      @delete_matched_heavy  = DeleteMatchedHeavy.new(self)
+      @delete_matched_softly = DeleteMatchedSoftly.new(self)
+    end
 
     # @param key [String]
     # @param options [Hash]
@@ -138,7 +156,10 @@ def delete(key, **options)
     # @api private
     # @since 0.3.0
     def delete_matched(pattern, **options)
-
+      case pattern
+      when String then delete_matched_softly.call(pattern, **options)
+      when Regexp then delete_matched_heavy.call(pattern, **options)
+      end
     end
 
     # @param key [String]

lib/any_cache/adapters/redis/delete_matched_basic.rb

@@ -0,0 +1,40 @@
+# frozen_string_literal: true
+
+class AnyCache::Adapters::Redis
+  class DeleteMatchedBasic
+    # @since 0.3.0
+    extend Forwardable
+
+    # @return [String]
+    #
+    # @api private
+    # @since 0.3.0
+    CURSOR_LOOP_FLAG = "0"
+
+    # @return [Integer]
+    #
+    # @api private
+    # @since 0.3.0
+    BATCH_SIZE = 10
+
+    # @return [AnyCache::Adapters::Redis]
+    #
+    # @api private
+    # @since 0.3.0
+    attr_reader :adapter
+
+    # @param adapter [AnyCache::Adapters::Redis]
+    # @return [void]
+    #
+    # @api private
+    # @since 0.3.0
+    def initiaalize(adapter)
+      @adapter = adapter
+    end
+
+    # @!method delete_matched(pattern, **options)
+    #   @param pattern [Object]
+    #   @param options [Hash]
+    #   @return [void]
+  end
+end

lib/any_cache/adapters/redis/delete_matched_heavy.rb

@@ -0,0 +1,21 @@
+# frozen_string_literal: true
+
+class AnyCache::Adapters::Redis
+  class DeleteMatchedHeavy < DeleteMatchedBasic
+    # @param pattern [Regexp]
+    # @param options [Hash]
+    # @return [void]
+    #
+    # @api private
+    # @since 0.3.0
+    def delete_matched(pattern, **options)
+      cursor = CURSOR_LOOP_FLAG
+
+      loop do
+        cursor, keys = adapter.scan(cursor, count: BATCH_SIZE)
+        adapter.del(keys.grep(pattern))
+        break if cursor == CURSOR_LOOP_FLAG
+      end
+    end
+  end
+end

lib/any_cache/adapters/redis/delete_matched_softly.rb

@@ -0,0 +1,21 @@
+# frozen_string_literal: true
+
+class AnyCache::Adapters::Redis
+  class DeleteMatchedSoftly < DeleteMatchedBasic
+    # @param pattern [String]
+    # @param options [Hash]
+    # @return [void]
+    #
+    # @api private
+    # @since 0.3.0
+    def delete_matched(pattern, **options)
+      cursor = CURSOR_LOOP_FLAG
+
+      loop do
+        cursor, keys = adapter.scan(cursor, match: pattern, count: BATCH_SIZE)
+        adapter.del(keys)
+        break if cursor == CURSOR_LOOP_FLAG
+      end
+    end
+  end
+end