Local adapter improvement: purge expired keys when cleanup runs

cabol · Jan 29, 2023 · 6da0b54 · 6da0b54
1 parent 8b32464
commit 6da0b54
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/lib/nebulex/adapters/local/generation.ex b/lib/nebulex/adapters/local/generation.ex
@@ -51,6 +51,7 @@ defmodule Nebulex.Adapters.Local.Generation do
   # State
   defstruct [
     :cache,
+    :name,
     :telemetry,
     :telemetry_prefix,
     :meta_tab,
@@ -402,6 +403,8 @@ defmodule Nebulex.Adapters.Local.Generation do
   defp maybe_cleanup(
          info,
          %__MODULE__{
+           cache: cache,
+           name: name,
            gc_cleanup_ref: cleanup_ref,
            gc_cleanup_min_timeout: min_timeout,
            gc_cleanup_max_timeout: max_timeout,
@@ -414,6 +417,9 @@ defmodule Nebulex.Adapters.Local.Generation do
         # Create a new generation
         :ok = new_gen(state)
 
+        # Purge expired entries
+        _ = cache.delete_all(:expired, dynamic_cache: name)
+
         # Reset the heartbeat timer
         heartbeat_ref = start_timer(gc_interval, heartbeat_ref)