@@ -43,28 +43,20 @@ func (m *Manager) sendNonBlockingSignalWithMetrics(ch chan<- struct{}, channelNa
4343
4444// updateChannelMetrics updates the buffer usage metrics for all channels
4545func (m * Manager ) updateChannelMetrics () {
46- // Update channel buffer usage
47- if m .metrics .ChannelBufferUsage ["header_in" ] != nil {
48- m .metrics .ChannelBufferUsage ["header_in" ].Set (float64 (len (m .headerInCh )))
49- }
50- if m .metrics .ChannelBufferUsage ["data_in" ] != nil {
51- m .metrics .ChannelBufferUsage ["data_in" ].Set (float64 (len (m .dataInCh )))
52- }
53- if m .metrics .ChannelBufferUsage ["header_store" ] != nil {
54- m .metrics .ChannelBufferUsage ["header_store" ].Set (float64 (len (m .headerStoreCh )))
55- }
56- if m .metrics .ChannelBufferUsage ["data_store" ] != nil {
57- m .metrics .ChannelBufferUsage ["data_store" ].Set (float64 (len (m .dataStoreCh )))
58- }
59- if m .metrics .ChannelBufferUsage ["retrieve" ] != nil {
60- m .metrics .ChannelBufferUsage ["retrieve" ].Set (float64 (len (m .retrieveCh )))
61- }
62- if m .metrics .ChannelBufferUsage ["da_includer" ] != nil {
63- m .metrics .ChannelBufferUsage ["da_includer" ].Set (float64 (len (m .daIncluderCh )))
64- }
65- if m .metrics .ChannelBufferUsage ["tx_notify" ] != nil {
66- m .metrics .ChannelBufferUsage ["tx_notify" ].Set (float64 (len (m .txNotifyCh )))
67- }
46+ // Update channel buffer usage if m.metrics.ChannelBufferUsage["header_in"] != nil {
47+ m .metrics .ChannelBufferUsage ["header_in" ].Set (float64 (len (m .headerInCh )))
48+
49+ m .metrics .ChannelBufferUsage ["data_in" ].Set (float64 (len (m .dataInCh )))
50+
51+ m .metrics .ChannelBufferUsage ["header_store" ].Set (float64 (len (m .headerStoreCh )))
52+
53+ m .metrics .ChannelBufferUsage ["data_store" ].Set (float64 (len (m .dataStoreCh )))
54+
55+ m .metrics .ChannelBufferUsage ["retrieve" ].Set (float64 (len (m .retrieveCh )))
56+
57+ m .metrics .ChannelBufferUsage ["da_includer" ].Set (float64 (len (m .daIncluderCh )))
58+
59+ m .metrics .ChannelBufferUsage ["tx_notify" ].Set (float64 (len (m .txNotifyCh )))
6860
6961 // Update goroutine count
7062 m .metrics .GoroutineCount .Set (float64 (runtime .NumGoroutine ()))
@@ -76,7 +68,6 @@ func (m *Manager) recordError(errorType string, recoverable bool) {
7668 if m .metrics .ErrorsByType [errorType ] != nil {
7769 m .metrics .ErrorsByType [errorType ].Add (1 )
7870 }
79-
8071 if recoverable {
8172 m .metrics .RecoverableErrors .Add (1 )
8273 } else {
@@ -108,7 +99,6 @@ func (m *Manager) recordDAMetrics(operation string, success bool) {
10899func (m * Manager ) recordBlockProductionMetrics (txCount int , isLazy bool , duration time.Duration ) {
109100 // Record production time
110101 m .metrics .BlockProductionTime .Observe (duration .Seconds ())
111-
112102 // Record transactions per block
113103 m .metrics .TxsPerBlock .Observe (float64 (txCount ))
114104
0 commit comments