txmgr

Oct 8, 2024

Changes in this version

+ func DefaultGasPriceEstimatorFn(ctx context.Context, backend ETHBackend) (*big.Int, *big.Int, *big.Int, error)

type Config

+ GasPriceEstimatorFn GasPriceEstimatorFn

+ type GasPriceEstimatorFn func(ctx context.Context, backend ETHBackend) (*big.Int, *big.Int, *big.Int, error)

Sep 25, 2024

Changes in this version

+ type SendResponse struct

+ Err error

+ Nonce uint64

+ Receipt *types.Receipt

type SimpleTxManager

+ func (m *SimpleTxManager) SendAsync(ctx context.Context, candidate TxCandidate, ch chan SendResponse)

type TxManager

+ SendAsync func(ctx context.Context, candidate TxCandidate, ch chan SendResponse)

+ SuggestGasPriceCaps func(ctx context.Context) (tipCap *big.Int, baseFee *big.Int, blobBaseFee *big.Int, err error)

Aug 28, 2024

Changes in this version

type Config

+ MinBlobTxFee atomic.Pointer[big.Int]

type SimpleTxManager

+ func (m *SimpleTxManager) API() rpc.API

+ func (m *SimpleTxManager) GetBumpFeeRetryTime() time.Duration

+ func (m *SimpleTxManager) GetFeeLimitMultiplier() uint64

+ func (m *SimpleTxManager) GetFeeThreshold() *big.Int

+ func (m *SimpleTxManager) GetMinBaseFee() *big.Int

+ func (m *SimpleTxManager) GetMinBlobFee() *big.Int

+ func (m *SimpleTxManager) GetMinPriorityFee() *big.Int

+ func (m *SimpleTxManager) SetBumpFeeRetryTime(val time.Duration)

+ func (m *SimpleTxManager) SetFeeLimitMultiplier(val uint64)

+ func (m *SimpleTxManager) SetFeeThreshold(val *big.Int)

+ func (m *SimpleTxManager) SetMinBaseFee(val *big.Int)

+ func (m *SimpleTxManager) SetMinBlobFee(val *big.Int)

+ func (m *SimpleTxManager) SetMinPriorityFee(val *big.Int)

+ type SimpleTxmgrAPI struct

+ func (a *SimpleTxmgrAPI) GetBumpFeeRetryTime(_ context.Context) time.Duration

+ func (a *SimpleTxmgrAPI) GetFeeThreshold(_ context.Context) *big.Int

+ func (a *SimpleTxmgrAPI) GetMinBaseFee(_ context.Context) *big.Int

+ func (a *SimpleTxmgrAPI) GetMinBlobFee(_ context.Context) *big.Int

+ func (a *SimpleTxmgrAPI) GetMinPriorityFee(_ context.Context) *big.Int

+ func (a *SimpleTxmgrAPI) SetBumpFeeRetryTime(_ context.Context, val time.Duration)

+ func (a *SimpleTxmgrAPI) SetFeeThreshold(_ context.Context, val *big.Int)

+ func (a *SimpleTxmgrAPI) SetMinBaseFee(_ context.Context, val *big.Int)

+ func (a *SimpleTxmgrAPI) SetMinBlobFee(_ context.Context, val *big.Int)

+ func (a *SimpleTxmgrAPI) SetMinPriorityFee(_ context.Context, val *big.Int)

type TxManager

+ API func() rpc.API

Aug 7, 2024

Changes in this version

type SimpleTxManager

+ func (m *SimpleTxManager) SuggestGasPriceCaps(ctx context.Context) (*big.Int, *big.Int, *big.Int, error)

+ type TestTxManager struct

+ func (m *TestTxManager) JamTxPool(ctx context.Context, candidate TxCandidate) error

+ func (m *TestTxManager) WaitOnJammingTx(ctx context.Context) error

Mar 20, 2024

Changes in this version

+ var ErrAlreadyReserved = errors.New("address already reserved")

+ var ErrMempoolDeadlineExpired = errors.New("failed to get tx into the mempool")

type SendState

+ func (s *SendState) CriticalError() error

type SimpleTxManager

+ func (m *SimpleTxManager) IsClosed() bool

type TxManager

+ IsClosed func() bool

Feb 15, 2024

Changes in this version

type DefaultFlagValues

+ MinBaseFeeGwei float64

+ MinTipCapGwei float64

Jan 31, 2024

Changes in this version

+ const MinBaseFeeFlagName

+ var ErrBlobFeeLimit = errors.New("blob fee limit reached")

+ var ErrClosed = errors.New("transaction manager is closed")

+ func MakeSidecar(blobs []*eth.Blob) (*types.BlobTxSidecar, []common.Hash, error)

type CLIConfig

+ MinBaseFeeGwei float64

type Config

+ MinBaseFee *big.Int

type TxCandidate

+ Blobs []*eth.Blob

Jan 6, 2024

Changes in this version

+ const MinBasefeeFlagName

+ const MinTipCapFlagName

type CLIConfig

+ MinBasefeeGwei float64

+ MinTipCapGwei float64

type Config

+ MinBasefee *big.Int

+ MinTipCap *big.Int

Dec 22, 2023

Changes in this version

+ const FeeLimitMultiplierFlagName

+ const FeeLimitThresholdFlagName

type CLIConfig

+ FeeLimitMultiplier uint64

+ FeeLimitThresholdGwei float64

type Config

+ FeeLimitMultiplier uint64

+ FeeLimitThreshold *big.Int

type DefaultFlagValues

+ FeeLimitMultiplier uint64

+ FeeLimitThresholdGwei float64

type ETHBackend

+ Close func()

type SimpleTxManager

+ func (m *SimpleTxManager) Close()

type TxManager

+ Close func()

Oct 6, 2023

Changes in this version

+ var DefaultBatcherFlagValues = DefaultFlagValues

+ var DefaultChallengerFlagValues = DefaultFlagValues

+ func CLIFlagsWithDefaults(envPrefix string, defaults DefaultFlagValues) []cli.Flag

+ type DefaultFlagValues struct

+ NetworkTimeout time.Duration

+ NumConfirmations uint64

+ ReceiptQueryInterval time.Duration

+ ResubmissionTimeout time.Duration

+ SafeAbortNonceTooLowCount uint64

+ TxNotInMempoolTimeout time.Duration

+ TxSendTimeout time.Duration

Sep 25, 2023

Changes in this version

type Config

+ func (m Config) Check() error

type SimpleTxManager

+ func NewSimpleTxManagerFromConfig(name string, l log.Logger, m metrics.TxMetricer, conf Config) (*SimpleTxManager, error)

type TxCandidate

+ Value *big.Int

Jul 25, 2023

Changes in this version

type CLIConfig

+ func NewCLIConfig(l1RPCURL string) CLIConfig

type ETHBackend

+ CallContract func(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)

type SimpleTxManager

+ func (m *SimpleTxManager) BlockNumber(ctx context.Context) (uint64, error)

+ func (m *SimpleTxManager) Call(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)

type TxManager

+ BlockNumber func(ctx context.Context) (uint64, error)

+ Call func(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)

May 1, 2023

Changes in this version

+ type Queue struct

+ func NewQueue(ctx context.Context, txMgr TxManager, maxPending uint64) *Queue[T]

+ func (q *Queue[T]) Send(id T, candidate TxCandidate, receiptCh chan TxReceipt[T])

+ func (q *Queue[T]) TrySend(id T, candidate TxCandidate, receiptCh chan TxReceipt[T]) bool

+ func (q *Queue[T]) Wait()

+ type TxReceipt struct

+ Err error

+ ID T

+ Receipt *types.Receipt

Apr 3, 2023

Changes in this version

+ const HDPathFlagName

+ const L1RPCFlagName

+ const MnemonicFlagName

+ const NetworkTimeoutFlagName

+ const NumConfirmationsFlagName

+ const PrivateKeyFlagName

+ const ReceiptQueryIntervalFlagName

+ const ResubmissionTimeoutFlagName

+ const SafeAbortNonceTooLowCountFlagName

+ const TxNotInMempoolTimeoutFlagName

+ const TxSendTimeoutFlagName

+ var L2OutputHDPathFlag = cli.StringFlag

+ var SequencerHDPathFlag = cli.StringFlag

+ func CLIFlags(envPrefix string) []cli.Flag

+ type CLIConfig struct

+ HDPath string

+ L1RPCURL string

+ L2OutputHDPath string

+ Mnemonic string

+ NetworkTimeout time.Duration

+ NumConfirmations uint64

+ PrivateKey string

+ ReceiptQueryInterval time.Duration

+ ResubmissionTimeout time.Duration

+ SafeAbortNonceTooLowCount uint64

+ SequencerHDPath string

+ SignerCLIConfig client.CLIConfig

+ TxNotInMempoolTimeout time.Duration

+ TxSendTimeout time.Duration

+ func ReadCLIConfig(ctx *cli.Context) CLIConfig

+ func (m CLIConfig) Check() error

type Config

+ Backend ETHBackend

+ TxNotInMempoolTimeout time.Duration

+ TxSendTimeout time.Duration

+ func NewConfig(cfg CLIConfig, l log.Logger) (Config, error)

type ETHBackend

+ PendingNonceAt func(ctx context.Context, account common.Address) (uint64, error)

type SendState

+ func NewSendStateWithNow(safeAbortNonceTooLowCount uint64, unableToSendTimeout time.Duration, ...) *SendState

type SimpleTxManager

+ func (m *SimpleTxManager) From() common.Address

type TxManager

+ From func() common.Address

Mar 27, 2023

Changes in this version

+ func CalcGasFeeCap(baseFee, gasTipCap *big.Int) *big.Int

+ type Config struct

+ ChainID *big.Int

+ From common.Address

+ NetworkTimeout time.Duration

+ NumConfirmations uint64

+ ReceiptQueryInterval time.Duration

+ ResubmissionTimeout time.Duration

+ SafeAbortNonceTooLowCount uint64

+ Signer opcrypto.SignerFn

+ type ETHBackend interface

+ BlockNumber func(ctx context.Context) (uint64, error)

+ EstimateGas func(ctx context.Context, msg ethereum.CallMsg) (uint64, error)

+ HeaderByNumber func(ctx context.Context, number *big.Int) (*types.Header, error)

+ NonceAt func(ctx context.Context, account common.Address, blockNumber *big.Int) (uint64, error)

+ SendTransaction func(ctx context.Context, tx *types.Transaction) error

+ SuggestGasTipCap func(ctx context.Context) (*big.Int, error)

+ TransactionReceipt func(ctx context.Context, txHash common.Hash) (*types.Receipt, error)

+ type SendState struct

+ func NewSendState(safeAbortNonceTooLowCount uint64) *SendState

+ func (s *SendState) IsWaitingForConfirmation() bool

+ func (s *SendState) ProcessSendError(err error)

+ func (s *SendState) ShouldAbortImmediately() bool

+ func (s *SendState) TxMined(txHash common.Hash)

+ func (s *SendState) TxNotMined(txHash common.Hash)

+ type SendTransactionFunc = func(ctx context.Context, tx *types.Transaction) error

+ type SimpleTxManager struct

+ func NewSimpleTxManager(name string, l log.Logger, cfg Config, backend ETHBackend) *SimpleTxManager

+ func (m *SimpleTxManager) IncreaseGasPrice(ctx context.Context, tx *types.Transaction) (*types.Transaction, error)

+ func (m *SimpleTxManager) Send(ctx context.Context, candidate TxCandidate) (*types.Receipt, error)

+ type TxCandidate struct

+ From common.Address

+ GasLimit uint64

+ To common.Address

+ TxData []byte

+ type TxManager interface

+ Send func(ctx context.Context, candidate TxCandidate) (*types.Receipt, error)

+ type UpdateGasPriceFunc = func(ctx context.Context) (*types.Transaction, error)