Canary Rate Threshold Circuit Breaker Strategy: All circuits open at start (mageddo#588)

* implementing circuit breaker factory

* fixmes

* testing

* testing

* setup strategy mapping

* fixing validation

* must call hotload method once

* adjusting logs

* add server address as circuit breaker name

* fixing compiling errors

* refactoring

* refactoring

* fixing test

* fixing test

* fixing test

* fixing test

* fixing test

* fixing test

* fixing test

* messages formatting and refactoring

* refactoring

* disabling metrics

* heating circuit breakers at app startup

* todos

* adjusts

* adjusts

* fixing tests

* fixing tests

* fixing tests

* testing

* item tick

* clearing todos

* [Gradle Release Plugin] - new version commit:  '3.31.1-snapshot'.

* release notes

Author: mageddo

RELEASE-NOTES.md

@@ -1,3 +1,6 @@
+## 3.31.1
+* Adjusting Canary Rate Threshold Circuit Breaker to mark all circuits as open at the start. #533
+
 ## 3.31.0
 * Canary Rate Threshold Circuit Breaker. #533
 

TODO.md

@@ -1 +1 @@
-version=3.31.0-snapshot
+version=3.31.1-snapshot

gradle.properties

@@ -38,24 +38,24 @@ public static String simplePrint(Response res) {
     return simplePrint(res.getMessage());
   }
 
-  public static String simplePrint(Message message) {
-    if (message == null) {
+  public static String simplePrint(Message reqOrRes) {
+    if (reqOrRes == null) {
       return null;
     }
     try {
-      final var answer = findFirstAnswerRecord(message);
-      final var rcode = message.getRcode();
+      final var answer = findFirstAnswerRecord(reqOrRes);
+      final var rcode = reqOrRes.getRcode();
       if (answer != null) {
         return String.format("rc=%d, res=%s", rcode, simplePrint(answer));
       }
-      final var question = message.getQuestion();
+      final var question = reqOrRes.getQuestion();
       final var type = Objects.useItOrDefault(
         Objects.toString(Entry.Type.of(question.getType())),
         () -> String.valueOf(question.getType())
       );
       final var hostname = question.getName().toString(true);
       final var sb = new StringBuilder();
-      if (Messages.hasFlag(message, Flags.QR)) {
+      if (Messages.hasFlag(reqOrRes, Flags.QR)) {
         sb.append("rc=")
           .append(rcode)
           .append(", ")
@@ -64,8 +64,8 @@ public static String simplePrint(Message message) {
       sb.append(String.format("query=%s:%s", type, hostname));
       return sb.toString();
     } catch (Throwable e) {
-      log.warn("status=failedToSimplePrint, msg={}", message, e);
-      return String.valueOf(message);
+      log.warn("status=failedToSimplePrint, msg={}", reqOrRes, e);
+      return String.valueOf(reqOrRes);
     }
   }
 

src/main/java/com/mageddo/dns/utils/Messages.java

@@ -1,6 +1,7 @@
 package com.mageddo.dnsproxyserver.di.module;
 
 import com.mageddo.di.Eager;
+import com.mageddo.dnsproxyserver.solver.remote.circuitbreaker.entrypoint.CircuitBreakerHeater;
 import dagger.Module;
 import dagger.Provides;
 import dagger.multibindings.ElementsIntoSet;
@@ -13,7 +14,9 @@ public class ModuleEager {
   @Provides
   @Singleton
   @ElementsIntoSet
-  Set<Eager> beans() {
-    return Set.of();
+  Set<Eager> beans(CircuitBreakerHeater a) {
+    return Set.of(
+      a
+    );
   }
 }

src/main/java/com/mageddo/dnsproxyserver/di/module/ModuleEager.java

@@ -1,5 +1,8 @@
 package com.mageddo.dnsproxyserver.solver;
 
+import com.mageddo.net.IpAddr;
+import com.mageddo.net.IpAddrs;
+
 import java.net.InetAddress;
 import java.net.InetSocketAddress;
 import java.net.UnknownHostException;
@@ -20,4 +23,8 @@ public SimpleResolver(InetSocketAddress addr) {
   public SimpleResolver(InetAddress host) {
     super(host);
   }
+
+  public SimpleResolver(IpAddr addr) {
+    super(IpAddrs.toInetSocketAddress(addr));
+  }
 }

src/main/java/com/mageddo/dnsproxyserver/solver/SimpleResolver.java

@@ -1,7 +1,6 @@
 package com.mageddo.dnsproxyserver.solver.remote.application.failsafe;
 
 import com.mageddo.commons.lang.tuple.Pair;
-import com.mageddo.dnsproxyserver.config.CanaryRateThresholdCircuitBreakerStrategyConfig;
 import com.mageddo.dnsproxyserver.config.CircuitBreakerStrategyConfig;
 import com.mageddo.dnsproxyserver.config.StaticThresholdCircuitBreakerStrategyConfig;
 import com.mageddo.dnsproxyserver.config.application.ConfigService;
@@ -14,6 +13,7 @@
 import com.mageddo.dnsproxyserver.solver.remote.circuitbreaker.application.CircuitBreakerDelegateStaticThresholdFailsafe;
 import com.mageddo.dnsproxyserver.solver.remote.mapper.ResolverMapper;
 import com.mageddo.net.IpAddr;
+import com.mageddo.net.IpAddrs;
 import lombok.RequiredArgsConstructor;
 import lombok.Value;
 import lombok.extern.slf4j.Slf4j;
@@ -25,6 +25,7 @@
 import java.util.List;
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
+import java.util.function.Supplier;
 
 @Slf4j
 @Singleton
@@ -67,8 +68,7 @@ CircuitBreakerDelegate findCircuitBreakerHotLoad(InetSocketAddress address) {
   }
 
   CircuitBreakerDelegate buildCanaryRateThreshold(CircuitBreakerStrategyConfig config, InetSocketAddress address) {
-//    return this.canaryThresholdFactory.build(config, IpAddrs.from(address));
-    return this.canaryThresholdFactory.build((CanaryRateThresholdCircuitBreakerStrategyConfig) config);
+    return this.canaryThresholdFactory.build(config, IpAddrs.from(address));
   }
 
   private CircuitBreakerDelegateStaticThresholdFailsafe buildStaticThresholdFailSafeCircuitBreaker(

src/main/java/com/mageddo/dnsproxyserver/solver/remote/application/failsafe/CircuitBreakerFactory.java

@@ -2,6 +2,7 @@
 
 import com.mageddo.dnsproxyserver.solver.remote.CircuitStatus;
 import com.mageddo.dnsproxyserver.solver.remote.Result;
+import com.mageddo.dnsproxyserver.solver.remote.circuitbreaker.statetransitor.StateTransitor;
 
 import java.util.function.Supplier;
 
@@ -11,5 +12,13 @@ public interface CircuitBreakerDelegate {
 
   CircuitStatus findStatus();
 
-  void transitionToHalfOpenState();
+  StateTransitor stateTransitor();
+
+  default void transitionToHalfOpenState(){
+    this.stateTransitor().halfOpen();
+  }
+
+  default void transitionToClosedState(){
+    this.stateTransitor().closed();
+  }
 }

src/main/java/com/mageddo/dnsproxyserver/solver/remote/circuitbreaker/application/CircuitBreakerDelegate.java

@@ -2,6 +2,8 @@
 
 import com.mageddo.dnsproxyserver.solver.remote.CircuitStatus;
 import com.mageddo.dnsproxyserver.solver.remote.Result;
+import com.mageddo.dnsproxyserver.solver.remote.circuitbreaker.statetransitor.NopStateTransitor;
+import com.mageddo.dnsproxyserver.solver.remote.circuitbreaker.statetransitor.StateTransitor;
 
 import java.util.function.Supplier;
 
@@ -18,7 +20,8 @@ public CircuitStatus findStatus() {
   }
 
   @Override
-  public void transitionToHalfOpenState() {
-
+  public StateTransitor stateTransitor() {
+    return new NopStateTransitor();
   }
+
 }

src/main/java/com/mageddo/dnsproxyserver/solver/remote/circuitbreaker/application/CircuitBreakerDelegateNonResilient.java

@@ -1,9 +1,11 @@
 package com.mageddo.dnsproxyserver.solver.remote.circuitbreaker.application;
 
 import com.mageddo.circuitbreaker.failsafe.CircuitStatusRefresh;
+import com.mageddo.commons.circuitbreaker.CircuitIsOpenException;
 import com.mageddo.dnsproxyserver.solver.remote.CircuitStatus;
 import com.mageddo.dnsproxyserver.solver.remote.Result;
-import com.mageddo.commons.circuitbreaker.CircuitIsOpenException;
+import com.mageddo.dnsproxyserver.solver.remote.circuitbreaker.statetransitor.FailSafeStateTransitor;
+import com.mageddo.dnsproxyserver.solver.remote.circuitbreaker.statetransitor.StateTransitor;
 import com.mageddo.dnsproxyserver.solver.remote.mapper.CircuitBreakerStateMapper;
 import dev.failsafe.CircuitBreaker;
 import dev.failsafe.CircuitBreakerOpenException;
@@ -25,7 +27,7 @@ public Result execute(Supplier<Result> sup) {
       return Failsafe
         .with(this.circuitBreaker)
         .get((ctx) -> sup.get());
-    } catch (CircuitBreakerOpenException e){
+    } catch (CircuitBreakerOpenException e) {
       throw new CircuitIsOpenException(e);
     }
   }
@@ -37,7 +39,8 @@ public CircuitStatus findStatus() {
   }
 
   @Override
-  public void transitionToHalfOpenState() {
-    this.circuitBreaker.halfOpen();
+  public StateTransitor stateTransitor() {
+    return new FailSafeStateTransitor(circuitBreaker);
   }
+
 }