diff --git a/block/metrics.go b/block/metrics.go index 03b2c47947..120a2f0a80 100644 --- a/block/metrics.go +++ b/block/metrics.go @@ -124,7 +124,7 @@ func PrometheusMetrics(namespace string, labelsAndValues ...string) *Metrics { }, labels).With(labelsAndValues...) // Initialize channel buffer usage gauges - channelNames := []string{"header_in", "data_in", "header_store", "data_store", "retrieve", "da_includer", "tx_notify"} + channelNames := []string{"height_in", "header_store", "data_store", "retrieve", "da_includer", "tx_notify"} for _, name := range channelNames { m.ChannelBufferUsage[name] = prometheus.NewGaugeFrom(stdprometheus.GaugeOpts{ Namespace: namespace, diff --git a/block/metrics_test.go b/block/metrics_test.go index c1dc1fa89a..80981f3c63 100644 --- a/block/metrics_test.go +++ b/block/metrics_test.go @@ -18,9 +18,8 @@ func TestMetrics(t *testing.T) { assert.NotNil(t, em.NumTxs) // Test channel metrics initialization - assert.Len(t, em.ChannelBufferUsage, 7) - assert.NotNil(t, em.ChannelBufferUsage["header_in"]) - assert.NotNil(t, em.ChannelBufferUsage["data_in"]) + assert.Len(t, em.ChannelBufferUsage, 6) + assert.NotNil(t, em.ChannelBufferUsage["height_in"]) assert.NotNil(t, em.DroppedSignals) // Test error metrics initialization @@ -75,6 +74,7 @@ func TestMetrics(t *testing.T) { // Test maps are initialized assert.Len(t, em.ChannelBufferUsage, 6) + assert.NotNil(t, em.ChannelBufferUsage["height_in"]) assert.Len(t, em.ErrorsByType, 5) assert.Len(t, em.OperationDuration, 5) assert.Len(t, em.StateTransitions, 3) @@ -176,8 +176,7 @@ func TestMetricsIntegration(t *testing.T) { em.GoroutineCount.Set(50) // Test channel metrics - em.ChannelBufferUsage["header_in"].Set(5) - em.ChannelBufferUsage["data_in"].Set(3) + em.ChannelBufferUsage["height_in"].Set(5) // Test error metrics em.ErrorsByType["block_production"].Add(1)