test

src/CircuitBreaker.ts

@@ -62,15 +62,12 @@ export class CircuitBreaker extends EventEmitter {
     }
 
     async _evaluate() {
-        this._evaluatingPromiseHook = Promise.allSettled(this._probes.map(p => p.check().catch(error => {
-            this.emit('connection-failed', error);
-            return 'failed';
-        })));
+        this._evaluatingPromiseHook = Promise.allSettled(this._probes.map(p => p.check()));
         await this._evaluatingPromiseHook;
         this._evaluatingPromiseHook = null;
 
         const allOk = this._probes.every(probe => probe.value);
-
+        console.log('allOk:', allOk);
         const initialState = this._aggregateState;
 
         if (allOk) {

src/probes/PrometheusClient.ts

@@ -51,7 +51,7 @@ export class PrometheusClient {
             return series[0].value.value;
         } catch (error: unknown) {
             log.error('unable to query prometheus', { error });
-            return null;
+            return -1;
         }
     }
 }

src/probes/PrometheusQueryProbe.ts

@@ -36,6 +36,7 @@ export class PrometheusQueryProbe implements Probe {
 
     async check() {
         const v = await this.prometheusClient.instantQuery();
+        log.info('observed value', { value: v });
         if (v != null) {
             if (Number.isNaN(v)) {
                 log.warn('warning: ignoring received NaN value (interval too long for retention?)');
@@ -46,6 +47,8 @@ export class PrometheusQueryProbe implements Probe {
     }
 
     get value() {
+        log.info('observed value', { value: this.observed });
+        log.info('threshold', { threshold: this.config.threshold });
         return this.observed < this.config.threshold;
     }
 }