forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-26 06:36:43 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

feat: add metrics finalized block (#1172)

Browse source
This commit is contained in:
Morty 2025-05-15 16:29:34 +08:00 committed by GitHub
parent 2500647c49
commit aba2ddda86
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 11 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
rollup/rollup_sync_service/rollup_sync_service.go
View file

@ -17,6 +17,7 @@ import (
"github.com/scroll-tech/go-ethereum/core/rawdb" "github.com/scroll-tech/go-ethereum/core/rawdb"
"github.com/scroll-tech/go-ethereum/ethdb" "github.com/scroll-tech/go-ethereum/ethdb"
"github.com/scroll-tech/go-ethereum/log" "github.com/scroll-tech/go-ethereum/log"
"github.com/scroll-tech/go-ethereum/metrics"
"github.com/scroll-tech/go-ethereum/node" "github.com/scroll-tech/go-ethereum/node"
"github.com/scroll-tech/go-ethereum/params" "github.com/scroll-tech/go-ethereum/params"
"github.com/scroll-tech/go-ethereum/rollup/da_syncer" "github.com/scroll-tech/go-ethereum/rollup/da_syncer"
@ -43,7 +44,10 @@ const (
defaultLogInterval = 5 * time.Minute defaultLogInterval = 5 * time.Minute
) )
var ErrShouldResetSyncHeight = errors.New("ErrShouldResetSyncHeight") var (
finalizedBlockGauge = metrics.NewRegisteredGauge("chain/head/finalized", nil)
ErrShouldResetSyncHeight = errors.New("ErrShouldResetSyncHeight")
)
// RollupSyncService collects ScrollChain batch commit/revert/finalize events and stores metadata into db. // RollupSyncService collects ScrollChain batch commit/revert/finalize events and stores metadata into db.
type RollupSyncService struct { type RollupSyncService struct {
@ -135,6 +139,11 @@ func (s *RollupSyncService) Start() {
log.Info("Starting rollup event sync background service", "latest processed block", s.callDataBlobSource.L1Height()) log.Info("Starting rollup event sync background service", "latest processed block", s.callDataBlobSource.L1Height())
finalizedBlockHeightPtr := rawdb.ReadFinalizedL2BlockNumber(s.db)
if finalizedBlockHeightPtr != nil {
finalizedBlockGauge.Update(int64(*finalizedBlockHeightPtr))
}
go func() { go func() {
syncTicker := time.NewTicker(defaultSyncInterval) syncTicker := time.NewTicker(defaultSyncInterval)
defer syncTicker.Stop() defer syncTicker.Stop()
@ -321,6 +330,7 @@ func (s *RollupSyncService) updateRollupEvents(daEntries da.Entries) error {
return fmt.Errorf("failed to batch write finalized batch meta to database: %w", err) return fmt.Errorf("failed to batch write finalized batch meta to database: %w", err)
} }
rawdb.WriteFinalizedL2BlockNumber(s.db, highestFinalizedBlockNumber) rawdb.WriteFinalizedL2BlockNumber(s.db, highestFinalizedBlockNumber)
finalizedBlockGauge.Update(int64(highestFinalizedBlockNumber))
rawdb.WriteLastFinalizedBatchIndex(s.db, batchIndex) rawdb.WriteLastFinalizedBatchIndex(s.db, batchIndex)
log.Debug("write finalized l2 block number", "batch index", batchIndex, "finalized l2 block height", highestFinalizedBlockNumber) log.Debug("write finalized l2 block number", "batch index", batchIndex, "finalized l2 block height", highestFinalizedBlockNumber)