feat(taiko-client): add proposer_pool_content_fetch_time metric (#1…

…8190)

packages/taiko-client/internal/metrics/metrics.go

@@ -29,6 +29,7 @@ var (
 	ProposerProposeEpochCounter    = factory.NewCounter(prometheus.CounterOpts{Name: "proposer_epoch"})
 	ProposerProposedTxListsCounter = factory.NewCounter(prometheus.CounterOpts{Name: "proposer_proposed_txLists"})
 	ProposerProposedTxsCounter     = factory.NewCounter(prometheus.CounterOpts{Name: "proposer_proposed_txs"})
+	ProposerPoolContentFetchTime   = factory.NewGauge(prometheus.GaugeOpts{Name: "proposer_pool_content_fetch_time"})
 
 	// Prover
 	ProverLatestVerifiedIDGauge      = factory.NewGauge(prometheus.GaugeOpts{Name: "prover_latestVerified_id"})

packages/taiko-client/proposer/proposer.go

@@ -184,7 +184,10 @@ func (p *Proposer) Close(_ context.Context) {
 
 // fetchPoolContent fetches the transaction pool content from L2 execution engine.
 func (p *Proposer) fetchPoolContent(filterPoolContent bool) ([]types.Transactions, error) {
-	minTip := p.MinTip
+	var (
+		minTip  = p.MinTip
+		startAt = time.Now()
+	)
 	// If `--epoch.allowZeroInterval` flag is set, allow proposing zero tip transactions once when
 	// the total epochs number is divisible by the flag value.
 	if p.AllowZeroInterval > 0 && p.totalEpochs%p.AllowZeroInterval == 0 {
@@ -206,6 +209,8 @@ func (p *Proposer) fetchPoolContent(filterPoolContent bool) ([]types.Transaction
 		return nil, fmt.Errorf("failed to fetch transaction pool content: %w", err)
 	}
 
+	metrics.ProposerPoolContentFetchTime.Set(time.Since(startAt).Seconds())
+
 	txLists := []types.Transactions{}
 	for i, txs := range preBuiltTxList {
 		// Filter the pool content if the filterPoolContent flag is set.