[servicecomb-java-chassis] branch master updated: [SCB-2600]add forceClosed and forceOpen parameter to circuit breaker (#3121)

[li...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

liubao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/servicecomb-java-chassis.git


The following commit(s) were added to refs/heads/master by this push:
     new 951c422a3 [SCB-2600]add forceClosed and forceOpen parameter to circuit breaker (#3121)
951c422a3 is described below

commit 951c422a3eae52e50451f3d57f1f8f69fa528a72
Author: liubao68 <bi...@qq.com>
AuthorDate: Fri Jun 24 15:28:15 2022 +0800

    [SCB-2600]add forceClosed and forceOpen parameter to circuit breaker (#3121)
---
 .../governance/policy/CircuitBreakerPolicy.java    | 26 ++++++++++++++++++++--
 1 file changed, 24 insertions(+), 2 deletions(-)

diff --git a/governance/src/main/java/org/apache/servicecomb/governance/policy/CircuitBreakerPolicy.java b/governance/src/main/java/org/apache/servicecomb/governance/policy/CircuitBreakerPolicy.java
index c412ed7c0..9996d1b72 100644
--- a/governance/src/main/java/org/apache/servicecomb/governance/policy/CircuitBreakerPolicy.java
+++ b/governance/src/main/java/org/apache/servicecomb/governance/policy/CircuitBreakerPolicy.java
@@ -64,9 +64,15 @@ public class CircuitBreakerPolicy extends AbstractPolicy {
 
   private String slidingWindowSize = DEFAULT_SLIDING_WINDOW_SIZE;
 
-  //status code that need retry
+  //status code that need record as a failure
   private List<String> recordFailureStatus = new ArrayList<>();
 
+  //force close this circuit breaker. This parameter is not used by circuit breaker directly
+  private boolean forceClosed = false;
+
+  //force open this circuit breaker. This parameter is not used by circuit breaker directly
+  private boolean forceOpen = false;
+
   public CircuitBreakerPolicy() {
   }
 
@@ -193,10 +199,26 @@ public class CircuitBreakerPolicy extends AbstractPolicy {
     return this.recordFailureStatus;
   }
 
-  public void setRRecordFailureStatus(List<String> recordFailureStatus) {
+  public void setRecordFailureStatus(List<String> recordFailureStatus) {
     this.recordFailureStatus = recordFailureStatus;
   }
 
+  public boolean isForceClosed() {
+    return forceClosed;
+  }
+
+  public void setForceClosed(boolean forceClosed) {
+    this.forceClosed = forceClosed;
+  }
+
+  public boolean isForceOpen() {
+    return forceOpen;
+  }
+
+  public void setForceOpen(boolean forceOpen) {
+    this.forceOpen = forceOpen;
+  }
+
   @Override
   public String toString() {
     return "CircuitBreakerPolicy{" +