feat: add candlestick for monitor tx latency

Author: 0x416e746f6e

metrics/exports.go

@@ -19,13 +19,15 @@ var (
 	ProbesSentCount   otelapi.Int64Counter
 	ProbesFailedCount otelapi.Int64Counter
 	ProbesLandedCount otelapi.Int64Counter
-	ProbesLatency     otelapi.Int64Histogram
-
-	TxPerBlock_Old  otelapi.Int64Histogram
-	GasPerBlock_Old otelapi.Int64Histogram
-	GasPrice_Old    otelapi.Int64Histogram
+	ProbesLatency     *Int64Candlestick
 
 	TxPerBlock  *Int64Candlestick
 	GasPerBlock *Int64Candlestick
 	GasPrice    *Int64Candlestick
+
+	// TODO: get rid of this
+	ProbesLatency_Old otelapi.Int64Histogram
+	TxPerBlock_Old    otelapi.Int64Histogram
+	GasPerBlock_Old   otelapi.Int64Histogram
+	GasPrice_Old      otelapi.Int64Histogram
 )

metrics/metrics.go

@@ -191,15 +191,27 @@ func setupProbesLanded(ctx context.Context, _ *config.Monitor) error {
 }
 
 func setupProbesLatency(ctx context.Context, _ *config.Monitor) error {
-	m, err := meter.Int64Histogram("probes_latency",
-		otelapi.WithDescription("latency of landed probe transactions"),
-		otelapi.WithUnit("s"),
-		otelapi.WithExplicitBucketBoundaries(0, 1, 4, 16, 64, 256),
-	)
+	{ // TODO: remove in the future
+		m, err := meter.Int64Histogram("probes_latency",
+			otelapi.WithDescription("latency of landed probe transactions"),
+			otelapi.WithUnit("s"),
+			otelapi.WithExplicitBucketBoundaries(0, 1, 4, 16, 64, 256),
+		)
+		if err != nil {
+			return err
+		}
+		ProbesLatency_Old = m
+	}
+
+	m, err := NewInt64Candlestick("probes_latency_ohlc", "latency of landed probe transactions", "s")
 	if err != nil {
 		return err
 	}
+	if _, err := m.registerCallback(meter); err != nil {
+		return err
+	}
 	ProbesLatency = m
+
 	return nil
 }
 

server/l2.go

@@ -372,6 +372,7 @@ func (l2 *L2) processBlock(ctx context.Context, blockNumber uint64) error {
 					zap.Uint64("landed", block.Time()),
 				)
 				metrics.ProbesLatency.Record(ctx, int64(latency))
+				metrics.ProbesLatency_Old.Record(ctx, int64(latency))
 			}
 		}