diff --git a/ethergo/submitter/metrics.go b/ethergo/submitter/metrics.go index e21196fedd..c156b1b2ed 100644 --- a/ethergo/submitter/metrics.go +++ b/ethergo/submitter/metrics.go @@ -128,6 +128,8 @@ func (o *otelRecorder) recordNumPending(_ context.Context, observer metric.Obser ) observer.ObserveInt64(o.numPendingGauge, int64(numPending), opts) + fmt.Println("recoreded", chainID, numPending) + return true }) @@ -145,6 +147,7 @@ func (o *otelRecorder) recordNonces(_ context.Context, observer metric.Observer) attribute.String("wallet", o.signer.Address().Hex()), ) observer.ObserveInt64(o.nonceGauge, int64(nonce), opts) + fmt.Println("recoreded", chainID, nonce) return true }) @@ -173,6 +176,8 @@ func (o *otelRecorder) recordBalance(_ context.Context, observer metric.Observer return nil } + fmt.Println("recoreded", o.currentGasBalances) + o.currentGasBalances.Range(func(chainID uint32, gasPrice *big.Int) bool { opts := metric.WithAttributes( attribute.Int(metrics.ChainID, int(chainID)), @@ -191,6 +196,8 @@ func (o *otelRecorder) recordOldestPendingTx(_ context.Context, observer metric. return nil } + fmt.Println("recoreded", o.oldestPendingPerChain) + o.oldestPendingPerChain.Range(func(chainID uint32, oldestPendingTx time.Duration) bool { opts := metric.WithAttributes( attribute.Int(metrics.ChainID, int(chainID)),