chore: add metrics for mailjet

rudderlabs · Dec 6, 2024 · 7120740 · 7120740
1 parent d7f390c
commit 7120740
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/src/util/prometheus.js b/src/util/prometheus.js
@@ -520,6 +520,12 @@ class Prometheus {
         type: 'counter',
         labelNames: ['destination_id'],
       },
+      {
+        name: 'mailjet_packing_size',
+        help: 'mailjet_packing_size',
+        type: 'gauge',
+        labelNames: ['destination_id'],
+      },
       {
         name: 'hs_batch_size',
         help: 'hs_batch_size',

diff --git a/src/v0/destinations/mailjet/transform.js b/src/v0/destinations/mailjet/transform.js
@@ -1,5 +1,6 @@
 const lodash = require('lodash');
 const { TransformationError, InstrumentationError } = require('@rudderstack/integrations-lib');
+const stats = require('../../../util/stats');
 const {
   getSuccessRespEvents,
   defaultRequestConfig,
@@ -105,6 +106,9 @@ const batchEvents = (successRespList) => {
     const eventChunks = lodash.chunk(eventGroups[combination], MAX_BATCH_SIZE);
     // eventChunks = [[e1,e2,e3,..batchSize],[e1,e2,e3,..batchSize]..]
     eventChunks.forEach((chunk) => {
+      stats.gauge('mailjet_packing_size', chunk.length, {
+        group: combination,
+      });
       const batchEventResponse = generateBatchedPaylaodForArray(chunk, combination);
       batchedResponseList.push(
         getSuccessRespEvents(