diff --git a/bridge/watcher/batch_proposer.go b/bridge/watcher/batch_proposer.go index c338f5cc6..cf59ef095 100644 --- a/bridge/watcher/batch_proposer.go +++ b/bridge/watcher/batch_proposer.go @@ -25,9 +25,11 @@ var ( bridgeL2BatchesTxsOverThresholdTotalCounter = geth_metrics.NewRegisteredCounter("bridge/l2/batches/txs/over/threshold/total", metrics.ScrollRegistry) bridgeL2BatchesBlocksCreatedTotalCounter = geth_metrics.NewRegisteredCounter("bridge/l2/batches/blocks/created/total", metrics.ScrollRegistry) bridgeL2BatchesCommitsSentTotalCounter = geth_metrics.NewRegisteredCounter("bridge/l2/batches/commits/sent/total", metrics.ScrollRegistry) + bridgeL2BatchesOversizedTotalCounter = geth_metrics.NewRegisteredCounter("bridge/l2/batches/oversized/total", metrics.ScrollRegistry) - bridgeL2BatchesTxsCreatedPerBatchGauge = geth_metrics.NewRegisteredGauge("bridge/l2/batches/txs/created/per/batch", metrics.ScrollRegistry) - bridgeL2BatchesGasCreatedPerBatchGauge = geth_metrics.NewRegisteredGauge("bridge/l2/batches/gas/created/per/batch", metrics.ScrollRegistry) + bridgeL2BatchesTxsCreatedPerBatchGauge = geth_metrics.NewRegisteredGauge("bridge/l2/batches/txs/created/per/batch", metrics.ScrollRegistry) + bridgeL2BatchesGasCreatedPerBatchGauge = geth_metrics.NewRegisteredGauge("bridge/l2/batches/gas/created/per/batch", metrics.ScrollRegistry) + bridgeL2BatchesPayloadSizePerBatchGauge = geth_metrics.NewRegisteredGauge("bridge/l2/batches/payload/size/per/batch", metrics.ScrollRegistry) ) // AddBatchInfoToDB inserts the batch information to the BlockBatch table and updates the batch_hash @@ -297,7 +299,9 @@ func (p *BatchProposer) proposeBatch(blocks []*types.BlockInfo) bool { } bridgeL2BatchesTxsCreatedPerBatchGauge.Update(int64(blocks[0].TxNum)) bridgeL2BatchesGasCreatedPerBatchGauge.Update(int64(blocks[0].GasUsed)) + bridgeL2BatchesPayloadSizePerBatchGauge.Update(int64(firstSize)) bridgeL2BatchesBlocksCreatedTotalCounter.Inc(1) + bridgeL2BatchesOversizedTotalCounter.Inc(1) return true } @@ -309,6 +313,7 @@ func (p *BatchProposer) proposeBatch(blocks []*types.BlockInfo) bool { } else { bridgeL2BatchesTxsCreatedPerBatchGauge.Update(int64(blocks[0].TxNum)) bridgeL2BatchesGasCreatedPerBatchGauge.Update(int64(blocks[0].GasUsed)) + bridgeL2BatchesPayloadSizePerBatchGauge.Update(int64(firstSize)) bridgeL2BatchesBlocksCreatedTotalCounter.Inc(1) } return true @@ -322,6 +327,7 @@ func (p *BatchProposer) proposeBatch(blocks []*types.BlockInfo) bool { } else { bridgeL2BatchesTxsCreatedPerBatchGauge.Update(int64(blocks[0].TxNum)) bridgeL2BatchesGasCreatedPerBatchGauge.Update(int64(blocks[0].GasUsed)) + bridgeL2BatchesPayloadSizePerBatchGauge.Update(int64(firstSize)) bridgeL2BatchesBlocksCreatedTotalCounter.Inc(1) } return true @@ -359,6 +365,7 @@ func (p *BatchProposer) proposeBatch(blocks []*types.BlockInfo) bool { } else { bridgeL2BatchesTxsCreatedPerBatchGauge.Update(int64(txNum)) bridgeL2BatchesGasCreatedPerBatchGauge.Update(int64(gasUsed)) + bridgeL2BatchesPayloadSizePerBatchGauge.Update(int64(payloadSize)) bridgeL2BatchesBlocksCreatedTotalCounter.Inc(int64(len(blocks))) } diff --git a/common/version/version.go b/common/version/version.go index 2a1b7c7f3..1b51c90b3 100644 --- a/common/version/version.go +++ b/common/version/version.go @@ -5,7 +5,7 @@ import ( "runtime/debug" ) -var tag = "v3.1.0" +var tag = "v3.1.1" var commit = func() string { if info, ok := debug.ReadBuildInfo(); ok {