add metric for anchor accepted (#1191)

* add metric for anchor accepted * name the controller metric ANCHOR_REQUEST_ACCEPTED * add metrics for adding to sqs queue and updating existing requests
ceramicnetwork · Apr 17, 2024 · 516cc99 · 516cc99
1 parent e0538a5
commit 516cc99
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 0 deletions.
diff --git a/src/controllers/request-controller.ts b/src/controllers/request-controller.ts
@@ -135,6 +135,7 @@ export class RequestController {
         )
       }
       logger.debug(`Found request for ${requestParams.cid} of stream ${requestParams.streamId}`)
+      Metrics.count(METRIC_NAMES.ANCHOR_REQUEST_ACCEPTED, 1, { source: parseOrigin(req) })
       return res.status(StatusCodes.ACCEPTED).json(found)
     } catch (err: any) {
       Metrics.count(METRIC_NAMES.REQUEST_NOT_CREATED, 1, { source: parseOrigin(req) })

diff --git a/src/services/request-service.ts b/src/services/request-service.ts
@@ -109,8 +109,10 @@ export class RequestService {
         crt: storedRequest.createdAt,
         org: origin,
       })
+      Metrics.count(METRIC_NAMES.PUBLISH_TO_QUEUE, 1) 
     } else {
       await this.requestRepository.markReplaced(storedRequest)
+      Metrics.count(METRIC_NAMES.UPDATED_STORED_REQUEST, 1)
     }
 
     const did = genesisFields?.controllers?.[0]
@@ -126,6 +128,7 @@ export class RequestService {
       cacao: 'cacaoDomain' in params ? params.cacaoDomain : '',
     };
 
+    // High cardinality business metrics, should be skipped by prometheus
     Metrics.count(METRIC_NAMES.WRITE_TOTAL_TSDB, 1, logData)
 
     logger.debug(`Anchor request received: ${JSON.stringify(logData)}`);

diff --git a/src/settings.ts b/src/settings.ts
@@ -51,13 +51,17 @@ export enum METRIC_NAMES {
   ANCHOR_REQUESTS_BATCH_TIME = 'anchor_requests_batch_time',
   ANCHOR_REQUESTS_BATCH_FAILURE_TIME = 'anchor_requests_batch_failure_time',
 
+  ANCHOR_REQUEST_ACCEPTED = 'anchor_request_accepted',  // in controller
+
   // *******************************************************************//
   // Request Service
   WRITE_TOTAL_TSDB = 'write_total_tsdb', // note _tsdb implies handles high cardinality
   MERKLE_CAR_CACHE_HIT = 'merkle_car_cache_hit',
   MERKLE_CAR_CACHE_MISS = 'merkle_car_cache_miss',
   WITNESS_CAR_CACHE_HIT = 'witness_car_cache_hit',
   WITNESS_CAR_CACHE_MISS = 'witness_car_cache_miss',
+  PUBLISH_TO_QUEUE = 'publish_to_queue',
+  UPDATED_STORED_REQUEST = 'updated_stored_request',
 
   // *******************************************************************//
   // Ceramic Service