Track lag for block time to ingestion time

dydxprotocol · Nov 29, 2023 · 0a38535 · 0a38535
1 parent d6fa5fd
commit 0a38535
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/indexer/services/ender/src/lib/on-message.ts b/indexer/services/ender/src/lib/on-message.ts
@@ -20,6 +20,7 @@ import {
   KafkaMessage,
 } from 'kafkajs';
 import _ from 'lodash';
+import { DateTime } from 'luxon';
 
 import {
   shouldSkipBlock,
@@ -55,6 +56,11 @@ export async function onMessage(message: KafkaMessage): Promise<void> {
   if (indexerTendermintBlock === undefined) {
     return;
   }
+  stats.timing(
+    `${config.SERVICE_NAME}.block_time_lag.timing`,
+    DateTime.now().diff(dateToDateTime(indexerTendermintBlock.time!)).toMillis(),
+    STATS_NO_SAMPLING,
+  );
 
   const offset = message.offset;
   const blockHeight: string = indexerTendermintBlock.height.toString();