#1679 - ENH: Support enabling/disabling L2 cache by "region" at runtime

src/main/java/io/ebeaninternal/server/cache/DefaultServerCacheManager.java

@@ -1,14 +1,29 @@
 package io.ebeaninternal.server.cache;
 
 import io.ebean.cache.ServerCache;
+import io.ebean.cache.ServerCacheRegion;
 import io.ebean.cache.ServerCacheType;
+import io.ebeaninternal.api.SpiCacheRegion;
 import io.ebeaninternal.server.cluster.ClusterManager;
+import io.ebeaninternal.server.deploy.DCacheRegion;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
 
 /**
  * Manages the bean and query caches.
  */
 public class DefaultServerCacheManager implements SpiCacheManager {
 
+  private static final Logger log = LoggerFactory.getLogger("io.ebean.cache.REGION");
+
+  private final Map<String, SpiCacheRegion> regionMap = new HashMap<>();
+
   private final ClusterManager clusterManager;
 
   private final DefaultCacheHolder cacheHolder;
@@ -39,6 +54,47 @@ public class DefaultServerCacheManager implements SpiCacheManager {
     return localL2Caching;
   }
 
+  @Override
+  public List<ServerCacheRegion> allRegions() {
+    return new ArrayList<>(regionMap.values());
+  }
+
+  @Override
+  public void setEnabledRegions(String regions) {
+
+    List<String> enabledRegions = Arrays.asList(regions.split(","));
+    List<String> disabledRegions = new ArrayList<>();
+
+    for (SpiCacheRegion region : regionMap.values()) {
+      if (enabledRegions.contains(region.getName())) {
+        if (!region.isEnabled()) {
+          region.setEnabled(true);
+          log.debug("Cache region[{}] enabled", region.getName());
+        }
+      } else {
+        disabledRegions.add(region.getName());
+        if (region.isEnabled()) {
+          region.setEnabled(false);
+          log.debug("Cache region[{}] disabled", region.getName());
+        }
+      }
+    }
+    log.info("Cache regions enabled:{} disabled:{}", enabledRegions, disabledRegions);
+  }
+
+  @Override
+  public void setAllRegionsEnabled(boolean enabled) {
+    log.debug("All cache regions enabled[{}]", enabled);
+    for (SpiCacheRegion region : regionMap.values()) {
+      region.setEnabled(enabled);
+    }
+  }
+
+  @Override
+  public SpiCacheRegion getRegion(String region) {
+    return regionMap.computeIfAbsent(region, DCacheRegion::new);
+  }
+
   /**
    * Clear all caches.
    */