add transaction suspended metrics

taikoxyz · Feb 8, 2024 · a28cfc0 · a28cfc0
1 parent 6e3b2a1
commit a28cfc0
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/packages/relayer/prometheus.go b/packages/relayer/prometheus.go
@@ -14,6 +14,10 @@ var (
 		Name: "blocks_processed_ops_total",
 		Help: "The total number of processed blocks",
 	})
+	TransactionsSuspended = promauto.NewCounter(prometheus.CounterOpts{
+		Name: "transactions_suspended_ops_total",
+		Help: "The total number of suspended transactions",
+	})
 	BlocksScanned = promauto.NewCounter(prometheus.CounterOpts{
 		Name: "blocks_scanned_ops_total",
 		Help: "The total number of scanned blocks. Acts as heartbeat metric.",

diff --git a/packages/relayer/watchdog/watchdog.go b/packages/relayer/watchdog/watchdog.go
@@ -314,6 +314,8 @@ func (w *Watchdog) checkMessage(ctx context.Context, msg queue.Message) error {
 
 	slog.Info("Mined tx", "txHash", hex.EncodeToString(tx.Hash().Bytes()))
 
+	relayer.TransactionsSuspended.Inc()
+
 	if _, err := w.suspendedTxRepo.Save(ctx,
 		relayer.SuspendTransactionOpts{
 			MessageID:    int(msgBody.Event.Message.Id.Int64()),