feat: add reset for other types (#11)

Author: codeflyer

README.md

@@ -21,9 +21,10 @@ Create metrics yaml configuration file:
 ---
 component: bitswap-peer
 metrics:
-  bitswap-total-connections: BitSwap Total Connections
-  s3-request: AWS S3 requests
-  dynamo-request: AWS DynamoDB requests
+  count:
+    bitswap-total-connections: BitSwap Total Connections
+    s3-request: AWS S3 requests
+    dynamo-request: AWS DynamoDB requests
 version: 0.1.0
 buildDate: "20220307.1423"
 ```
@@ -39,7 +40,8 @@ telemetry.increaseCount('bitswap-total-connections', 2)
 
 const result = await telemetry.export()
 console.log(result)
-telemetry.resetCount()
+telemetry.resetDurations()
+telemetry.resetCounters()
 ```
 
 #### Telemetry instance methods
@@ -52,6 +54,8 @@ telemetry.resetCount()
     ```
 * resetAll(): Reset all metrics
 * resetCounters(): Reset count and labelCount metrics
+* resetDurations(): Reset durations metrics
+* resetGauges(): Reset gauges metrics
 * async export(): Export values  in Prometheus format 
 * increaseCount(category, amount = 1): Increase the count for a category
   * category: String - The given name of the category

package.json

@@ -1,6 +1,6 @@
 {
   "name": "e-ipfs-core-lib",
-  "version": "0.4.0-beta-01",
+  "version": "0.4.0",
   "description": "E-IPFS core library",
   "license": "(Apache-2.0 AND MIT)",
   "homepage": "https://github.com/elastic-ipfs/core-lib",

src/telemetry.js

@@ -76,6 +76,14 @@ class Telemetry {
     this.labelCountRegistry.resetMetrics()
   }
 
+  resetDurations () {
+    this.durationsRegistry.resetMetrics()
+  }
+
+  resetGauges () {
+    this.gaugeRegistry.resetMetrics()
+  }
+
   async export () {
     return this.allRegistry.metrics()
   }

test/telemetry.test.js

@@ -203,6 +203,24 @@ t.test('Telemetry', async t => {
       `.trim())
     })
 
+    t.test('should reset only the gauge', async t => {
+      const telemetry = new Telemetry({ configFile, logger })
+      telemetry.increaseGauge('bitswap-total-connections')
+      telemetry.increaseGauge('bitswap-total-connections', 10)
+
+      telemetry.resetGauges()
+
+      t.equal((await telemetry.gaugeRegistry.metrics()).trim(), dedent`
+      # HELP bitswap_event_loop_utilization BitSwap Event Loop Utilization
+      # TYPE bitswap_event_loop_utilization gauge
+      bitswap_event_loop_utilization 0
+      
+      # HELP bitswap_total_connections BitSwap Total Connections
+      # TYPE bitswap_total_connections gauge
+      bitswap_total_connections 0
+      `.trim())
+    })
+
     t.test('all metrics should be defined in the config file', async t => {
       const telemetry = new Telemetry({ configFile, logger })
       t.throws(() => telemetry.increaseGauge('unknown'), { message: 'Metric unknown not found' })
@@ -227,7 +245,7 @@ t.test('Telemetry', async t => {
         await telemetry.trackDuration('bitswap-connections-duration-durations', async () => { await setTimeoutAsync(300) })
       ])
       t.ok((await telemetry.durationsRegistry.metrics()).includes('bitswap_connections_duration_durations_count 6'))
-      telemetry.resetAll()
+      telemetry.resetDurations()
       t.ok(!(await telemetry.durationsRegistry.metrics()).includes('bitswap_connections_duration_durations_count'))
     })