From 226fbf6d44ae83c834cee1a56e4f5c94387fb3c5 Mon Sep 17 00:00:00 2001 From: healthykim Date: Tue, 24 Mar 2026 20:55:44 +0900 Subject: [PATCH] add availability timeout metric --- eth/fetcher/blob_fetcher.go | 1 + eth/fetcher/metrics.go | 2 ++ 2 files changed, 3 insertions(+) diff --git a/eth/fetcher/blob_fetcher.go b/eth/fetcher/blob_fetcher.go index 98d0ff24c4..d8a2f205ea 100644 --- a/eth/fetcher/blob_fetcher.go +++ b/eth/fetcher/blob_fetcher.go @@ -378,6 +378,7 @@ func (f *BlobFetcher) loop() { } delete(f.waittime, hash) delete(f.waitlist, hash) + blobAnnounceTimeoutMeter.Mark(1) } } diff --git a/eth/fetcher/metrics.go b/eth/fetcher/metrics.go index a2317e7c64..4eb4db0a99 100644 --- a/eth/fetcher/metrics.go +++ b/eth/fetcher/metrics.go @@ -60,6 +60,8 @@ var ( blobAnnounceInMeter = metrics.NewRegisteredMeter("eth/fetcher/blob/announces/in", nil) blobAnnounceDOSMeter = metrics.NewRegisteredMeter("eth/fetcher/blob/announces/dos", nil) + // This metric is to track the number of availability failure + blobAnnounceTimeoutMeter = metrics.NewRegisteredMeter("eth/fetcher/blob/announces/timeout", nil) blobRequestOutMeter = metrics.NewRegisteredMeter("eth/fetcher/blob/request/out", nil) blobRequestFailMeter = metrics.NewRegisteredMeter("eth/fetcher/blob/request/fail", nil)