Add config key in circuit breaker config to fetch config level thresholds

Author: Gg-harness

grpc-circuitbreaker-utils/src/main/java/org/hypertrace/circuitbreaker/grpcutils/CircuitBreakerConfiguration.java

@@ -24,4 +24,7 @@ public class CircuitBreakerConfiguration<T> {
   @Builder.Default
   Function<String, StatusRuntimeException> exceptionBuilder =
       reason -> Status.RESOURCE_EXHAUSTED.withDescription(reason).asRuntimeException();
+
+  // config key to access non default circuit breaker thresholds
+  String configKey;
 }

grpc-circuitbreaker-utils/src/main/java/org/hypertrace/circuitbreaker/grpcutils/resilience/ResilienceCircuitBreakerConfigConverter.java

@@ -18,7 +18,7 @@ public static Map<String, CircuitBreakerConfig> getCircuitBreakerConfigs(
   public static List<String> getDisabledKeys(
       Map<String, CircuitBreakerThresholds> configurationMap) {
     return configurationMap.entrySet().stream()
-        .filter(entry -> entry.getValue().isEnabled())
+        .filter(entry -> !entry.getValue().isEnabled())
         .map(Map.Entry::getKey)
         .collect(Collectors.toList());
   }

grpc-circuitbreaker-utils/src/main/java/org/hypertrace/circuitbreaker/grpcutils/resilience/ResilienceCircuitBreakerFactory.java

@@ -22,7 +22,8 @@ public static ResilienceCircuitBreakerInterceptor getResilienceCircuitBreakerInt
             resilienceCircuitBreakerConfigMap,
             ResilienceCircuitBreakerConfigConverter.getDisabledKeys(
                 circuitBreakerConfiguration.getCircuitBreakerThresholdsMap()),
-            circuitBreakerConfiguration.getDefaultThresholds().isEnabled());
+            circuitBreakerConfiguration.getDefaultThresholds().isEnabled(),
+            circuitBreakerConfiguration.getConfigKey());
     return new ResilienceCircuitBreakerInterceptor(
         circuitBreakerConfiguration, clock, resilienceCircuitBreakerProvider);
   }

grpc-circuitbreaker-utils/src/main/java/org/hypertrace/circuitbreaker/grpcutils/resilience/ResilienceCircuitBreakerProvider.java

@@ -8,6 +8,7 @@
 import io.github.resilience4j.circuitbreaker.CircuitBreakerRegistry;
 import java.util.List;
 import java.util.Map;
+import java.util.Objects;
 import java.util.Optional;
 import java.util.concurrent.TimeUnit;
 import lombok.extern.slf4j.Slf4j;
@@ -21,6 +22,7 @@ class ResilienceCircuitBreakerProvider {
   private final Map<String, CircuitBreakerConfig> circuitBreakerConfigMap;
   private final List<String> disabledKeys;
   private final boolean defaultEnabled;
+  private final String configKey;
 
   // LoadingCache to manage CircuitBreaker instances with automatic loading and eviction
   private final LoadingCache<String, Optional<CircuitBreaker>> circuitBreakerCache =
@@ -33,17 +35,23 @@ public ResilienceCircuitBreakerProvider(
       CircuitBreakerRegistry circuitBreakerRegistry,
       Map<String, CircuitBreakerConfig> circuitBreakerConfigMap,
       List<String> disabledKeys,
-      boolean defaultEnabled) {
+      boolean defaultEnabled,
+      String configKey) {
     this.circuitBreakerRegistry = circuitBreakerRegistry;
     this.circuitBreakerConfigMap = circuitBreakerConfigMap;
     this.disabledKeys = disabledKeys;
     this.defaultEnabled = defaultEnabled;
+    this.configKey = configKey;
   }
 
   public Optional<CircuitBreaker> getCircuitBreaker(String circuitBreakerKey) {
-    if (disabledKeys.contains(circuitBreakerKey)) {
+    if (disabledKeys.contains(circuitBreakerKey)
+        || (Objects.nonNull(configKey)
+            && !circuitBreakerConfigMap.containsKey(circuitBreakerKey)
+            && disabledKeys.contains(configKey))) {
       return Optional.empty();
     }
+
     return circuitBreakerCache.getUnchecked(circuitBreakerKey);
   }
 
@@ -75,6 +83,7 @@ private static void attachListeners(CircuitBreaker circuitBreaker) {
 
   private Optional<CircuitBreaker> buildNewCircuitBreaker(String circuitBreakerKey) {
     return Optional.ofNullable(circuitBreakerConfigMap.get(circuitBreakerKey))
+        .or(() -> Optional.ofNullable(configKey).map(circuitBreakerConfigMap::get))
         .map(config -> circuitBreakerRegistry.circuitBreaker(circuitBreakerKey, config))
         .or(
             () ->