Documentation ¶
Index ¶
- type Config
- func (_m *Config) BlockHistoryEstimatorBatchSize() uint32
- func (_m *Config) BlockHistoryEstimatorBlockDelay() uint16
- func (_m *Config) BlockHistoryEstimatorBlockHistorySize() uint16
- func (_m *Config) BlockHistoryEstimatorCheckInclusionBlocks() uint16
- func (_m *Config) BlockHistoryEstimatorCheckInclusionPercentile() uint16
- func (_m *Config) BlockHistoryEstimatorEIP1559FeeCapBufferBlocks() uint16
- func (_m *Config) BlockHistoryEstimatorTransactionPercentile() uint16
- func (_m *Config) ChainType() config.ChainType
- func (_m *Config) DatabaseDefaultQueryTimeout() time.Duration
- func (_m *Config) EthTxReaperInterval() time.Duration
- func (_m *Config) EthTxReaperThreshold() time.Duration
- func (_m *Config) EthTxResendAfterThreshold() time.Duration
- func (_m *Config) EvmEIP1559DynamicFees() bool
- func (_m *Config) EvmFinalityDepth() uint32
- func (_m *Config) EvmGasBumpPercent() uint16
- func (_m *Config) EvmGasBumpThreshold() uint64
- func (_m *Config) EvmGasBumpTxDepth() uint16
- func (_m *Config) EvmGasBumpWei() *assets.Wei
- func (_m *Config) EvmGasFeeCapDefault() *assets.Wei
- func (_m *Config) EvmGasLimitDefault() uint32
- func (_m *Config) EvmGasLimitMax() uint32
- func (_m *Config) EvmGasLimitMultiplier() float32
- func (_m *Config) EvmGasPriceDefault() *assets.Wei
- func (_m *Config) EvmGasTipCapDefault() *assets.Wei
- func (_m *Config) EvmGasTipCapMinimum() *assets.Wei
- func (_m *Config) EvmMaxGasPriceWei() *assets.Wei
- func (_m *Config) EvmMaxInFlightTransactions() uint32
- func (_m *Config) EvmMaxQueuedTransactions() uint64
- func (_m *Config) EvmMinGasPriceWei() *assets.Wei
- func (_m *Config) EvmNonceAutoSync() bool
- func (_m *Config) EvmRPCDefaultBatchSize() uint32
- func (_m *Config) EvmUseForwarders() bool
- func (_m *Config) GasEstimatorMode() string
- func (_m *Config) KeySpecificMaxGasPriceWei(addr common.Address) *assets.Wei
- func (_m *Config) LogSQL() bool
- func (_m *Config) TriggerFallbackDBPollInterval() time.Duration
- type ORM
- func (_m *ORM) CheckEthTxQueueCapacity(fromAddress common.Address, maxQueuedTransactions uint64, chainID big.Int, ...) error
- func (_m *ORM) Close()
- func (_m *ORM) CountUnconfirmedTransactions(fromAddress common.Address, chainID big.Int, qopts ...pg.QOpt) (uint32, error)
- func (_m *ORM) CountUnstartedTransactions(fromAddress common.Address, chainID big.Int, qopts ...pg.QOpt) (uint32, error)
- func (_m *ORM) CreateEthTransaction(newTx txmgr.NewTx, chainID big.Int, qopts ...pg.QOpt) (txmgr.EthTx, error)
- func (_m *ORM) DeleteInProgressAttempt(ctx context.Context, attempt txmgr.EthTxAttempt) error
- func (_m *ORM) EthTransactions(offset int, limit int) ([]txmgr.EthTx, int, error)
- func (_m *ORM) EthTransactionsWithAttempts(offset int, limit int) ([]txmgr.EthTx, int, error)
- func (_m *ORM) EthTxAttempts(offset int, limit int) ([]txmgr.EthTxAttempt, int, error)
- func (_m *ORM) FindEthReceiptsPendingConfirmation(ctx context.Context, blockNum int64, chainID big.Int) ([]types.ReceiptPlus[evmtypes.Receipt], error)
- func (_m *ORM) FindEthTxAttempt(hash common.Hash) (*txmgr.EthTxAttempt, error)
- func (_m *ORM) FindEthTxAttemptConfirmedByEthTxIDs(ids []int64) ([]txmgr.EthTxAttempt, error)
- func (_m *ORM) FindEthTxAttemptsByEthTxIDs(ids []int64) ([]txmgr.EthTxAttempt, error)
- func (_m *ORM) FindEthTxAttemptsRequiringReceiptFetch(chainID big.Int) ([]txmgr.EthTxAttempt, error)
- func (_m *ORM) FindEthTxAttemptsRequiringResend(olderThan time.Time, maxInFlightTransactions uint32, chainID big.Int, ...) ([]txmgr.EthTxAttempt, error)
- func (_m *ORM) FindEthTxByHash(hash common.Hash) (*txmgr.EthTx, error)
- func (_m *ORM) FindEthTxWithAttempts(etxID int64) (txmgr.EthTx, error)
- func (_m *ORM) FindEthTxWithNonce(fromAddress common.Address, nonce int64) (*txmgr.EthTx, error)
- func (_m *ORM) FindEthTxsRequiringGasBump(ctx context.Context, address common.Address, blockNum int64, ...) ([]*txmgr.EthTx, error)
- func (_m *ORM) FindEthTxsRequiringResubmissionDueToInsufficientEth(address common.Address, chainID big.Int, qopts ...pg.QOpt) ([]*txmgr.EthTx, error)
- func (_m *ORM) FindEtxAttemptsConfirmedMissingReceipt(chainID big.Int) ([]txmgr.EthTxAttempt, error)
- func (_m *ORM) FindNextUnstartedTransactionFromAddress(etx *txmgr.EthTx, fromAddress common.Address, chainID big.Int, ...) error
- func (_m *ORM) FindTransactionsConfirmedInBlockRange(highBlockNumber int64, lowBlockNumber int64, chainID big.Int) ([]*txmgr.EthTx, error)
- func (_m *ORM) GetEthTxInProgress(fromAddress common.Address, qopts ...pg.QOpt) (*txmgr.EthTx, error)
- func (_m *ORM) GetInProgressEthTxAttempts(ctx context.Context, address common.Address, chainID big.Int) ([]txmgr.EthTxAttempt, error)
- func (_m *ORM) HasInProgressTransaction(account common.Address, chainID big.Int, qopts ...pg.QOpt) (bool, error)
- func (_m *ORM) InsertEthReceipt(receipt *types.Receipt[evmtypes.Receipt, common.Hash]) error
- func (_m *ORM) InsertEthTx(etx *txmgr.EthTx) error
- func (_m *ORM) InsertEthTxAttempt(attempt *txmgr.EthTxAttempt) error
- func (_m *ORM) LoadEthTxAttempts(etx *txmgr.EthTx, qopts ...pg.QOpt) error
- func (_m *ORM) LoadEthTxesAttempts(etxs []*txmgr.EthTx, qopts ...pg.QOpt) error
- func (_m *ORM) MarkAllConfirmedMissingReceipt(chainID big.Int) error
- func (_m *ORM) MarkOldTxesMissingReceiptAsErrored(blockNum int64, finalityDepth uint32, chainID big.Int, qopts ...pg.QOpt) error
- func (_m *ORM) PreloadEthTxes(attempts []txmgr.EthTxAttempt) error
- func (_m *ORM) PruneUnstartedTxQueue(queueSize uint32, subject uuid.UUID, qopts ...pg.QOpt) (int64, error)
- func (_m *ORM) SaveConfirmedMissingReceiptAttempt(ctx context.Context, timeout time.Duration, attempt *txmgr.EthTxAttempt, ...) error
- func (_m *ORM) SaveFetchedReceipts(receipts []evmtypes.Receipt, chainID big.Int) error
- func (_m *ORM) SaveInProgressAttempt(attempt *txmgr.EthTxAttempt) error
- func (_m *ORM) SaveInsufficientEthAttempt(timeout time.Duration, attempt *txmgr.EthTxAttempt, broadcastAt time.Time) error
- func (_m *ORM) SaveReplacementInProgressAttempt(oldAttempt txmgr.EthTxAttempt, replacementAttempt *txmgr.EthTxAttempt, ...) error
- func (_m *ORM) SaveSentAttempt(timeout time.Duration, attempt *txmgr.EthTxAttempt, broadcastAt time.Time) error
- func (_m *ORM) SetBroadcastBeforeBlockNum(blockNum int64, chainID big.Int) error
- func (_m *ORM) UpdateBroadcastAts(now time.Time, etxIDs []int64) error
- func (_m *ORM) UpdateEthKeyNextNonce(newNextNonce int64, currentNextNonce int64, address common.Address, ...) error
- func (_m *ORM) UpdateEthTxAttemptInProgressToBroadcast(etx *txmgr.EthTx, attempt txmgr.EthTxAttempt, ...) error
- func (_m *ORM) UpdateEthTxFatalError(etx *txmgr.EthTx, qopts ...pg.QOpt) error
- func (_m *ORM) UpdateEthTxForRebroadcast(etx txmgr.EthTx, etxAttempt txmgr.EthTxAttempt) error
- func (_m *ORM) UpdateEthTxUnstartedToInProgress(etx *txmgr.EthTx, attempt *txmgr.EthTxAttempt, qopts ...pg.QOpt) error
- func (_m *ORM) UpdateEthTxsUnconfirmed(ids []int64) error
- type ReaperConfig
- type TxManager
- func (_m *TxManager) Close() error
- func (_m *TxManager) CreateEthTransaction(newTx txmgr.NewTx, qopts ...pg.QOpt) (txmgr.EthTx, error)
- func (_m *TxManager) GetForwarderForEOA(eoa common.Address) (common.Address, error)
- func (_m *TxManager) HealthReport() map[string]error
- func (_m *TxManager) Name() string
- func (_m *TxManager) OnNewLongestChain(ctx context.Context, head *types.Head)
- func (_m *TxManager) Ready() error
- func (_m *TxManager) RegisterResumeCallback(fn txmgr.ResumeCallback)
- func (_m *TxManager) Reset(f func(), addr common.Address, abandon bool) error
- func (_m *TxManager) SendEther(chainID *big.Int, from common.Address, to common.Address, value assets.Eth, ...) (txmgr.EthTx, error)
- func (_m *TxManager) Start(_a0 context.Context) error
- func (_m *TxManager) Trigger(addr common.Address)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
Config is an autogenerated mock type for the Config type
func NewConfig ¶
func NewConfig(t mockConstructorTestingTNewConfig) *Config
NewConfig creates a new instance of Config. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Config) BlockHistoryEstimatorBatchSize ¶
BlockHistoryEstimatorBatchSize provides a mock function with given fields:
func (*Config) BlockHistoryEstimatorBlockDelay ¶
BlockHistoryEstimatorBlockDelay provides a mock function with given fields:
func (*Config) BlockHistoryEstimatorBlockHistorySize ¶
BlockHistoryEstimatorBlockHistorySize provides a mock function with given fields:
func (*Config) BlockHistoryEstimatorCheckInclusionBlocks ¶
BlockHistoryEstimatorCheckInclusionBlocks provides a mock function with given fields:
func (*Config) BlockHistoryEstimatorCheckInclusionPercentile ¶
BlockHistoryEstimatorCheckInclusionPercentile provides a mock function with given fields:
func (*Config) BlockHistoryEstimatorEIP1559FeeCapBufferBlocks ¶
BlockHistoryEstimatorEIP1559FeeCapBufferBlocks provides a mock function with given fields:
func (*Config) BlockHistoryEstimatorTransactionPercentile ¶
BlockHistoryEstimatorTransactionPercentile provides a mock function with given fields:
func (*Config) DatabaseDefaultQueryTimeout ¶
DatabaseDefaultQueryTimeout provides a mock function with given fields:
func (*Config) EthTxReaperInterval ¶
EthTxReaperInterval provides a mock function with given fields:
func (*Config) EthTxReaperThreshold ¶
EthTxReaperThreshold provides a mock function with given fields:
func (*Config) EthTxResendAfterThreshold ¶
EthTxResendAfterThreshold provides a mock function with given fields:
func (*Config) EvmEIP1559DynamicFees ¶
EvmEIP1559DynamicFees provides a mock function with given fields:
func (*Config) EvmFinalityDepth ¶
EvmFinalityDepth provides a mock function with given fields:
func (*Config) EvmGasBumpPercent ¶
EvmGasBumpPercent provides a mock function with given fields:
func (*Config) EvmGasBumpThreshold ¶
EvmGasBumpThreshold provides a mock function with given fields:
func (*Config) EvmGasBumpTxDepth ¶
EvmGasBumpTxDepth provides a mock function with given fields:
func (*Config) EvmGasBumpWei ¶
EvmGasBumpWei provides a mock function with given fields:
func (*Config) EvmGasFeeCapDefault ¶
EvmGasFeeCapDefault provides a mock function with given fields:
func (*Config) EvmGasLimitDefault ¶
EvmGasLimitDefault provides a mock function with given fields:
func (*Config) EvmGasLimitMax ¶
EvmGasLimitMax provides a mock function with given fields:
func (*Config) EvmGasLimitMultiplier ¶
EvmGasLimitMultiplier provides a mock function with given fields:
func (*Config) EvmGasPriceDefault ¶
EvmGasPriceDefault provides a mock function with given fields:
func (*Config) EvmGasTipCapDefault ¶
EvmGasTipCapDefault provides a mock function with given fields:
func (*Config) EvmGasTipCapMinimum ¶
EvmGasTipCapMinimum provides a mock function with given fields:
func (*Config) EvmMaxGasPriceWei ¶
EvmMaxGasPriceWei provides a mock function with given fields:
func (*Config) EvmMaxInFlightTransactions ¶
EvmMaxInFlightTransactions provides a mock function with given fields:
func (*Config) EvmMaxQueuedTransactions ¶
EvmMaxQueuedTransactions provides a mock function with given fields:
func (*Config) EvmMinGasPriceWei ¶
EvmMinGasPriceWei provides a mock function with given fields:
func (*Config) EvmNonceAutoSync ¶
EvmNonceAutoSync provides a mock function with given fields:
func (*Config) EvmRPCDefaultBatchSize ¶
EvmRPCDefaultBatchSize provides a mock function with given fields:
func (*Config) EvmUseForwarders ¶
EvmUseForwarders provides a mock function with given fields:
func (*Config) GasEstimatorMode ¶
GasEstimatorMode provides a mock function with given fields:
func (*Config) KeySpecificMaxGasPriceWei ¶
KeySpecificMaxGasPriceWei provides a mock function with given fields: addr
func (*Config) TriggerFallbackDBPollInterval ¶
TriggerFallbackDBPollInterval provides a mock function with given fields:
type ORM ¶
ORM is an autogenerated mock type for the ORM type
func NewORM ¶
func NewORM(t mockConstructorTestingTNewORM) *ORM
NewORM creates a new instance of ORM. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*ORM) CheckEthTxQueueCapacity ¶
func (_m *ORM) CheckEthTxQueueCapacity(fromAddress common.Address, maxQueuedTransactions uint64, chainID big.Int, qopts ...pg.QOpt) error
CheckEthTxQueueCapacity provides a mock function with given fields: fromAddress, maxQueuedTransactions, chainID, qopts
func (*ORM) CountUnconfirmedTransactions ¶
func (_m *ORM) CountUnconfirmedTransactions(fromAddress common.Address, chainID big.Int, qopts ...pg.QOpt) (uint32, error)
CountUnconfirmedTransactions provides a mock function with given fields: fromAddress, chainID, qopts
func (*ORM) CountUnstartedTransactions ¶
func (_m *ORM) CountUnstartedTransactions(fromAddress common.Address, chainID big.Int, qopts ...pg.QOpt) (uint32, error)
CountUnstartedTransactions provides a mock function with given fields: fromAddress, chainID, qopts
func (*ORM) CreateEthTransaction ¶
func (_m *ORM) CreateEthTransaction(newTx txmgr.NewTx, chainID big.Int, qopts ...pg.QOpt) (txmgr.EthTx, error)
CreateEthTransaction provides a mock function with given fields: newTx, chainID, qopts
func (*ORM) DeleteInProgressAttempt ¶
DeleteInProgressAttempt provides a mock function with given fields: ctx, attempt
func (*ORM) EthTransactions ¶
EthTransactions provides a mock function with given fields: offset, limit
func (*ORM) EthTransactionsWithAttempts ¶
EthTransactionsWithAttempts provides a mock function with given fields: offset, limit
func (*ORM) EthTxAttempts ¶
EthTxAttempts provides a mock function with given fields: offset, limit
func (*ORM) FindEthReceiptsPendingConfirmation ¶
func (_m *ORM) FindEthReceiptsPendingConfirmation(ctx context.Context, blockNum int64, chainID big.Int) ([]types.ReceiptPlus[evmtypes.Receipt], error)
FindEthReceiptsPendingConfirmation provides a mock function with given fields: ctx, blockNum, chainID
func (*ORM) FindEthTxAttempt ¶
FindEthTxAttempt provides a mock function with given fields: hash
func (*ORM) FindEthTxAttemptConfirmedByEthTxIDs ¶
func (_m *ORM) FindEthTxAttemptConfirmedByEthTxIDs(ids []int64) ([]txmgr.EthTxAttempt, error)
FindEthTxAttemptConfirmedByEthTxIDs provides a mock function with given fields: ids
func (*ORM) FindEthTxAttemptsByEthTxIDs ¶
func (_m *ORM) FindEthTxAttemptsByEthTxIDs(ids []int64) ([]txmgr.EthTxAttempt, error)
FindEthTxAttemptsByEthTxIDs provides a mock function with given fields: ids
func (*ORM) FindEthTxAttemptsRequiringReceiptFetch ¶
func (_m *ORM) FindEthTxAttemptsRequiringReceiptFetch(chainID big.Int) ([]txmgr.EthTxAttempt, error)
FindEthTxAttemptsRequiringReceiptFetch provides a mock function with given fields: chainID
func (*ORM) FindEthTxAttemptsRequiringResend ¶
func (_m *ORM) FindEthTxAttemptsRequiringResend(olderThan time.Time, maxInFlightTransactions uint32, chainID big.Int, address common.Address) ([]txmgr.EthTxAttempt, error)
FindEthTxAttemptsRequiringResend provides a mock function with given fields: olderThan, maxInFlightTransactions, chainID, address
func (*ORM) FindEthTxByHash ¶
FindEthTxByHash provides a mock function with given fields: hash
func (*ORM) FindEthTxWithAttempts ¶
FindEthTxWithAttempts provides a mock function with given fields: etxID
func (*ORM) FindEthTxWithNonce ¶
FindEthTxWithNonce provides a mock function with given fields: fromAddress, nonce
func (*ORM) FindEthTxsRequiringGasBump ¶
func (_m *ORM) FindEthTxsRequiringGasBump(ctx context.Context, address common.Address, blockNum int64, gasBumpThreshold int64, depth int64, chainID big.Int) ([]*txmgr.EthTx, error)
FindEthTxsRequiringGasBump provides a mock function with given fields: ctx, address, blockNum, gasBumpThreshold, depth, chainID
func (*ORM) FindEthTxsRequiringResubmissionDueToInsufficientEth ¶
func (_m *ORM) FindEthTxsRequiringResubmissionDueToInsufficientEth(address common.Address, chainID big.Int, qopts ...pg.QOpt) ([]*txmgr.EthTx, error)
FindEthTxsRequiringResubmissionDueToInsufficientEth provides a mock function with given fields: address, chainID, qopts
func (*ORM) FindEtxAttemptsConfirmedMissingReceipt ¶
func (_m *ORM) FindEtxAttemptsConfirmedMissingReceipt(chainID big.Int) ([]txmgr.EthTxAttempt, error)
FindEtxAttemptsConfirmedMissingReceipt provides a mock function with given fields: chainID
func (*ORM) FindNextUnstartedTransactionFromAddress ¶
func (_m *ORM) FindNextUnstartedTransactionFromAddress(etx *txmgr.EthTx, fromAddress common.Address, chainID big.Int, qopts ...pg.QOpt) error
FindNextUnstartedTransactionFromAddress provides a mock function with given fields: etx, fromAddress, chainID, qopts
func (*ORM) FindTransactionsConfirmedInBlockRange ¶
func (_m *ORM) FindTransactionsConfirmedInBlockRange(highBlockNumber int64, lowBlockNumber int64, chainID big.Int) ([]*txmgr.EthTx, error)
FindTransactionsConfirmedInBlockRange provides a mock function with given fields: highBlockNumber, lowBlockNumber, chainID
func (*ORM) GetEthTxInProgress ¶
func (_m *ORM) GetEthTxInProgress(fromAddress common.Address, qopts ...pg.QOpt) (*txmgr.EthTx, error)
GetEthTxInProgress provides a mock function with given fields: fromAddress, qopts
func (*ORM) GetInProgressEthTxAttempts ¶
func (_m *ORM) GetInProgressEthTxAttempts(ctx context.Context, address common.Address, chainID big.Int) ([]txmgr.EthTxAttempt, error)
GetInProgressEthTxAttempts provides a mock function with given fields: ctx, address, chainID
func (*ORM) HasInProgressTransaction ¶
func (_m *ORM) HasInProgressTransaction(account common.Address, chainID big.Int, qopts ...pg.QOpt) (bool, error)
HasInProgressTransaction provides a mock function with given fields: account, chainID, qopts
func (*ORM) InsertEthReceipt ¶
InsertEthReceipt provides a mock function with given fields: receipt
func (*ORM) InsertEthTx ¶
InsertEthTx provides a mock function with given fields: etx
func (*ORM) InsertEthTxAttempt ¶
func (_m *ORM) InsertEthTxAttempt(attempt *txmgr.EthTxAttempt) error
InsertEthTxAttempt provides a mock function with given fields: attempt
func (*ORM) LoadEthTxAttempts ¶
LoadEthTxAttempts provides a mock function with given fields: etx, qopts
func (*ORM) LoadEthTxesAttempts ¶
LoadEthTxesAttempts provides a mock function with given fields: etxs, qopts
func (*ORM) MarkAllConfirmedMissingReceipt ¶
MarkAllConfirmedMissingReceipt provides a mock function with given fields: chainID
func (*ORM) MarkOldTxesMissingReceiptAsErrored ¶
func (_m *ORM) MarkOldTxesMissingReceiptAsErrored(blockNum int64, finalityDepth uint32, chainID big.Int, qopts ...pg.QOpt) error
MarkOldTxesMissingReceiptAsErrored provides a mock function with given fields: blockNum, finalityDepth, chainID, qopts
func (*ORM) PreloadEthTxes ¶
func (_m *ORM) PreloadEthTxes(attempts []txmgr.EthTxAttempt) error
PreloadEthTxes provides a mock function with given fields: attempts
func (*ORM) PruneUnstartedTxQueue ¶
func (_m *ORM) PruneUnstartedTxQueue(queueSize uint32, subject uuid.UUID, qopts ...pg.QOpt) (int64, error)
PruneUnstartedTxQueue provides a mock function with given fields: queueSize, subject, qopts
func (*ORM) SaveConfirmedMissingReceiptAttempt ¶
func (_m *ORM) SaveConfirmedMissingReceiptAttempt(ctx context.Context, timeout time.Duration, attempt *txmgr.EthTxAttempt, broadcastAt time.Time) error
SaveConfirmedMissingReceiptAttempt provides a mock function with given fields: ctx, timeout, attempt, broadcastAt
func (*ORM) SaveFetchedReceipts ¶
SaveFetchedReceipts provides a mock function with given fields: receipts, chainID
func (*ORM) SaveInProgressAttempt ¶
func (_m *ORM) SaveInProgressAttempt(attempt *txmgr.EthTxAttempt) error
SaveInProgressAttempt provides a mock function with given fields: attempt
func (*ORM) SaveInsufficientEthAttempt ¶
func (_m *ORM) SaveInsufficientEthAttempt(timeout time.Duration, attempt *txmgr.EthTxAttempt, broadcastAt time.Time) error
SaveInsufficientEthAttempt provides a mock function with given fields: timeout, attempt, broadcastAt
func (*ORM) SaveReplacementInProgressAttempt ¶
func (_m *ORM) SaveReplacementInProgressAttempt(oldAttempt txmgr.EthTxAttempt, replacementAttempt *txmgr.EthTxAttempt, qopts ...pg.QOpt) error
SaveReplacementInProgressAttempt provides a mock function with given fields: oldAttempt, replacementAttempt, qopts
func (*ORM) SaveSentAttempt ¶
func (_m *ORM) SaveSentAttempt(timeout time.Duration, attempt *txmgr.EthTxAttempt, broadcastAt time.Time) error
SaveSentAttempt provides a mock function with given fields: timeout, attempt, broadcastAt
func (*ORM) SetBroadcastBeforeBlockNum ¶
SetBroadcastBeforeBlockNum provides a mock function with given fields: blockNum, chainID
func (*ORM) UpdateBroadcastAts ¶
UpdateBroadcastAts provides a mock function with given fields: now, etxIDs
func (*ORM) UpdateEthKeyNextNonce ¶
func (_m *ORM) UpdateEthKeyNextNonce(newNextNonce int64, currentNextNonce int64, address common.Address, chainID big.Int, qopts ...pg.QOpt) error
UpdateEthKeyNextNonce provides a mock function with given fields: newNextNonce, currentNextNonce, address, chainID, qopts
func (*ORM) UpdateEthTxAttemptInProgressToBroadcast ¶
func (_m *ORM) UpdateEthTxAttemptInProgressToBroadcast(etx *txmgr.EthTx, attempt txmgr.EthTxAttempt, NewAttemptState types.TxAttemptState, incrNextNonceCallback func(pg.Queryer) error, qopts ...pg.QOpt) error
UpdateEthTxAttemptInProgressToBroadcast provides a mock function with given fields: etx, attempt, NewAttemptState, incrNextNonceCallback, qopts
func (*ORM) UpdateEthTxFatalError ¶
UpdateEthTxFatalError provides a mock function with given fields: etx, qopts
func (*ORM) UpdateEthTxForRebroadcast ¶
UpdateEthTxForRebroadcast provides a mock function with given fields: etx, etxAttempt
func (*ORM) UpdateEthTxUnstartedToInProgress ¶
func (_m *ORM) UpdateEthTxUnstartedToInProgress(etx *txmgr.EthTx, attempt *txmgr.EthTxAttempt, qopts ...pg.QOpt) error
UpdateEthTxUnstartedToInProgress provides a mock function with given fields: etx, attempt, qopts
func (*ORM) UpdateEthTxsUnconfirmed ¶
UpdateEthTxsUnconfirmed provides a mock function with given fields: ids
type ReaperConfig ¶
ReaperConfig is an autogenerated mock type for the ReaperConfig type
func NewReaperConfig ¶
func NewReaperConfig(t mockConstructorTestingTNewReaperConfig) *ReaperConfig
NewReaperConfig creates a new instance of ReaperConfig. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*ReaperConfig) EthTxReaperInterval ¶
func (_m *ReaperConfig) EthTxReaperInterval() time.Duration
EthTxReaperInterval provides a mock function with given fields:
func (*ReaperConfig) EthTxReaperThreshold ¶
func (_m *ReaperConfig) EthTxReaperThreshold() time.Duration
EthTxReaperThreshold provides a mock function with given fields:
func (*ReaperConfig) EvmFinalityDepth ¶
func (_m *ReaperConfig) EvmFinalityDepth() uint32
EvmFinalityDepth provides a mock function with given fields:
type TxManager ¶
TxManager is an autogenerated mock type for the TxManager type
func NewTxManager ¶
func NewTxManager(t mockConstructorTestingTNewTxManager) *TxManager
NewTxManager creates a new instance of TxManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*TxManager) CreateEthTransaction ¶
CreateEthTransaction provides a mock function with given fields: newTx, qopts
func (*TxManager) GetForwarderForEOA ¶
GetForwarderForEOA provides a mock function with given fields: eoa
func (*TxManager) HealthReport ¶
HealthReport provides a mock function with given fields:
func (*TxManager) OnNewLongestChain ¶
OnNewLongestChain provides a mock function with given fields: ctx, head
func (*TxManager) RegisterResumeCallback ¶
func (_m *TxManager) RegisterResumeCallback(fn txmgr.ResumeCallback)
RegisterResumeCallback provides a mock function with given fields: fn
func (*TxManager) SendEther ¶
func (_m *TxManager) SendEther(chainID *big.Int, from common.Address, to common.Address, value assets.Eth, gasLimit uint32) (txmgr.EthTx, error)
SendEther provides a mock function with given fields: chainID, from, to, value, gasLimit