tornadocontrib/infra
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

timeout metrics

Browse Source
This commit is contained in:
Felipe Andrade 2023-09-07 13:25:50 -07:00
parent cfbaf252b2
commit a231f5a16c
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
op-ufm/op-ufm/pkg/provider/roundtrip.go
View File

@ -84,6 +84,11 @@ func (p *Provider) RoundTrip(ctx context.Context) {
err.Error() == txpool.ErrReplaceUnderpriced.Error() || err.Error() == txpool.ErrReplaceUnderpriced.Error() ||
err.Error() == core.ErrNonceTooLow.Error() { err.Error() == core.ErrNonceTooLow.Error() {
log.Warn("cant send transaction (retryable)",
"provider", p.name,
"err", err,
"nonce", nonce)
if time.Since(firstAttemptAt) >= time.Duration(p.config.SendTransactionRetryTimeout) { if time.Since(firstAttemptAt) >= time.Duration(p.config.SendTransactionRetryTimeout) {
log.Error("send transaction timed out (known already)", log.Error("send transaction timed out (known already)",
"provider", p.name, "provider", p.name,
@ -91,7 +96,7 @@ func (p *Provider) RoundTrip(ctx context.Context) {
"nonce", nonce, "nonce", nonce,
"elapsed", time.Since(firstAttemptAt), "elapsed", time.Since(firstAttemptAt),
"attempt", attempt) "attempt", attempt)
metrics.RecordErrorDetails(p.name, "ethclient.SendTransaction", err) metrics.RecordErrorDetails(p.name, "send.timeout", err)
return return
} }
@ -148,6 +153,7 @@ func (p *Provider) RoundTrip(ctx context.Context) {
"hash", txHash, "hash", txHash,
"nonce", nonce, "nonce", nonce,
"elapsed", time.Since(sentAt)) "elapsed", time.Since(sentAt))
metrics.RecordErrorDetails(p.name, "receipt.timeout", err)
return return
} }
time.Sleep(time.Duration(p.config.ReceiptRetrievalInterval)) time.Sleep(time.Duration(p.config.ReceiptRetrievalInterval))
@ -251,9 +257,12 @@ func (p *Provider) createTx(ctx context.Context, client *iclients.InstrumentedEt
dynamicTx.Gas = gas dynamicTx.Gas = gas
tx := types.NewTx(dynamicTx) tx := types.NewTx(dynamicTx)
log.Debug("tx created", log.Info("tx created",
"provider", p.name, "provider", p.name,
"nonce", nonce, "from", addr,
"to", dynamicTx.To,
"nonce", dynamicTx.Nonce,
"value", dynamicTx.Value,
"gas", dynamicTx.Gas, "gas", dynamicTx.Gas,
"gasTipCap", dynamicTx.GasTipCap, "gasTipCap", dynamicTx.GasTipCap,
"gasFeeCap", dynamicTx.GasFeeCap, "gasFeeCap", dynamicTx.GasFeeCap,