add dynamic gas price metrics (#177)

* add DGP metrics * fix bug * fix lint * Update metrics_xlayer.go
okx · Apr 23, 2024 · 9cc0766 · 9cc0766
1 parent 3e9baae
commit 9cc0766
Show file tree

Hide file tree

Showing 3 changed files with 26 additions and 3 deletions.
diff --git a/jsonrpc/dynamic_gas_price_xlayer.go b/jsonrpc/dynamic_gas_price_xlayer.go
@@ -8,6 +8,7 @@ import (
 	"time"
 
 	zktypes "github.com/0xPolygonHermez/zkevm-node/config/types"
+	"github.com/0xPolygonHermez/zkevm-node/jsonrpc/metrics"
 	"github.com/0xPolygonHermez/zkevm-node/log"
 	"github.com/ethereum/go-ethereum/core/types"
 )
@@ -168,13 +169,15 @@ func (e *EthEndpoints) calcDynamicGP(ctx context.Context) {
 		e.dgpMan.cacheLock.Lock()
 		e.dgpMan.lastPrice = getAvgPrice(rawGP, price)
 		e.dgpMan.lastL2BatchNumber = l2BatchNumber
+		metrics.DynamicGasPrice(e.dgpMan.lastPrice.Int64())
 		e.dgpMan.cacheLock.Unlock()
 		return
 	}
 
 	e.dgpMan.cacheLock.Lock()
 	e.dgpMan.lastPrice = price
 	e.dgpMan.lastL2BatchNumber = l2BatchNumber
+	metrics.DynamicGasPrice(e.dgpMan.lastPrice.Int64())
 	e.dgpMan.cacheLock.Unlock()
 }
 

diff --git a/jsonrpc/metrics/metrics.go b/jsonrpc/metrics/metrics.go
@@ -75,6 +75,7 @@ func Register() {
 	// XLayer handler
 	metrics.RegisterCounterVecs(counterVecsXLayer...)
 	metrics.RegisterHistogramVecs(histogramVecs...)
+	metrics.RegisterGaugeVecs(gaugeVecs...)
 }
 
 // CountConn increments the connection counter vector by one for the

diff --git a/jsonrpc/metrics/metrics_xlayer.go b/jsonrpc/metrics/metrics_xlayer.go
@@ -19,9 +19,23 @@ var (
 	requestWsMethodDurationName = wsRequestPrefix + "method_duration"
 	requestMethodLabelName      = "method"
 
-	start         = 0.1
-	width         = 0.1
-	count         = 10
+	start = 0.1
+	width = 0.1
+	count = 10
+
+	lastDynamicGasPriceName  = prefix + "dynamic_gas_price"
+	lastBatchNumberLabelName = "batch_number"
+
+	gaugeVecs = []metrics.GaugeVecOpts{
+		{
+			GaugeOpts: prometheus.GaugeOpts{
+				Name: lastDynamicGasPriceName,
+				Help: "[JSONRPC] dynamic gas price",
+			},
+			Labels: []string{lastBatchNumberLabelName},
+		},
+	}
+
 	histogramVecs = []metrics.HistogramVecOpts{
 		{
 			HistogramOpts: prometheus.HistogramOpts{
@@ -117,3 +131,8 @@ func RequestInnerTxCachedCount() {
 func RequestInnerTxAddErrorCount() {
 	metrics.CounterVecInc(requestInnerTxAddErrorCount, "add_error")
 }
+
+// DynamicGasPrice sets the gauge vector to the given batch number and dynamic gas price.
+func DynamicGasPrice(dgp int64) {
+	metrics.GaugeVecSet(lastDynamicGasPriceName, "inf", float64(dgp))
+}