Documentation ¶
Index ¶
- type Config
- type EvmTxStore
- func (_m *EvmTxStore) Abandon(id *big.Int, addr common.Address) error
- func (_m *EvmTxStore) CheckTxQueueCapacity(fromAddress common.Address, maxQueuedTransactions uint64, chainID *big.Int, ...) error
- func (_m *EvmTxStore) Close()
- func (_m *EvmTxStore) CountUnconfirmedTransactions(fromAddress common.Address, chainID *big.Int, qopts ...pg.QOpt) (uint32, error)
- func (_m *EvmTxStore) CountUnstartedTransactions(fromAddress common.Address, chainID *big.Int, qopts ...pg.QOpt) (uint32, error)
- func (_m *EvmTxStore) CreateTransaction(txRequest types.TxRequest[common.Address, common.Hash], chainID *big.Int, ...) (...)
- func (_m *EvmTxStore) DeleteInProgressAttempt(ctx context.Context, ...) error
- func (_m *EvmTxStore) FindNextUnstartedTransactionFromAddress(...) error
- func (_m *EvmTxStore) FindReceiptsPendingConfirmation(ctx context.Context, blockNum int64, chainID *big.Int) ([]types.ReceiptPlus[*evmtypes.Receipt], error)
- func (_m *EvmTxStore) FindTransactionsConfirmedInBlockRange(highBlockNumber int64, lowBlockNumber int64, chainID *big.Int) (...)
- func (_m *EvmTxStore) FindTxAttempt(hash common.Hash) (...)
- func (_m *EvmTxStore) FindTxAttemptConfirmedByTxIDs(ids []int64) (...)
- func (_m *EvmTxStore) FindTxAttemptsConfirmedMissingReceipt(chainID *big.Int) (...)
- func (_m *EvmTxStore) FindTxAttemptsRequiringReceiptFetch(chainID *big.Int) (...)
- func (_m *EvmTxStore) FindTxAttemptsRequiringResend(olderThan time.Time, maxInFlightTransactions uint32, chainID *big.Int, ...) (...)
- func (_m *EvmTxStore) FindTxByHash(hash common.Hash) (...)
- func (_m *EvmTxStore) FindTxWithSequence(fromAddress common.Address, seq evmtypes.Nonce) (...)
- func (_m *EvmTxStore) FindTxsRequiringGasBump(ctx context.Context, address common.Address, blockNum int64, ...) (...)
- func (_m *EvmTxStore) FindTxsRequiringResubmissionDueToInsufficientFunds(address common.Address, chainID *big.Int, qopts ...pg.QOpt) (...)
- func (_m *EvmTxStore) GetInProgressTxAttempts(ctx context.Context, address common.Address, chainID *big.Int) (...)
- func (_m *EvmTxStore) GetTxInProgress(fromAddress common.Address, qopts ...pg.QOpt) (...)
- func (_m *EvmTxStore) HasInProgressTransaction(account common.Address, chainID *big.Int, qopts ...pg.QOpt) (bool, error)
- func (_m *EvmTxStore) LoadTxAttempts(...) error
- func (_m *EvmTxStore) MarkAllConfirmedMissingReceipt(chainID *big.Int) error
- func (_m *EvmTxStore) MarkOldTxesMissingReceiptAsErrored(blockNum int64, finalityDepth uint32, chainID *big.Int, qopts ...pg.QOpt) error
- func (_m *EvmTxStore) PreloadTxes(...) error
- func (_m *EvmTxStore) PruneUnstartedTxQueue(queueSize uint32, subject uuid.UUID, qopts ...pg.QOpt) (int64, error)
- func (_m *EvmTxStore) ReapTxHistory(minBlockNumberToKeep int64, timeThreshold time.Time, chainID *big.Int) error
- func (_m *EvmTxStore) SaveConfirmedMissingReceiptAttempt(ctx context.Context, timeout time.Duration, ...) error
- func (_m *EvmTxStore) SaveFetchedReceipts(receipts []*evmtypes.Receipt, chainID *big.Int) error
- func (_m *EvmTxStore) SaveInProgressAttempt(...) error
- func (_m *EvmTxStore) SaveInsufficientFundsAttempt(timeout time.Duration, ...) error
- func (_m *EvmTxStore) SaveReplacementInProgressAttempt(...) error
- func (_m *EvmTxStore) SaveSentAttempt(timeout time.Duration, ...) error
- func (_m *EvmTxStore) SetBroadcastBeforeBlockNum(blockNum int64, chainID *big.Int) error
- func (_m *EvmTxStore) Transactions(offset int, limit int) (...)
- func (_m *EvmTxStore) TransactionsWithAttempts(offset int, limit int) (...)
- func (_m *EvmTxStore) TxAttempts(offset int, limit int) (...)
- func (_m *EvmTxStore) UpdateBroadcastAts(now time.Time, etxIDs []int64) error
- func (_m *EvmTxStore) UpdateKeyNextSequence(newNextSequence evmtypes.Nonce, currentNextSequence evmtypes.Nonce, ...) error
- func (_m *EvmTxStore) UpdateTxAttemptInProgressToBroadcast(...) error
- func (_m *EvmTxStore) UpdateTxFatalError(...) error
- func (_m *EvmTxStore) UpdateTxForRebroadcast(...) error
- func (_m *EvmTxStore) UpdateTxUnstartedToInProgress(...) error
- func (_m *EvmTxStore) UpdateTxsUnconfirmed(ids []int64) error
- type MockEvmTxManager
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 ChainConfig 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) FinalityDepth ¶ added in v2.3.0
FinalityDepth provides a mock function with given fields:
func (*Config) FinalityTagEnabled ¶ added in v2.4.0
FinalityTagEnabled provides a mock function with given fields:
func (*Config) NonceAutoSync ¶ added in v2.3.0
NonceAutoSync provides a mock function with given fields:
func (*Config) RPCDefaultBatchSize ¶ added in v2.3.0
RPCDefaultBatchSize provides a mock function with given fields:
type EvmTxStore ¶ added in v2.3.0
EvmTxStore is an autogenerated mock type for the EvmTxStore type
func NewEvmTxStore ¶ added in v2.3.0
func NewEvmTxStore(t mockConstructorTestingTNewEvmTxStore) *EvmTxStore
NewEvmTxStore creates a new instance of EvmTxStore. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*EvmTxStore) Abandon ¶ added in v2.3.0
Abandon provides a mock function with given fields: id, addr
func (*EvmTxStore) CheckTxQueueCapacity ¶ added in v2.3.0
func (_m *EvmTxStore) CheckTxQueueCapacity(fromAddress common.Address, maxQueuedTransactions uint64, chainID *big.Int, qopts ...pg.QOpt) error
CheckTxQueueCapacity provides a mock function with given fields: fromAddress, maxQueuedTransactions, chainID, qopts
func (*EvmTxStore) Close ¶ added in v2.3.0
func (_m *EvmTxStore) Close()
Close provides a mock function with given fields:
func (*EvmTxStore) CountUnconfirmedTransactions ¶ added in v2.3.0
func (_m *EvmTxStore) CountUnconfirmedTransactions(fromAddress common.Address, chainID *big.Int, qopts ...pg.QOpt) (uint32, error)
CountUnconfirmedTransactions provides a mock function with given fields: fromAddress, chainID, qopts
func (*EvmTxStore) CountUnstartedTransactions ¶ added in v2.3.0
func (_m *EvmTxStore) CountUnstartedTransactions(fromAddress common.Address, chainID *big.Int, qopts ...pg.QOpt) (uint32, error)
CountUnstartedTransactions provides a mock function with given fields: fromAddress, chainID, qopts
func (*EvmTxStore) CreateTransaction ¶ added in v2.3.0
func (_m *EvmTxStore) CreateTransaction(txRequest types.TxRequest[common.Address, common.Hash], chainID *big.Int, qopts ...pg.QOpt) (types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
CreateTransaction provides a mock function with given fields: txRequest, chainID, qopts
func (*EvmTxStore) DeleteInProgressAttempt ¶ added in v2.3.0
func (_m *EvmTxStore) DeleteInProgressAttempt(ctx context.Context, attempt types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee]) error
DeleteInProgressAttempt provides a mock function with given fields: ctx, attempt
func (*EvmTxStore) FindNextUnstartedTransactionFromAddress ¶ added in v2.3.0
func (_m *EvmTxStore) FindNextUnstartedTransactionFromAddress(etx *types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], fromAddress common.Address, chainID *big.Int, qopts ...pg.QOpt) error
FindNextUnstartedTransactionFromAddress provides a mock function with given fields: etx, fromAddress, chainID, qopts
func (*EvmTxStore) FindReceiptsPendingConfirmation ¶ added in v2.3.0
func (_m *EvmTxStore) FindReceiptsPendingConfirmation(ctx context.Context, blockNum int64, chainID *big.Int) ([]types.ReceiptPlus[*evmtypes.Receipt], error)
FindReceiptsPendingConfirmation provides a mock function with given fields: ctx, blockNum, chainID
func (*EvmTxStore) FindTransactionsConfirmedInBlockRange ¶ added in v2.3.0
func (_m *EvmTxStore) FindTransactionsConfirmedInBlockRange(highBlockNumber int64, lowBlockNumber int64, chainID *big.Int) ([]*types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
FindTransactionsConfirmedInBlockRange provides a mock function with given fields: highBlockNumber, lowBlockNumber, chainID
func (*EvmTxStore) FindTxAttempt ¶ added in v2.3.0
func (_m *EvmTxStore) FindTxAttempt(hash common.Hash) (*types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
FindTxAttempt provides a mock function with given fields: hash
func (*EvmTxStore) FindTxAttemptConfirmedByTxIDs ¶ added in v2.3.0
func (_m *EvmTxStore) FindTxAttemptConfirmedByTxIDs(ids []int64) ([]types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
FindTxAttemptConfirmedByTxIDs provides a mock function with given fields: ids
func (*EvmTxStore) FindTxAttemptsConfirmedMissingReceipt ¶ added in v2.3.0
func (_m *EvmTxStore) FindTxAttemptsConfirmedMissingReceipt(chainID *big.Int) ([]types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
FindTxAttemptsConfirmedMissingReceipt provides a mock function with given fields: chainID
func (*EvmTxStore) FindTxAttemptsRequiringReceiptFetch ¶ added in v2.3.0
func (_m *EvmTxStore) FindTxAttemptsRequiringReceiptFetch(chainID *big.Int) ([]types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
FindTxAttemptsRequiringReceiptFetch provides a mock function with given fields: chainID
func (*EvmTxStore) FindTxAttemptsRequiringResend ¶ added in v2.3.0
func (_m *EvmTxStore) FindTxAttemptsRequiringResend(olderThan time.Time, maxInFlightTransactions uint32, chainID *big.Int, address common.Address) ([]types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
FindTxAttemptsRequiringResend provides a mock function with given fields: olderThan, maxInFlightTransactions, chainID, address
func (*EvmTxStore) FindTxByHash ¶ added in v2.3.0
func (_m *EvmTxStore) FindTxByHash(hash common.Hash) (*types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
FindTxByHash provides a mock function with given fields: hash
func (*EvmTxStore) FindTxWithSequence ¶ added in v2.3.0
func (_m *EvmTxStore) FindTxWithSequence(fromAddress common.Address, seq evmtypes.Nonce) (*types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
FindTxWithSequence provides a mock function with given fields: fromAddress, seq
func (*EvmTxStore) FindTxsRequiringGasBump ¶ added in v2.3.0
func (_m *EvmTxStore) FindTxsRequiringGasBump(ctx context.Context, address common.Address, blockNum int64, gasBumpThreshold int64, depth int64, chainID *big.Int) ([]*types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
FindTxsRequiringGasBump provides a mock function with given fields: ctx, address, blockNum, gasBumpThreshold, depth, chainID
func (*EvmTxStore) FindTxsRequiringResubmissionDueToInsufficientFunds ¶ added in v2.3.0
func (_m *EvmTxStore) FindTxsRequiringResubmissionDueToInsufficientFunds(address common.Address, chainID *big.Int, qopts ...pg.QOpt) ([]*types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
FindTxsRequiringResubmissionDueToInsufficientFunds provides a mock function with given fields: address, chainID, qopts
func (*EvmTxStore) GetInProgressTxAttempts ¶ added in v2.3.0
func (_m *EvmTxStore) GetInProgressTxAttempts(ctx context.Context, address common.Address, chainID *big.Int) ([]types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
GetInProgressTxAttempts provides a mock function with given fields: ctx, address, chainID
func (*EvmTxStore) GetTxInProgress ¶ added in v2.3.0
func (_m *EvmTxStore) GetTxInProgress(fromAddress common.Address, qopts ...pg.QOpt) (*types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
GetTxInProgress provides a mock function with given fields: fromAddress, qopts
func (*EvmTxStore) HasInProgressTransaction ¶ added in v2.3.0
func (_m *EvmTxStore) HasInProgressTransaction(account common.Address, chainID *big.Int, qopts ...pg.QOpt) (bool, error)
HasInProgressTransaction provides a mock function with given fields: account, chainID, qopts
func (*EvmTxStore) LoadTxAttempts ¶ added in v2.3.0
func (_m *EvmTxStore) LoadTxAttempts(etx *types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], qopts ...pg.QOpt) error
LoadTxAttempts provides a mock function with given fields: etx, qopts
func (*EvmTxStore) MarkAllConfirmedMissingReceipt ¶ added in v2.3.0
func (_m *EvmTxStore) MarkAllConfirmedMissingReceipt(chainID *big.Int) error
MarkAllConfirmedMissingReceipt provides a mock function with given fields: chainID
func (*EvmTxStore) MarkOldTxesMissingReceiptAsErrored ¶ added in v2.3.0
func (_m *EvmTxStore) 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 (*EvmTxStore) PreloadTxes ¶ added in v2.3.0
func (_m *EvmTxStore) PreloadTxes(attempts []types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], qopts ...pg.QOpt) error
PreloadTxes provides a mock function with given fields: attempts, qopts
func (*EvmTxStore) PruneUnstartedTxQueue ¶ added in v2.3.0
func (_m *EvmTxStore) PruneUnstartedTxQueue(queueSize uint32, subject uuid.UUID, qopts ...pg.QOpt) (int64, error)
PruneUnstartedTxQueue provides a mock function with given fields: queueSize, subject, qopts
func (*EvmTxStore) ReapTxHistory ¶ added in v2.3.0
func (_m *EvmTxStore) ReapTxHistory(minBlockNumberToKeep int64, timeThreshold time.Time, chainID *big.Int) error
ReapTxHistory provides a mock function with given fields: minBlockNumberToKeep, timeThreshold, chainID
func (*EvmTxStore) SaveConfirmedMissingReceiptAttempt ¶ added in v2.3.0
func (_m *EvmTxStore) SaveConfirmedMissingReceiptAttempt(ctx context.Context, timeout time.Duration, attempt *types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], broadcastAt time.Time) error
SaveConfirmedMissingReceiptAttempt provides a mock function with given fields: ctx, timeout, attempt, broadcastAt
func (*EvmTxStore) SaveFetchedReceipts ¶ added in v2.3.0
SaveFetchedReceipts provides a mock function with given fields: receipts, chainID
func (*EvmTxStore) SaveInProgressAttempt ¶ added in v2.3.0
func (_m *EvmTxStore) SaveInProgressAttempt(attempt *types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee]) error
SaveInProgressAttempt provides a mock function with given fields: attempt
func (*EvmTxStore) SaveInsufficientFundsAttempt ¶ added in v2.3.0
func (_m *EvmTxStore) SaveInsufficientFundsAttempt(timeout time.Duration, attempt *types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], broadcastAt time.Time) error
SaveInsufficientFundsAttempt provides a mock function with given fields: timeout, attempt, broadcastAt
func (*EvmTxStore) SaveReplacementInProgressAttempt ¶ added in v2.3.0
func (_m *EvmTxStore) SaveReplacementInProgressAttempt(oldAttempt types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], replacementAttempt *types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], qopts ...pg.QOpt) error
SaveReplacementInProgressAttempt provides a mock function with given fields: oldAttempt, replacementAttempt, qopts
func (*EvmTxStore) SaveSentAttempt ¶ added in v2.3.0
func (_m *EvmTxStore) SaveSentAttempt(timeout time.Duration, attempt *types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], broadcastAt time.Time) error
SaveSentAttempt provides a mock function with given fields: timeout, attempt, broadcastAt
func (*EvmTxStore) SetBroadcastBeforeBlockNum ¶ added in v2.3.0
func (_m *EvmTxStore) SetBroadcastBeforeBlockNum(blockNum int64, chainID *big.Int) error
SetBroadcastBeforeBlockNum provides a mock function with given fields: blockNum, chainID
func (*EvmTxStore) Transactions ¶ added in v2.3.0
func (_m *EvmTxStore) Transactions(offset int, limit int) ([]types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], int, error)
Transactions provides a mock function with given fields: offset, limit
func (*EvmTxStore) TransactionsWithAttempts ¶ added in v2.3.0
func (_m *EvmTxStore) TransactionsWithAttempts(offset int, limit int) ([]types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], int, error)
TransactionsWithAttempts provides a mock function with given fields: offset, limit
func (*EvmTxStore) TxAttempts ¶ added in v2.3.0
func (_m *EvmTxStore) TxAttempts(offset int, limit int) ([]types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], int, error)
TxAttempts provides a mock function with given fields: offset, limit
func (*EvmTxStore) UpdateBroadcastAts ¶ added in v2.3.0
func (_m *EvmTxStore) UpdateBroadcastAts(now time.Time, etxIDs []int64) error
UpdateBroadcastAts provides a mock function with given fields: now, etxIDs
func (*EvmTxStore) UpdateKeyNextSequence ¶ added in v2.3.0
func (_m *EvmTxStore) UpdateKeyNextSequence(newNextSequence evmtypes.Nonce, currentNextSequence evmtypes.Nonce, address common.Address, chainID *big.Int, qopts ...pg.QOpt) error
UpdateKeyNextSequence provides a mock function with given fields: newNextSequence, currentNextSequence, address, chainID, qopts
func (*EvmTxStore) UpdateTxAttemptInProgressToBroadcast ¶ added in v2.3.0
func (_m *EvmTxStore) UpdateTxAttemptInProgressToBroadcast(etx *types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], attempt types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], NewAttemptState types.TxAttemptState, incrNextSequenceCallback func(pg.Queryer) error, qopts ...pg.QOpt) error
UpdateTxAttemptInProgressToBroadcast provides a mock function with given fields: etx, attempt, NewAttemptState, incrNextSequenceCallback, qopts
func (*EvmTxStore) UpdateTxFatalError ¶ added in v2.3.0
func (_m *EvmTxStore) UpdateTxFatalError(etx *types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], qopts ...pg.QOpt) error
UpdateTxFatalError provides a mock function with given fields: etx, qopts
func (*EvmTxStore) UpdateTxForRebroadcast ¶ added in v2.3.0
func (_m *EvmTxStore) UpdateTxForRebroadcast(etx types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], etxAttempt types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee]) error
UpdateTxForRebroadcast provides a mock function with given fields: etx, etxAttempt
func (*EvmTxStore) UpdateTxUnstartedToInProgress ¶ added in v2.3.0
func (_m *EvmTxStore) UpdateTxUnstartedToInProgress(etx *types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], attempt *types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], qopts ...pg.QOpt) error
UpdateTxUnstartedToInProgress provides a mock function with given fields: etx, attempt, qopts
func (*EvmTxStore) UpdateTxsUnconfirmed ¶ added in v2.3.0
func (_m *EvmTxStore) UpdateTxsUnconfirmed(ids []int64) error
UpdateTxsUnconfirmed provides a mock function with given fields: ids