Add operatorId in attestation latency (#574)

Layr-Labs · May 22, 2024 · 1f91e4a · 1f91e4a
1 parent 27b4caa
commit 1f91e4a
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/disperser/batcher/grpc/dispatcher.go b/disperser/batcher/grpc/dispatcher.go
@@ -88,7 +88,7 @@ func (c *dispatcher) sendAllChunks(ctx context.Context, state *core.IndexedOpera
 					BatchHeaderHash:      batchHeaderHash,
 					AttestationLatencyMs: latencyMs,
 				}
-				c.metrics.ObserveLatency(false, latencyMs)
+				c.metrics.ObserveLatency(id.Hex(), false, latencyMs)
 			} else {
 				update <- core.SigningMessage{
 					Signature:            sig,
@@ -97,7 +97,7 @@ func (c *dispatcher) sendAllChunks(ctx context.Context, state *core.IndexedOpera
 					AttestationLatencyMs: latencyMs,
 					Err:                  nil,
 				}
-				c.metrics.ObserveLatency(true, latencyMs)
+				c.metrics.ObserveLatency(id.Hex(), true, latencyMs)
 			}
 
 		}(core.IndexedOperatorInfo{

diff --git a/disperser/batcher/metrics.go b/disperser/batcher/metrics.go
@@ -164,7 +164,7 @@ func NewMetrics(httpPort string, logger logging.Logger) *Metrics {
 				Help:       "attestation latency summary in milliseconds",
 				Objectives: map[float64]float64{0.5: 0.05, 0.9: 0.01, 0.95: 0.01, 0.99: 0.001},
 			},
-			[]string{"status"},
+			[]string{"operator_id", "status"},
 		),
 	}
 
@@ -252,12 +252,12 @@ func (g *Metrics) UpdateAttestation(operatorCount map[core.QuorumID]int, signerC
 	}
 }
 
-func (t *DispatcherMetrics) ObserveLatency(success bool, latencyMS float64) {
+func (t *DispatcherMetrics) ObserveLatency(operatorId string, success bool, latencyMS float64) {
 	label := "success"
 	if !success {
 		label = "failure"
 	}
-	t.Latency.WithLabelValues(label).Observe(latencyMS)
+	t.Latency.WithLabelValues(operatorId, label).Observe(latencyMS)
 }
 
 // UpdateCompletedBlob increments the number and updates size of processed blobs.