test

scality · Jun 18, 2024 · ca152ef · ca152ef
1 parent 4a6fa2c
commit ca152ef
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/src/CircuitBreaker.ts b/src/CircuitBreaker.ts
@@ -6,6 +6,7 @@ export enum BreakerState {
     Nominal = 0,
     Stabilizing = 1,
     Tripped = 2,
+    ErrorProm = 3,
 }
 
 export class CircuitBreaker extends EventEmitter {
@@ -39,6 +40,8 @@ export class CircuitBreaker extends EventEmitter {
             [BreakerState.Nominal]: this._config.nominalEvaluateIntervalMs || defaultProbeEvaluateInterval,
             [BreakerState.Stabilizing]: this._config.stabilizingEvaluateIntervalMs || defaultProbeEvaluateInterval,
             [BreakerState.Tripped]: this._config.trippedEvaluateIntervalMs || defaultProbeEvaluateInterval,
+            [BreakerState.ErrorProm] : this._config.errorPromEvaluateIntervalMs || defaultProbeEvaluateInterval,
+
         };
 
         this._evaluateTimeoutHandle = null;
@@ -69,6 +72,7 @@ export class CircuitBreaker extends EventEmitter {
         const allOk = this._probes.every(probe => probe.value);
         console.log('allOk:', allOk);
         const initialState = this._aggregateState;
+        console.log('initialState:', initialState);
 
         if (allOk) {
             switch (this._aggregateState) {
@@ -84,7 +88,9 @@ export class CircuitBreaker extends EventEmitter {
                     this._aggregateState = BreakerState.Nominal;
                 }
                 break;
-
+            case BreakerState.ErrorProm:
+                this._aggregateState = BreakerState.ErrorProm;
+                break;
             default:
                 break;
             }

diff --git a/src/Configuration.ts b/src/Configuration.ts
@@ -10,6 +10,7 @@ const topSchema = joi.object({
     probes: joi.array().items(probeSchema).optional(),
     nominalEvaluateIntervalMs: joi.number().positive().default(defaultProbeEvaluateInterval).optional(),
     trippedEvaluateIntervalMs: joi.number().positive().default(defaultProbeEvaluateInterval).optional(),
+    errorPromEvaluateIntervalMs: joi.number().positive().default(defaultProbeEvaluateInterval).optional(),
     stabilizingEvaluateIntervalMs: joi.number().positive().default(defaultProbeEvaluateInterval).optional(),
     stabilizeAfterNSuccesses: joi.number().positive().default(defaultStabilizeAfterNSuccesses).optional(),
 });