remove removalNotification

Signed-off-by: Peter Alfonsi <petealft@amazon.com>

Author: Peter Alfonsi

modules/cache-common/src/internalClusterTest/java/org/opensearch/cache/common/tier/TieredSpilloverCacheIT.java

@@ -254,8 +254,6 @@ public void testWithDynamicHeapTookTimePolicy() throws Exception {
             assertSearchResponse(resp);
         }
         RequestCacheStats requestCacheStats = getRequestCacheStats(client, "index");
-        // Check the old stats API has properly subtracted off the byte size for key, without incrementing evictions.
-        assertEquals(0, requestCacheStats.getMemorySizeInBytes());
         assertEquals(0, requestCacheStats.getEvictions());
     }
 

modules/cache-common/src/main/java/org/opensearch/cache/common/tier/TieredSpilloverCache.java

@@ -278,9 +278,6 @@ public void put(ICacheKey<K> key, V value) {
                     }
                     updateStatsOnPut(cacheValueTuple.v2(), key, value);
                 }
-            } else {
-                // Signal to the caller that the key didn't enter the cache by sending a removal notification.
-                removalListener.onRemoval(new RemovalNotification<>(key, value, RemovalReason.EXPLICIT));
             }
         }
 
@@ -403,11 +400,6 @@ private Tuple<V, Tuple<Boolean, Boolean>> compute(
                     throw new IllegalStateException(ex);
                 }
             }
-            if (wasRejectedByPolicy) {
-                // Signal to the caller that the key didn't enter the cache by sending a removal notification.
-                // This case does not count as a cache miss.
-                removalListener.onRemoval(new RemovalNotification<>(key, value, RemovalReason.EXPLICIT));
-            }
             return new Tuple<>(value, new Tuple<>(wasCacheMiss, wasRejectedByPolicy));
         }
 

modules/cache-common/src/test/java/org/opensearch/cache/common/tier/TieredSpilloverCacheTests.java

@@ -1567,7 +1567,7 @@ public CachedQueryResult.PolicyValues apply(String s) {
                 expectedKeys++;
             }
         }
-        assertEquals(keyValueMap.size() - expectedKeys, removalListener.evictionsMetric.count());
+        assertEquals(0, removalListener.evictionsMetric.count());
         assertEquals(0, getHitsForTier(tieredSpilloverCache, TIER_DIMENSION_VALUE_ON_HEAP));
         assertEquals(expectedKeys, tieredSpilloverCache.count());
 
@@ -1657,8 +1657,7 @@ public void testEntryPoliciesWithPut() throws Exception {
 
         assertEquals(0, getEvictionsForTier(tieredSpilloverCache, TIER_DIMENSION_VALUE_ON_HEAP));
         assertEquals(expectedKeys, getTotalStatsSnapshot(tieredSpilloverCache).getItems());
-        assertEquals(keyValuePairs.size() - expectedKeys, removalListener.evictionsMetric.count()); // Policy rejects should send a removal
-                                                                                                    // notification
+        assertEquals(0, removalListener.evictionsMetric.count());
     }
 
     public void testEntryPoliciesConcurrentlyWithComputeIfAbsent() throws Exception {
@@ -1745,8 +1744,7 @@ public void testEntryPoliciesConcurrentlyWithComputeIfAbsent() throws Exception
 
         assertEquals(0, getEvictionsForTier(tieredSpilloverCache, TIER_DIMENSION_VALUE_ON_HEAP));
         assertEquals(expectedKeys, getTotalStatsSnapshot(tieredSpilloverCache).getItems());
-        // Policy rejects should send a removal notification every time the caller attempts to put them in
-        assertEquals((keyValuePairs.size() - expectedKeys) * numRepetitionsPerKey, removalListener.evictionsMetric.count());
+        assertEquals(0, removalListener.evictionsMetric.count());
     }
 
     public void testPutWithDiskCacheDisabledSetting() throws Exception {