feat(metrics): instrument success and failure rates of chunk broadcas…

…ting
ar-io · Nov 20, 2024 · 5c98e0a · 5c98e0a
1 parent 1cc1276
commit 5c98e0a
Show file tree

Hide file tree

Showing 3 changed files with 25 additions and 0 deletions.
diff --git a/src/arweave/composite-client.ts b/src/arweave/composite-client.ts
@@ -743,6 +743,11 @@ export class ArweaveCompositeClient
 
           successCount++;
 
+          metrics.arweaveChunkPostCounter.inc({
+            endpoint: url,
+            status: 'success',
+          });
+
           return {
             success: true,
             statusCode: resp.status,
@@ -765,6 +770,11 @@ export class ArweaveCompositeClient
 
           failureCount++;
 
+          metrics.arweaveChunkPostCounter.inc({
+            endpoint: url,
+            status: 'fail',
+          });
+
           return {
             success: false,
             statusCode: error.response?.status,

diff --git a/src/metrics.ts b/src/metrics.ts
@@ -120,6 +120,18 @@ export const arweaveTxFetchCounter = new promClient.Counter({
   labelNames: ['node_type'],
 });
 
+export const arweaveChunkPostCounter = new promClient.Counter({
+  name: 'arweave_chunk_post_total',
+  help: 'Counts individual POST request to endpoint',
+  labelNames: ['endpoint', 'status'],
+});
+
+export const arweaveChunkBroadcastCounter = new promClient.Counter({
+  name: 'arweave_chunk_broadcast_total',
+  help: 'Counts successful broadcast accounting for min threshold count etc',
+  labelNames: ['status'],
+});
+
 //
 // SQLite metrics
 //

diff --git a/src/routes/arweave.ts b/src/routes/arweave.ts
@@ -19,6 +19,7 @@ import { Router, default as express } from 'express';
 
 import log from '../log.js';
 import * as system from '../system.js';
+import * as metrics from '../metrics.js';
 import {
   CHUNK_POST_URLS,
   CHUNK_POST_ABORT_TIMEOUT_MS,
@@ -54,8 +55,10 @@ arweaveRouter.post('/chunk', async (req, res) => {
     if (
       result.successCount >= Math.min(MIN_SUCCESS_COUNT, CHUNK_POST_URLS.length)
     ) {
+      metrics.arweaveChunkBroadcastCounter.inc({ status: 'success' });
       res.status(200).send(result);
     } else {
+      metrics.arweaveChunkBroadcastCounter.inc({ status: 'fail' });
       res.status(500).send(result);
     }
   } catch (error: any) {