Documentation ¶
Index ¶
- type Config
- type Config_ChainType_Call
- type Config_Expecter
- func (_e *Config_Expecter) ChainType() *Config_ChainType_Call
- func (_e *Config_Expecter) FinalityDepth() *Config_FinalityDepth_Call
- func (_e *Config_Expecter) FinalityTagEnabled() *Config_FinalityTagEnabled_Call
- func (_e *Config_Expecter) NonceAutoSync() *Config_NonceAutoSync_Call
- func (_e *Config_Expecter) RPCDefaultBatchSize() *Config_RPCDefaultBatchSize_Call
- type Config_FinalityDepth_Call
- type Config_FinalityTagEnabled_Call
- type Config_NonceAutoSync_Call
- type Config_RPCDefaultBatchSize_Call
- type EvmTxStore
- func (_m *EvmTxStore) Abandon(ctx context.Context, id *big.Int, addr common.Address) error
- func (_m *EvmTxStore) CheckTxQueueCapacity(ctx context.Context, fromAddress common.Address, maxQueuedTransactions uint64, ...) error
- func (_m *EvmTxStore) Close()
- func (_m *EvmTxStore) CountTransactionsByState(ctx context.Context, state types.TxState, chainID *big.Int) (uint32, error)
- func (_m *EvmTxStore) CountUnconfirmedTransactions(ctx context.Context, fromAddress common.Address, chainID *big.Int) (uint32, error)
- func (_m *EvmTxStore) CountUnstartedTransactions(ctx context.Context, fromAddress common.Address, chainID *big.Int) (uint32, error)
- func (_m *EvmTxStore) CreateTransaction(ctx context.Context, txRequest types.TxRequest[common.Address, common.Hash], ...) (...)
- func (_m *EvmTxStore) DeleteInProgressAttempt(ctx context.Context, ...) error
- func (_m *EvmTxStore) EXPECT() *EvmTxStore_Expecter
- func (_m *EvmTxStore) FindEarliestUnconfirmedBroadcastTime(ctx context.Context, chainID *big.Int) (null.Time, error)
- func (_m *EvmTxStore) FindEarliestUnconfirmedTxAttemptBlock(ctx context.Context, chainID *big.Int) (null.Int, error)
- func (_m *EvmTxStore) FindLatestSequence(ctx context.Context, fromAddress common.Address, chainId *big.Int) (evmtypes.Nonce, error)
- func (_m *EvmTxStore) FindNextUnstartedTransactionFromAddress(ctx context.Context, fromAddress common.Address, chainID *big.Int) (...)
- func (_m *EvmTxStore) FindTransactionsConfirmedInBlockRange(ctx context.Context, highBlockNumber int64, lowBlockNumber int64, ...) (...)
- func (_m *EvmTxStore) FindTxAttempt(ctx context.Context, hash common.Hash) (...)
- func (_m *EvmTxStore) FindTxAttemptConfirmedByTxIDs(ctx context.Context, ids []int64) (...)
- func (_m *EvmTxStore) FindTxAttemptsConfirmedMissingReceipt(ctx context.Context, chainID *big.Int) (...)
- func (_m *EvmTxStore) FindTxAttemptsRequiringReceiptFetch(ctx context.Context, chainID *big.Int) (...)
- func (_m *EvmTxStore) FindTxAttemptsRequiringResend(ctx context.Context, olderThan time.Time, maxInFlightTransactions uint32, ...) (...)
- func (_m *EvmTxStore) FindTxByHash(ctx context.Context, hash common.Hash) (...)
- func (_m *EvmTxStore) FindTxWithAttempts(ctx context.Context, etxID int64) (...)
- func (_m *EvmTxStore) FindTxWithIdempotencyKey(ctx context.Context, idempotencyKey string, chainID *big.Int) (...)
- func (_m *EvmTxStore) FindTxWithSequence(ctx context.Context, fromAddress common.Address, seq evmtypes.Nonce) (...)
- func (_m *EvmTxStore) FindTxesByMetaFieldAndStates(ctx context.Context, metaField string, metaValue string, ...) (...)
- func (_m *EvmTxStore) FindTxesPendingCallback(ctx context.Context, blockNum int64, chainID *big.Int) ([]types.ReceiptPlus[*evmtypes.Receipt], error)
- func (_m *EvmTxStore) FindTxesWithAttemptsAndReceiptsByIdsAndState(ctx context.Context, ids []int64, states []types.TxState, chainID *big.Int) (...)
- func (_m *EvmTxStore) FindTxesWithMetaFieldByReceiptBlockNum(ctx context.Context, metaField string, blockNum int64, chainID *big.Int) (...)
- func (_m *EvmTxStore) FindTxesWithMetaFieldByStates(ctx context.Context, metaField string, states []types.TxState, ...) (...)
- func (_m *EvmTxStore) FindTxsByStateAndFromAddresses(ctx context.Context, addresses []common.Address, state types.TxState, ...) (...)
- func (_m *EvmTxStore) FindTxsRequiringGasBump(ctx context.Context, address common.Address, blockNum int64, ...) (...)
- func (_m *EvmTxStore) FindTxsRequiringResubmissionDueToInsufficientFunds(ctx context.Context, address common.Address, chainID *big.Int) (...)
- func (_m *EvmTxStore) GetAbandonedTransactionsByBatch(ctx context.Context, chainID *big.Int, enabledAddrs []common.Address, ...) (...)
- func (_m *EvmTxStore) GetInProgressTxAttempts(ctx context.Context, address common.Address, chainID *big.Int) (...)
- func (_m *EvmTxStore) GetTxByID(ctx context.Context, id int64) (...)
- func (_m *EvmTxStore) GetTxInProgress(ctx context.Context, fromAddress common.Address) (...)
- func (_m *EvmTxStore) HasInProgressTransaction(ctx context.Context, account common.Address, chainID *big.Int) (bool, error)
- func (_m *EvmTxStore) IsTxFinalized(ctx context.Context, blockHeight int64, txID int64, chainID *big.Int) (bool, error)
- func (_m *EvmTxStore) LoadTxAttempts(ctx context.Context, ...) error
- func (_m *EvmTxStore) MarkAllConfirmedMissingReceipt(ctx context.Context, chainID *big.Int) error
- func (_m *EvmTxStore) MarkOldTxesMissingReceiptAsErrored(ctx context.Context, blockNum int64, finalityDepth uint32, chainID *big.Int) error
- func (_m *EvmTxStore) PreloadTxes(ctx context.Context, ...) error
- func (_m *EvmTxStore) PruneUnstartedTxQueue(ctx context.Context, queueSize uint32, subject uuid.UUID) ([]int64, error)
- func (_m *EvmTxStore) ReapTxHistory(ctx context.Context, minBlockNumberToKeep int64, timeThreshold time.Time, ...) error
- func (_m *EvmTxStore) SaveConfirmedMissingReceiptAttempt(ctx context.Context, timeout time.Duration, ...) error
- func (_m *EvmTxStore) SaveFetchedReceipts(ctx context.Context, r []*evmtypes.Receipt, state types.TxState, ...) error
- func (_m *EvmTxStore) SaveInProgressAttempt(ctx context.Context, ...) error
- func (_m *EvmTxStore) SaveInsufficientFundsAttempt(ctx context.Context, timeout time.Duration, ...) error
- func (_m *EvmTxStore) SaveReplacementInProgressAttempt(ctx context.Context, ...) error
- func (_m *EvmTxStore) SaveSentAttempt(ctx context.Context, timeout time.Duration, ...) error
- func (_m *EvmTxStore) SetBroadcastBeforeBlockNum(ctx context.Context, blockNum int64, chainID *big.Int) error
- func (_m *EvmTxStore) Transactions(ctx context.Context, offset int, limit int) (...)
- func (_m *EvmTxStore) TransactionsWithAttempts(ctx context.Context, offset int, limit int) (...)
- func (_m *EvmTxStore) TxAttempts(ctx context.Context, offset int, limit int) (...)
- func (_m *EvmTxStore) UpdateBroadcastAts(ctx context.Context, now time.Time, etxIDs []int64) error
- func (_m *EvmTxStore) UpdateTxAttemptInProgressToBroadcast(ctx context.Context, ...) error
- func (_m *EvmTxStore) UpdateTxCallbackCompleted(ctx context.Context, pipelineTaskRunRid uuid.UUID, chainId *big.Int) error
- func (_m *EvmTxStore) UpdateTxFatalError(ctx context.Context, ...) error
- func (_m *EvmTxStore) UpdateTxForRebroadcast(ctx context.Context, ...) error
- func (_m *EvmTxStore) UpdateTxUnstartedToInProgress(ctx context.Context, ...) error
- func (_m *EvmTxStore) UpdateTxsUnconfirmed(ctx context.Context, ids []int64) error
- type EvmTxStore_Abandon_Call
- func (_c *EvmTxStore_Abandon_Call) Return(_a0 error) *EvmTxStore_Abandon_Call
- func (_c *EvmTxStore_Abandon_Call) Run(run func(ctx context.Context, id *big.Int, addr common.Address)) *EvmTxStore_Abandon_Call
- func (_c *EvmTxStore_Abandon_Call) RunAndReturn(run func(context.Context, *big.Int, common.Address) error) *EvmTxStore_Abandon_Call
- type EvmTxStore_CheckTxQueueCapacity_Call
- func (_c *EvmTxStore_CheckTxQueueCapacity_Call) Return(err error) *EvmTxStore_CheckTxQueueCapacity_Call
- func (_c *EvmTxStore_CheckTxQueueCapacity_Call) Run(...) *EvmTxStore_CheckTxQueueCapacity_Call
- func (_c *EvmTxStore_CheckTxQueueCapacity_Call) RunAndReturn(run func(context.Context, common.Address, uint64, *big.Int) error) *EvmTxStore_CheckTxQueueCapacity_Call
- type EvmTxStore_Close_Call
- type EvmTxStore_CountTransactionsByState_Call
- func (_c *EvmTxStore_CountTransactionsByState_Call) Return(count uint32, err error) *EvmTxStore_CountTransactionsByState_Call
- func (_c *EvmTxStore_CountTransactionsByState_Call) Run(run func(ctx context.Context, state types.TxState, chainID *big.Int)) *EvmTxStore_CountTransactionsByState_Call
- func (_c *EvmTxStore_CountTransactionsByState_Call) RunAndReturn(run func(context.Context, types.TxState, *big.Int) (uint32, error)) *EvmTxStore_CountTransactionsByState_Call
- type EvmTxStore_CountUnconfirmedTransactions_Call
- func (_c *EvmTxStore_CountUnconfirmedTransactions_Call) Return(count uint32, err error) *EvmTxStore_CountUnconfirmedTransactions_Call
- func (_c *EvmTxStore_CountUnconfirmedTransactions_Call) Run(run func(ctx context.Context, fromAddress common.Address, chainID *big.Int)) *EvmTxStore_CountUnconfirmedTransactions_Call
- func (_c *EvmTxStore_CountUnconfirmedTransactions_Call) RunAndReturn(run func(context.Context, common.Address, *big.Int) (uint32, error)) *EvmTxStore_CountUnconfirmedTransactions_Call
- type EvmTxStore_CountUnstartedTransactions_Call
- func (_c *EvmTxStore_CountUnstartedTransactions_Call) Return(count uint32, err error) *EvmTxStore_CountUnstartedTransactions_Call
- func (_c *EvmTxStore_CountUnstartedTransactions_Call) Run(run func(ctx context.Context, fromAddress common.Address, chainID *big.Int)) *EvmTxStore_CountUnstartedTransactions_Call
- func (_c *EvmTxStore_CountUnstartedTransactions_Call) RunAndReturn(run func(context.Context, common.Address, *big.Int) (uint32, error)) *EvmTxStore_CountUnstartedTransactions_Call
- type EvmTxStore_CreateTransaction_Call
- type EvmTxStore_DeleteInProgressAttempt_Call
- func (_c *EvmTxStore_DeleteInProgressAttempt_Call) Return(_a0 error) *EvmTxStore_DeleteInProgressAttempt_Call
- func (_c *EvmTxStore_DeleteInProgressAttempt_Call) Run(run func(ctx context.Context, ...)) *EvmTxStore_DeleteInProgressAttempt_Call
- func (_c *EvmTxStore_DeleteInProgressAttempt_Call) RunAndReturn(run func(context.Context, ...) error) *EvmTxStore_DeleteInProgressAttempt_Call
- type EvmTxStore_Expecter
- func (_e *EvmTxStore_Expecter) Abandon(ctx interface{}, id interface{}, addr interface{}) *EvmTxStore_Abandon_Call
- func (_e *EvmTxStore_Expecter) CheckTxQueueCapacity(ctx interface{}, fromAddress interface{}, maxQueuedTransactions interface{}, ...) *EvmTxStore_CheckTxQueueCapacity_Call
- func (_e *EvmTxStore_Expecter) Close() *EvmTxStore_Close_Call
- func (_e *EvmTxStore_Expecter) CountTransactionsByState(ctx interface{}, state interface{}, chainID interface{}) *EvmTxStore_CountTransactionsByState_Call
- func (_e *EvmTxStore_Expecter) CountUnconfirmedTransactions(ctx interface{}, fromAddress interface{}, chainID interface{}) *EvmTxStore_CountUnconfirmedTransactions_Call
- func (_e *EvmTxStore_Expecter) CountUnstartedTransactions(ctx interface{}, fromAddress interface{}, chainID interface{}) *EvmTxStore_CountUnstartedTransactions_Call
- func (_e *EvmTxStore_Expecter) CreateTransaction(ctx interface{}, txRequest interface{}, chainID interface{}) *EvmTxStore_CreateTransaction_Call
- func (_e *EvmTxStore_Expecter) DeleteInProgressAttempt(ctx interface{}, attempt interface{}) *EvmTxStore_DeleteInProgressAttempt_Call
- func (_e *EvmTxStore_Expecter) FindEarliestUnconfirmedBroadcastTime(ctx interface{}, chainID interface{}) *EvmTxStore_FindEarliestUnconfirmedBroadcastTime_Call
- func (_e *EvmTxStore_Expecter) FindEarliestUnconfirmedTxAttemptBlock(ctx interface{}, chainID interface{}) *EvmTxStore_FindEarliestUnconfirmedTxAttemptBlock_Call
- func (_e *EvmTxStore_Expecter) FindLatestSequence(ctx interface{}, fromAddress interface{}, chainId interface{}) *EvmTxStore_FindLatestSequence_Call
- func (_e *EvmTxStore_Expecter) FindNextUnstartedTransactionFromAddress(ctx interface{}, fromAddress interface{}, chainID interface{}) *EvmTxStore_FindNextUnstartedTransactionFromAddress_Call
- func (_e *EvmTxStore_Expecter) FindTransactionsConfirmedInBlockRange(ctx interface{}, highBlockNumber interface{}, lowBlockNumber interface{}, ...) *EvmTxStore_FindTransactionsConfirmedInBlockRange_Call
- func (_e *EvmTxStore_Expecter) FindTxAttempt(ctx interface{}, hash interface{}) *EvmTxStore_FindTxAttempt_Call
- func (_e *EvmTxStore_Expecter) FindTxAttemptConfirmedByTxIDs(ctx interface{}, ids interface{}) *EvmTxStore_FindTxAttemptConfirmedByTxIDs_Call
- func (_e *EvmTxStore_Expecter) FindTxAttemptsConfirmedMissingReceipt(ctx interface{}, chainID interface{}) *EvmTxStore_FindTxAttemptsConfirmedMissingReceipt_Call
- func (_e *EvmTxStore_Expecter) FindTxAttemptsRequiringReceiptFetch(ctx interface{}, chainID interface{}) *EvmTxStore_FindTxAttemptsRequiringReceiptFetch_Call
- func (_e *EvmTxStore_Expecter) FindTxAttemptsRequiringResend(ctx interface{}, olderThan interface{}, maxInFlightTransactions interface{}, ...) *EvmTxStore_FindTxAttemptsRequiringResend_Call
- func (_e *EvmTxStore_Expecter) FindTxByHash(ctx interface{}, hash interface{}) *EvmTxStore_FindTxByHash_Call
- func (_e *EvmTxStore_Expecter) FindTxWithAttempts(ctx interface{}, etxID interface{}) *EvmTxStore_FindTxWithAttempts_Call
- func (_e *EvmTxStore_Expecter) FindTxWithIdempotencyKey(ctx interface{}, idempotencyKey interface{}, chainID interface{}) *EvmTxStore_FindTxWithIdempotencyKey_Call
- func (_e *EvmTxStore_Expecter) FindTxWithSequence(ctx interface{}, fromAddress interface{}, seq interface{}) *EvmTxStore_FindTxWithSequence_Call
- func (_e *EvmTxStore_Expecter) FindTxesByMetaFieldAndStates(ctx interface{}, metaField interface{}, metaValue interface{}, ...) *EvmTxStore_FindTxesByMetaFieldAndStates_Call
- func (_e *EvmTxStore_Expecter) FindTxesPendingCallback(ctx interface{}, blockNum interface{}, chainID interface{}) *EvmTxStore_FindTxesPendingCallback_Call
- func (_e *EvmTxStore_Expecter) FindTxesWithAttemptsAndReceiptsByIdsAndState(ctx interface{}, ids interface{}, states interface{}, chainID interface{}) *EvmTxStore_FindTxesWithAttemptsAndReceiptsByIdsAndState_Call
- func (_e *EvmTxStore_Expecter) FindTxesWithMetaFieldByReceiptBlockNum(ctx interface{}, metaField interface{}, blockNum interface{}, ...) *EvmTxStore_FindTxesWithMetaFieldByReceiptBlockNum_Call
- func (_e *EvmTxStore_Expecter) FindTxesWithMetaFieldByStates(ctx interface{}, metaField interface{}, states interface{}, ...) *EvmTxStore_FindTxesWithMetaFieldByStates_Call
- func (_e *EvmTxStore_Expecter) FindTxsByStateAndFromAddresses(ctx interface{}, addresses interface{}, state interface{}, chainID interface{}) *EvmTxStore_FindTxsByStateAndFromAddresses_Call
- func (_e *EvmTxStore_Expecter) FindTxsRequiringGasBump(ctx interface{}, address interface{}, blockNum interface{}, ...) *EvmTxStore_FindTxsRequiringGasBump_Call
- func (_e *EvmTxStore_Expecter) FindTxsRequiringResubmissionDueToInsufficientFunds(ctx interface{}, address interface{}, chainID interface{}) *EvmTxStore_FindTxsRequiringResubmissionDueToInsufficientFunds_Call
- func (_e *EvmTxStore_Expecter) GetAbandonedTransactionsByBatch(ctx interface{}, chainID interface{}, enabledAddrs interface{}, ...) *EvmTxStore_GetAbandonedTransactionsByBatch_Call
- func (_e *EvmTxStore_Expecter) GetInProgressTxAttempts(ctx interface{}, address interface{}, chainID interface{}) *EvmTxStore_GetInProgressTxAttempts_Call
- func (_e *EvmTxStore_Expecter) GetTxByID(ctx interface{}, id interface{}) *EvmTxStore_GetTxByID_Call
- func (_e *EvmTxStore_Expecter) GetTxInProgress(ctx interface{}, fromAddress interface{}) *EvmTxStore_GetTxInProgress_Call
- func (_e *EvmTxStore_Expecter) HasInProgressTransaction(ctx interface{}, account interface{}, chainID interface{}) *EvmTxStore_HasInProgressTransaction_Call
- func (_e *EvmTxStore_Expecter) IsTxFinalized(ctx interface{}, blockHeight interface{}, txID interface{}, ...) *EvmTxStore_IsTxFinalized_Call
- func (_e *EvmTxStore_Expecter) LoadTxAttempts(ctx interface{}, etx interface{}) *EvmTxStore_LoadTxAttempts_Call
- func (_e *EvmTxStore_Expecter) MarkAllConfirmedMissingReceipt(ctx interface{}, chainID interface{}) *EvmTxStore_MarkAllConfirmedMissingReceipt_Call
- func (_e *EvmTxStore_Expecter) MarkOldTxesMissingReceiptAsErrored(ctx interface{}, blockNum interface{}, finalityDepth interface{}, ...) *EvmTxStore_MarkOldTxesMissingReceiptAsErrored_Call
- func (_e *EvmTxStore_Expecter) PreloadTxes(ctx interface{}, attempts interface{}) *EvmTxStore_PreloadTxes_Call
- func (_e *EvmTxStore_Expecter) PruneUnstartedTxQueue(ctx interface{}, queueSize interface{}, subject interface{}) *EvmTxStore_PruneUnstartedTxQueue_Call
- func (_e *EvmTxStore_Expecter) ReapTxHistory(ctx interface{}, minBlockNumberToKeep interface{}, timeThreshold interface{}, ...) *EvmTxStore_ReapTxHistory_Call
- func (_e *EvmTxStore_Expecter) SaveConfirmedMissingReceiptAttempt(ctx interface{}, timeout interface{}, attempt interface{}, ...) *EvmTxStore_SaveConfirmedMissingReceiptAttempt_Call
- func (_e *EvmTxStore_Expecter) SaveFetchedReceipts(ctx interface{}, r interface{}, state interface{}, errorMsg interface{}, ...) *EvmTxStore_SaveFetchedReceipts_Call
- func (_e *EvmTxStore_Expecter) SaveInProgressAttempt(ctx interface{}, attempt interface{}) *EvmTxStore_SaveInProgressAttempt_Call
- func (_e *EvmTxStore_Expecter) SaveInsufficientFundsAttempt(ctx interface{}, timeout interface{}, attempt interface{}, ...) *EvmTxStore_SaveInsufficientFundsAttempt_Call
- func (_e *EvmTxStore_Expecter) SaveReplacementInProgressAttempt(ctx interface{}, oldAttempt interface{}, replacementAttempt interface{}) *EvmTxStore_SaveReplacementInProgressAttempt_Call
- func (_e *EvmTxStore_Expecter) SaveSentAttempt(ctx interface{}, timeout interface{}, attempt interface{}, ...) *EvmTxStore_SaveSentAttempt_Call
- func (_e *EvmTxStore_Expecter) SetBroadcastBeforeBlockNum(ctx interface{}, blockNum interface{}, chainID interface{}) *EvmTxStore_SetBroadcastBeforeBlockNum_Call
- func (_e *EvmTxStore_Expecter) Transactions(ctx interface{}, offset interface{}, limit interface{}) *EvmTxStore_Transactions_Call
- func (_e *EvmTxStore_Expecter) TransactionsWithAttempts(ctx interface{}, offset interface{}, limit interface{}) *EvmTxStore_TransactionsWithAttempts_Call
- func (_e *EvmTxStore_Expecter) TxAttempts(ctx interface{}, offset interface{}, limit interface{}) *EvmTxStore_TxAttempts_Call
- func (_e *EvmTxStore_Expecter) UpdateBroadcastAts(ctx interface{}, now interface{}, etxIDs interface{}) *EvmTxStore_UpdateBroadcastAts_Call
- func (_e *EvmTxStore_Expecter) UpdateTxAttemptInProgressToBroadcast(ctx interface{}, etx interface{}, attempt interface{}, ...) *EvmTxStore_UpdateTxAttemptInProgressToBroadcast_Call
- func (_e *EvmTxStore_Expecter) UpdateTxCallbackCompleted(ctx interface{}, pipelineTaskRunRid interface{}, chainId interface{}) *EvmTxStore_UpdateTxCallbackCompleted_Call
- func (_e *EvmTxStore_Expecter) UpdateTxFatalError(ctx interface{}, etx interface{}) *EvmTxStore_UpdateTxFatalError_Call
- func (_e *EvmTxStore_Expecter) UpdateTxForRebroadcast(ctx interface{}, etx interface{}, etxAttempt interface{}) *EvmTxStore_UpdateTxForRebroadcast_Call
- func (_e *EvmTxStore_Expecter) UpdateTxUnstartedToInProgress(ctx interface{}, etx interface{}, attempt interface{}) *EvmTxStore_UpdateTxUnstartedToInProgress_Call
- func (_e *EvmTxStore_Expecter) UpdateTxsUnconfirmed(ctx interface{}, ids interface{}) *EvmTxStore_UpdateTxsUnconfirmed_Call
- type EvmTxStore_FindEarliestUnconfirmedBroadcastTime_Call
- func (_c *EvmTxStore_FindEarliestUnconfirmedBroadcastTime_Call) Return(_a0 null.Time, _a1 error) *EvmTxStore_FindEarliestUnconfirmedBroadcastTime_Call
- func (_c *EvmTxStore_FindEarliestUnconfirmedBroadcastTime_Call) Run(run func(ctx context.Context, chainID *big.Int)) *EvmTxStore_FindEarliestUnconfirmedBroadcastTime_Call
- func (_c *EvmTxStore_FindEarliestUnconfirmedBroadcastTime_Call) RunAndReturn(run func(context.Context, *big.Int) (null.Time, error)) *EvmTxStore_FindEarliestUnconfirmedBroadcastTime_Call
- type EvmTxStore_FindEarliestUnconfirmedTxAttemptBlock_Call
- func (_c *EvmTxStore_FindEarliestUnconfirmedTxAttemptBlock_Call) Return(_a0 null.Int, _a1 error) *EvmTxStore_FindEarliestUnconfirmedTxAttemptBlock_Call
- func (_c *EvmTxStore_FindEarliestUnconfirmedTxAttemptBlock_Call) Run(run func(ctx context.Context, chainID *big.Int)) *EvmTxStore_FindEarliestUnconfirmedTxAttemptBlock_Call
- func (_c *EvmTxStore_FindEarliestUnconfirmedTxAttemptBlock_Call) RunAndReturn(run func(context.Context, *big.Int) (null.Int, error)) *EvmTxStore_FindEarliestUnconfirmedTxAttemptBlock_Call
- type EvmTxStore_FindLatestSequence_Call
- func (_c *EvmTxStore_FindLatestSequence_Call) Return(_a0 evmtypes.Nonce, _a1 error) *EvmTxStore_FindLatestSequence_Call
- func (_c *EvmTxStore_FindLatestSequence_Call) Run(run func(ctx context.Context, fromAddress common.Address, chainId *big.Int)) *EvmTxStore_FindLatestSequence_Call
- func (_c *EvmTxStore_FindLatestSequence_Call) RunAndReturn(run func(context.Context, common.Address, *big.Int) (evmtypes.Nonce, error)) *EvmTxStore_FindLatestSequence_Call
- type EvmTxStore_FindNextUnstartedTransactionFromAddress_Call
- func (_c *EvmTxStore_FindNextUnstartedTransactionFromAddress_Call) Return(...) *EvmTxStore_FindNextUnstartedTransactionFromAddress_Call
- func (_c *EvmTxStore_FindNextUnstartedTransactionFromAddress_Call) Run(run func(ctx context.Context, fromAddress common.Address, chainID *big.Int)) *EvmTxStore_FindNextUnstartedTransactionFromAddress_Call
- func (_c *EvmTxStore_FindNextUnstartedTransactionFromAddress_Call) RunAndReturn(run func(context.Context, common.Address, *big.Int) (...)) *EvmTxStore_FindNextUnstartedTransactionFromAddress_Call
- type EvmTxStore_FindTransactionsConfirmedInBlockRange_Call
- func (_c *EvmTxStore_FindTransactionsConfirmedInBlockRange_Call) Return(...) *EvmTxStore_FindTransactionsConfirmedInBlockRange_Call
- func (_c *EvmTxStore_FindTransactionsConfirmedInBlockRange_Call) Run(...) *EvmTxStore_FindTransactionsConfirmedInBlockRange_Call
- func (_c *EvmTxStore_FindTransactionsConfirmedInBlockRange_Call) RunAndReturn(run func(context.Context, int64, int64, *big.Int) (...)) *EvmTxStore_FindTransactionsConfirmedInBlockRange_Call
- type EvmTxStore_FindTxAttemptConfirmedByTxIDs_Call
- func (_c *EvmTxStore_FindTxAttemptConfirmedByTxIDs_Call) Return(...) *EvmTxStore_FindTxAttemptConfirmedByTxIDs_Call
- func (_c *EvmTxStore_FindTxAttemptConfirmedByTxIDs_Call) Run(run func(ctx context.Context, ids []int64)) *EvmTxStore_FindTxAttemptConfirmedByTxIDs_Call
- func (_c *EvmTxStore_FindTxAttemptConfirmedByTxIDs_Call) RunAndReturn(run func(context.Context, []int64) (...)) *EvmTxStore_FindTxAttemptConfirmedByTxIDs_Call
- type EvmTxStore_FindTxAttempt_Call
- func (_c *EvmTxStore_FindTxAttempt_Call) Return(...) *EvmTxStore_FindTxAttempt_Call
- func (_c *EvmTxStore_FindTxAttempt_Call) Run(run func(ctx context.Context, hash common.Hash)) *EvmTxStore_FindTxAttempt_Call
- func (_c *EvmTxStore_FindTxAttempt_Call) RunAndReturn(run func(context.Context, common.Hash) (...)) *EvmTxStore_FindTxAttempt_Call
- type EvmTxStore_FindTxAttemptsConfirmedMissingReceipt_Call
- func (_c *EvmTxStore_FindTxAttemptsConfirmedMissingReceipt_Call) Return(...) *EvmTxStore_FindTxAttemptsConfirmedMissingReceipt_Call
- func (_c *EvmTxStore_FindTxAttemptsConfirmedMissingReceipt_Call) Run(run func(ctx context.Context, chainID *big.Int)) *EvmTxStore_FindTxAttemptsConfirmedMissingReceipt_Call
- func (_c *EvmTxStore_FindTxAttemptsConfirmedMissingReceipt_Call) RunAndReturn(run func(context.Context, *big.Int) (...)) *EvmTxStore_FindTxAttemptsConfirmedMissingReceipt_Call
- type EvmTxStore_FindTxAttemptsRequiringReceiptFetch_Call
- func (_c *EvmTxStore_FindTxAttemptsRequiringReceiptFetch_Call) Return(...) *EvmTxStore_FindTxAttemptsRequiringReceiptFetch_Call
- func (_c *EvmTxStore_FindTxAttemptsRequiringReceiptFetch_Call) Run(run func(ctx context.Context, chainID *big.Int)) *EvmTxStore_FindTxAttemptsRequiringReceiptFetch_Call
- func (_c *EvmTxStore_FindTxAttemptsRequiringReceiptFetch_Call) RunAndReturn(run func(context.Context, *big.Int) (...)) *EvmTxStore_FindTxAttemptsRequiringReceiptFetch_Call
- type EvmTxStore_FindTxAttemptsRequiringResend_Call
- func (_c *EvmTxStore_FindTxAttemptsRequiringResend_Call) Return(...) *EvmTxStore_FindTxAttemptsRequiringResend_Call
- func (_c *EvmTxStore_FindTxAttemptsRequiringResend_Call) Run(...) *EvmTxStore_FindTxAttemptsRequiringResend_Call
- func (_c *EvmTxStore_FindTxAttemptsRequiringResend_Call) RunAndReturn(run func(context.Context, time.Time, uint32, *big.Int, common.Address) (...)) *EvmTxStore_FindTxAttemptsRequiringResend_Call
- type EvmTxStore_FindTxByHash_Call
- func (_c *EvmTxStore_FindTxByHash_Call) Return(...) *EvmTxStore_FindTxByHash_Call
- func (_c *EvmTxStore_FindTxByHash_Call) Run(run func(ctx context.Context, hash common.Hash)) *EvmTxStore_FindTxByHash_Call
- func (_c *EvmTxStore_FindTxByHash_Call) RunAndReturn(run func(context.Context, common.Hash) (...)) *EvmTxStore_FindTxByHash_Call
- type EvmTxStore_FindTxWithAttempts_Call
- func (_c *EvmTxStore_FindTxWithAttempts_Call) Return(...) *EvmTxStore_FindTxWithAttempts_Call
- func (_c *EvmTxStore_FindTxWithAttempts_Call) Run(run func(ctx context.Context, etxID int64)) *EvmTxStore_FindTxWithAttempts_Call
- func (_c *EvmTxStore_FindTxWithAttempts_Call) RunAndReturn(run func(context.Context, int64) (...)) *EvmTxStore_FindTxWithAttempts_Call
- type EvmTxStore_FindTxWithIdempotencyKey_Call
- func (_c *EvmTxStore_FindTxWithIdempotencyKey_Call) Return(...) *EvmTxStore_FindTxWithIdempotencyKey_Call
- func (_c *EvmTxStore_FindTxWithIdempotencyKey_Call) Run(run func(ctx context.Context, idempotencyKey string, chainID *big.Int)) *EvmTxStore_FindTxWithIdempotencyKey_Call
- func (_c *EvmTxStore_FindTxWithIdempotencyKey_Call) RunAndReturn(run func(context.Context, string, *big.Int) (...)) *EvmTxStore_FindTxWithIdempotencyKey_Call
- type EvmTxStore_FindTxWithSequence_Call
- func (_c *EvmTxStore_FindTxWithSequence_Call) Return(...) *EvmTxStore_FindTxWithSequence_Call
- func (_c *EvmTxStore_FindTxWithSequence_Call) Run(run func(ctx context.Context, fromAddress common.Address, seq evmtypes.Nonce)) *EvmTxStore_FindTxWithSequence_Call
- func (_c *EvmTxStore_FindTxWithSequence_Call) RunAndReturn(run func(context.Context, common.Address, evmtypes.Nonce) (...)) *EvmTxStore_FindTxWithSequence_Call
- type EvmTxStore_FindTxesByMetaFieldAndStates_Call
- func (_c *EvmTxStore_FindTxesByMetaFieldAndStates_Call) Return(...) *EvmTxStore_FindTxesByMetaFieldAndStates_Call
- func (_c *EvmTxStore_FindTxesByMetaFieldAndStates_Call) Run(run func(ctx context.Context, metaField string, metaValue string, ...)) *EvmTxStore_FindTxesByMetaFieldAndStates_Call
- func (_c *EvmTxStore_FindTxesByMetaFieldAndStates_Call) RunAndReturn(run func(context.Context, string, string, []types.TxState, *big.Int) (...)) *EvmTxStore_FindTxesByMetaFieldAndStates_Call
- type EvmTxStore_FindTxesPendingCallback_Call
- func (_c *EvmTxStore_FindTxesPendingCallback_Call) Return(receiptsPlus []types.ReceiptPlus[*evmtypes.Receipt], err error) *EvmTxStore_FindTxesPendingCallback_Call
- func (_c *EvmTxStore_FindTxesPendingCallback_Call) Run(run func(ctx context.Context, blockNum int64, chainID *big.Int)) *EvmTxStore_FindTxesPendingCallback_Call
- func (_c *EvmTxStore_FindTxesPendingCallback_Call) RunAndReturn(...) *EvmTxStore_FindTxesPendingCallback_Call
- type EvmTxStore_FindTxesWithAttemptsAndReceiptsByIdsAndState_Call
- func (_c *EvmTxStore_FindTxesWithAttemptsAndReceiptsByIdsAndState_Call) Return(...) *EvmTxStore_FindTxesWithAttemptsAndReceiptsByIdsAndState_Call
- func (_c *EvmTxStore_FindTxesWithAttemptsAndReceiptsByIdsAndState_Call) Run(...) *EvmTxStore_FindTxesWithAttemptsAndReceiptsByIdsAndState_Call
- func (_c *EvmTxStore_FindTxesWithAttemptsAndReceiptsByIdsAndState_Call) RunAndReturn(run func(context.Context, []int64, []types.TxState, *big.Int) (...)) *EvmTxStore_FindTxesWithAttemptsAndReceiptsByIdsAndState_Call
- type EvmTxStore_FindTxesWithMetaFieldByReceiptBlockNum_Call
- func (_c *EvmTxStore_FindTxesWithMetaFieldByReceiptBlockNum_Call) Return(...) *EvmTxStore_FindTxesWithMetaFieldByReceiptBlockNum_Call
- func (_c *EvmTxStore_FindTxesWithMetaFieldByReceiptBlockNum_Call) Run(...) *EvmTxStore_FindTxesWithMetaFieldByReceiptBlockNum_Call
- func (_c *EvmTxStore_FindTxesWithMetaFieldByReceiptBlockNum_Call) RunAndReturn(run func(context.Context, string, int64, *big.Int) (...)) *EvmTxStore_FindTxesWithMetaFieldByReceiptBlockNum_Call
- type EvmTxStore_FindTxesWithMetaFieldByStates_Call
- func (_c *EvmTxStore_FindTxesWithMetaFieldByStates_Call) Return(...) *EvmTxStore_FindTxesWithMetaFieldByStates_Call
- func (_c *EvmTxStore_FindTxesWithMetaFieldByStates_Call) Run(run func(ctx context.Context, metaField string, states []types.TxState, ...)) *EvmTxStore_FindTxesWithMetaFieldByStates_Call
- func (_c *EvmTxStore_FindTxesWithMetaFieldByStates_Call) RunAndReturn(run func(context.Context, string, []types.TxState, *big.Int) (...)) *EvmTxStore_FindTxesWithMetaFieldByStates_Call
- type EvmTxStore_FindTxsByStateAndFromAddresses_Call
- func (_c *EvmTxStore_FindTxsByStateAndFromAddresses_Call) Return(...) *EvmTxStore_FindTxsByStateAndFromAddresses_Call
- func (_c *EvmTxStore_FindTxsByStateAndFromAddresses_Call) Run(...) *EvmTxStore_FindTxsByStateAndFromAddresses_Call
- func (_c *EvmTxStore_FindTxsByStateAndFromAddresses_Call) RunAndReturn(run func(context.Context, []common.Address, types.TxState, *big.Int) (...)) *EvmTxStore_FindTxsByStateAndFromAddresses_Call
- type EvmTxStore_FindTxsRequiringGasBump_Call
- func (_c *EvmTxStore_FindTxsRequiringGasBump_Call) Return(...) *EvmTxStore_FindTxsRequiringGasBump_Call
- func (_c *EvmTxStore_FindTxsRequiringGasBump_Call) Run(run func(ctx context.Context, address common.Address, blockNum int64, ...)) *EvmTxStore_FindTxsRequiringGasBump_Call
- func (_c *EvmTxStore_FindTxsRequiringGasBump_Call) RunAndReturn(run func(context.Context, common.Address, int64, int64, int64, *big.Int) (...)) *EvmTxStore_FindTxsRequiringGasBump_Call
- type EvmTxStore_FindTxsRequiringResubmissionDueToInsufficientFunds_Call
- func (_c *EvmTxStore_FindTxsRequiringResubmissionDueToInsufficientFunds_Call) Return(...) *EvmTxStore_FindTxsRequiringResubmissionDueToInsufficientFunds_Call
- func (_c *EvmTxStore_FindTxsRequiringResubmissionDueToInsufficientFunds_Call) Run(run func(ctx context.Context, address common.Address, chainID *big.Int)) *EvmTxStore_FindTxsRequiringResubmissionDueToInsufficientFunds_Call
- func (_c *EvmTxStore_FindTxsRequiringResubmissionDueToInsufficientFunds_Call) RunAndReturn(run func(context.Context, common.Address, *big.Int) (...)) *EvmTxStore_FindTxsRequiringResubmissionDueToInsufficientFunds_Call
- type EvmTxStore_GetAbandonedTransactionsByBatch_Call
- func (_c *EvmTxStore_GetAbandonedTransactionsByBatch_Call) Return(...) *EvmTxStore_GetAbandonedTransactionsByBatch_Call
- func (_c *EvmTxStore_GetAbandonedTransactionsByBatch_Call) Run(...) *EvmTxStore_GetAbandonedTransactionsByBatch_Call
- func (_c *EvmTxStore_GetAbandonedTransactionsByBatch_Call) RunAndReturn(run func(context.Context, *big.Int, []common.Address, uint, uint) (...)) *EvmTxStore_GetAbandonedTransactionsByBatch_Call
- type EvmTxStore_GetInProgressTxAttempts_Call
- func (_c *EvmTxStore_GetInProgressTxAttempts_Call) Return(...) *EvmTxStore_GetInProgressTxAttempts_Call
- func (_c *EvmTxStore_GetInProgressTxAttempts_Call) Run(run func(ctx context.Context, address common.Address, chainID *big.Int)) *EvmTxStore_GetInProgressTxAttempts_Call
- func (_c *EvmTxStore_GetInProgressTxAttempts_Call) RunAndReturn(run func(context.Context, common.Address, *big.Int) (...)) *EvmTxStore_GetInProgressTxAttempts_Call
- type EvmTxStore_GetTxByID_Call
- func (_c *EvmTxStore_GetTxByID_Call) Return(...) *EvmTxStore_GetTxByID_Call
- func (_c *EvmTxStore_GetTxByID_Call) Run(run func(ctx context.Context, id int64)) *EvmTxStore_GetTxByID_Call
- func (_c *EvmTxStore_GetTxByID_Call) RunAndReturn(run func(context.Context, int64) (...)) *EvmTxStore_GetTxByID_Call
- type EvmTxStore_GetTxInProgress_Call
- func (_c *EvmTxStore_GetTxInProgress_Call) Return(...) *EvmTxStore_GetTxInProgress_Call
- func (_c *EvmTxStore_GetTxInProgress_Call) Run(run func(ctx context.Context, fromAddress common.Address)) *EvmTxStore_GetTxInProgress_Call
- func (_c *EvmTxStore_GetTxInProgress_Call) RunAndReturn(run func(context.Context, common.Address) (...)) *EvmTxStore_GetTxInProgress_Call
- type EvmTxStore_HasInProgressTransaction_Call
- func (_c *EvmTxStore_HasInProgressTransaction_Call) Return(exists bool, err error) *EvmTxStore_HasInProgressTransaction_Call
- func (_c *EvmTxStore_HasInProgressTransaction_Call) Run(run func(ctx context.Context, account common.Address, chainID *big.Int)) *EvmTxStore_HasInProgressTransaction_Call
- func (_c *EvmTxStore_HasInProgressTransaction_Call) RunAndReturn(run func(context.Context, common.Address, *big.Int) (bool, error)) *EvmTxStore_HasInProgressTransaction_Call
- type EvmTxStore_IsTxFinalized_Call
- func (_c *EvmTxStore_IsTxFinalized_Call) Return(finalized bool, err error) *EvmTxStore_IsTxFinalized_Call
- func (_c *EvmTxStore_IsTxFinalized_Call) Run(run func(ctx context.Context, blockHeight int64, txID int64, chainID *big.Int)) *EvmTxStore_IsTxFinalized_Call
- func (_c *EvmTxStore_IsTxFinalized_Call) RunAndReturn(run func(context.Context, int64, int64, *big.Int) (bool, error)) *EvmTxStore_IsTxFinalized_Call
- type EvmTxStore_LoadTxAttempts_Call
- func (_c *EvmTxStore_LoadTxAttempts_Call) Return(_a0 error) *EvmTxStore_LoadTxAttempts_Call
- func (_c *EvmTxStore_LoadTxAttempts_Call) Run(run func(ctx context.Context, ...)) *EvmTxStore_LoadTxAttempts_Call
- func (_c *EvmTxStore_LoadTxAttempts_Call) RunAndReturn(run func(context.Context, ...) error) *EvmTxStore_LoadTxAttempts_Call
- type EvmTxStore_MarkAllConfirmedMissingReceipt_Call
- func (_c *EvmTxStore_MarkAllConfirmedMissingReceipt_Call) Return(err error) *EvmTxStore_MarkAllConfirmedMissingReceipt_Call
- func (_c *EvmTxStore_MarkAllConfirmedMissingReceipt_Call) Run(run func(ctx context.Context, chainID *big.Int)) *EvmTxStore_MarkAllConfirmedMissingReceipt_Call
- func (_c *EvmTxStore_MarkAllConfirmedMissingReceipt_Call) RunAndReturn(run func(context.Context, *big.Int) error) *EvmTxStore_MarkAllConfirmedMissingReceipt_Call
- type EvmTxStore_MarkOldTxesMissingReceiptAsErrored_Call
- func (_c *EvmTxStore_MarkOldTxesMissingReceiptAsErrored_Call) Return(_a0 error) *EvmTxStore_MarkOldTxesMissingReceiptAsErrored_Call
- func (_c *EvmTxStore_MarkOldTxesMissingReceiptAsErrored_Call) Run(...) *EvmTxStore_MarkOldTxesMissingReceiptAsErrored_Call
- func (_c *EvmTxStore_MarkOldTxesMissingReceiptAsErrored_Call) RunAndReturn(run func(context.Context, int64, uint32, *big.Int) error) *EvmTxStore_MarkOldTxesMissingReceiptAsErrored_Call
- type EvmTxStore_PreloadTxes_Call
- func (_c *EvmTxStore_PreloadTxes_Call) Return(_a0 error) *EvmTxStore_PreloadTxes_Call
- func (_c *EvmTxStore_PreloadTxes_Call) Run(run func(ctx context.Context, ...)) *EvmTxStore_PreloadTxes_Call
- func (_c *EvmTxStore_PreloadTxes_Call) RunAndReturn(run func(context.Context, ...) error) *EvmTxStore_PreloadTxes_Call
- type EvmTxStore_PruneUnstartedTxQueue_Call
- func (_c *EvmTxStore_PruneUnstartedTxQueue_Call) Return(ids []int64, err error) *EvmTxStore_PruneUnstartedTxQueue_Call
- func (_c *EvmTxStore_PruneUnstartedTxQueue_Call) Run(run func(ctx context.Context, queueSize uint32, subject uuid.UUID)) *EvmTxStore_PruneUnstartedTxQueue_Call
- func (_c *EvmTxStore_PruneUnstartedTxQueue_Call) RunAndReturn(run func(context.Context, uint32, uuid.UUID) ([]int64, error)) *EvmTxStore_PruneUnstartedTxQueue_Call
- type EvmTxStore_ReapTxHistory_Call
- func (_c *EvmTxStore_ReapTxHistory_Call) Return(_a0 error) *EvmTxStore_ReapTxHistory_Call
- func (_c *EvmTxStore_ReapTxHistory_Call) Run(...) *EvmTxStore_ReapTxHistory_Call
- func (_c *EvmTxStore_ReapTxHistory_Call) RunAndReturn(run func(context.Context, int64, time.Time, *big.Int) error) *EvmTxStore_ReapTxHistory_Call
- type EvmTxStore_SaveConfirmedMissingReceiptAttempt_Call
- func (_c *EvmTxStore_SaveConfirmedMissingReceiptAttempt_Call) Return(_a0 error) *EvmTxStore_SaveConfirmedMissingReceiptAttempt_Call
- func (_c *EvmTxStore_SaveConfirmedMissingReceiptAttempt_Call) Run(run func(ctx context.Context, timeout time.Duration, ...)) *EvmTxStore_SaveConfirmedMissingReceiptAttempt_Call
- func (_c *EvmTxStore_SaveConfirmedMissingReceiptAttempt_Call) RunAndReturn(run func(context.Context, time.Duration, ...) error) *EvmTxStore_SaveConfirmedMissingReceiptAttempt_Call
- type EvmTxStore_SaveFetchedReceipts_Call
- func (_c *EvmTxStore_SaveFetchedReceipts_Call) Return(_a0 error) *EvmTxStore_SaveFetchedReceipts_Call
- func (_c *EvmTxStore_SaveFetchedReceipts_Call) Run(run func(ctx context.Context, r []*evmtypes.Receipt, state types.TxState, ...)) *EvmTxStore_SaveFetchedReceipts_Call
- func (_c *EvmTxStore_SaveFetchedReceipts_Call) RunAndReturn(...) *EvmTxStore_SaveFetchedReceipts_Call
- type EvmTxStore_SaveInProgressAttempt_Call
- func (_c *EvmTxStore_SaveInProgressAttempt_Call) Return(_a0 error) *EvmTxStore_SaveInProgressAttempt_Call
- func (_c *EvmTxStore_SaveInProgressAttempt_Call) Run(run func(ctx context.Context, ...)) *EvmTxStore_SaveInProgressAttempt_Call
- func (_c *EvmTxStore_SaveInProgressAttempt_Call) RunAndReturn(run func(context.Context, ...) error) *EvmTxStore_SaveInProgressAttempt_Call
- type EvmTxStore_SaveInsufficientFundsAttempt_Call
- func (_c *EvmTxStore_SaveInsufficientFundsAttempt_Call) Return(_a0 error) *EvmTxStore_SaveInsufficientFundsAttempt_Call
- func (_c *EvmTxStore_SaveInsufficientFundsAttempt_Call) Run(run func(ctx context.Context, timeout time.Duration, ...)) *EvmTxStore_SaveInsufficientFundsAttempt_Call
- func (_c *EvmTxStore_SaveInsufficientFundsAttempt_Call) RunAndReturn(run func(context.Context, time.Duration, ...) error) *EvmTxStore_SaveInsufficientFundsAttempt_Call
- type EvmTxStore_SaveReplacementInProgressAttempt_Call
- func (_c *EvmTxStore_SaveReplacementInProgressAttempt_Call) Return(_a0 error) *EvmTxStore_SaveReplacementInProgressAttempt_Call
- func (_c *EvmTxStore_SaveReplacementInProgressAttempt_Call) Run(run func(ctx context.Context, ...)) *EvmTxStore_SaveReplacementInProgressAttempt_Call
- func (_c *EvmTxStore_SaveReplacementInProgressAttempt_Call) RunAndReturn(run func(context.Context, ...) error) *EvmTxStore_SaveReplacementInProgressAttempt_Call
- type EvmTxStore_SaveSentAttempt_Call
- func (_c *EvmTxStore_SaveSentAttempt_Call) Return(_a0 error) *EvmTxStore_SaveSentAttempt_Call
- func (_c *EvmTxStore_SaveSentAttempt_Call) Run(run func(ctx context.Context, timeout time.Duration, ...)) *EvmTxStore_SaveSentAttempt_Call
- func (_c *EvmTxStore_SaveSentAttempt_Call) RunAndReturn(run func(context.Context, time.Duration, ...) error) *EvmTxStore_SaveSentAttempt_Call
- type EvmTxStore_SetBroadcastBeforeBlockNum_Call
- func (_c *EvmTxStore_SetBroadcastBeforeBlockNum_Call) Return(_a0 error) *EvmTxStore_SetBroadcastBeforeBlockNum_Call
- func (_c *EvmTxStore_SetBroadcastBeforeBlockNum_Call) Run(run func(ctx context.Context, blockNum int64, chainID *big.Int)) *EvmTxStore_SetBroadcastBeforeBlockNum_Call
- func (_c *EvmTxStore_SetBroadcastBeforeBlockNum_Call) RunAndReturn(run func(context.Context, int64, *big.Int) error) *EvmTxStore_SetBroadcastBeforeBlockNum_Call
- type EvmTxStore_TransactionsWithAttempts_Call
- func (_c *EvmTxStore_TransactionsWithAttempts_Call) Return(...) *EvmTxStore_TransactionsWithAttempts_Call
- func (_c *EvmTxStore_TransactionsWithAttempts_Call) Run(run func(ctx context.Context, offset int, limit int)) *EvmTxStore_TransactionsWithAttempts_Call
- func (_c *EvmTxStore_TransactionsWithAttempts_Call) RunAndReturn(run func(context.Context, int, int) (...)) *EvmTxStore_TransactionsWithAttempts_Call
- type EvmTxStore_Transactions_Call
- func (_c *EvmTxStore_Transactions_Call) Return(...) *EvmTxStore_Transactions_Call
- func (_c *EvmTxStore_Transactions_Call) Run(run func(ctx context.Context, offset int, limit int)) *EvmTxStore_Transactions_Call
- func (_c *EvmTxStore_Transactions_Call) RunAndReturn(run func(context.Context, int, int) (...)) *EvmTxStore_Transactions_Call
- type EvmTxStore_TxAttempts_Call
- func (_c *EvmTxStore_TxAttempts_Call) Return(...) *EvmTxStore_TxAttempts_Call
- func (_c *EvmTxStore_TxAttempts_Call) Run(run func(ctx context.Context, offset int, limit int)) *EvmTxStore_TxAttempts_Call
- func (_c *EvmTxStore_TxAttempts_Call) RunAndReturn(run func(context.Context, int, int) (...)) *EvmTxStore_TxAttempts_Call
- type EvmTxStore_UpdateBroadcastAts_Call
- func (_c *EvmTxStore_UpdateBroadcastAts_Call) Return(_a0 error) *EvmTxStore_UpdateBroadcastAts_Call
- func (_c *EvmTxStore_UpdateBroadcastAts_Call) Run(run func(ctx context.Context, now time.Time, etxIDs []int64)) *EvmTxStore_UpdateBroadcastAts_Call
- func (_c *EvmTxStore_UpdateBroadcastAts_Call) RunAndReturn(run func(context.Context, time.Time, []int64) error) *EvmTxStore_UpdateBroadcastAts_Call
- type EvmTxStore_UpdateTxAttemptInProgressToBroadcast_Call
- func (_c *EvmTxStore_UpdateTxAttemptInProgressToBroadcast_Call) Return(_a0 error) *EvmTxStore_UpdateTxAttemptInProgressToBroadcast_Call
- func (_c *EvmTxStore_UpdateTxAttemptInProgressToBroadcast_Call) Run(run func(ctx context.Context, ...)) *EvmTxStore_UpdateTxAttemptInProgressToBroadcast_Call
- func (_c *EvmTxStore_UpdateTxAttemptInProgressToBroadcast_Call) RunAndReturn(run func(context.Context, ...) error) *EvmTxStore_UpdateTxAttemptInProgressToBroadcast_Call
- type EvmTxStore_UpdateTxCallbackCompleted_Call
- func (_c *EvmTxStore_UpdateTxCallbackCompleted_Call) Return(_a0 error) *EvmTxStore_UpdateTxCallbackCompleted_Call
- func (_c *EvmTxStore_UpdateTxCallbackCompleted_Call) Run(run func(ctx context.Context, pipelineTaskRunRid uuid.UUID, chainId *big.Int)) *EvmTxStore_UpdateTxCallbackCompleted_Call
- func (_c *EvmTxStore_UpdateTxCallbackCompleted_Call) RunAndReturn(run func(context.Context, uuid.UUID, *big.Int) error) *EvmTxStore_UpdateTxCallbackCompleted_Call
- type EvmTxStore_UpdateTxFatalError_Call
- func (_c *EvmTxStore_UpdateTxFatalError_Call) Return(_a0 error) *EvmTxStore_UpdateTxFatalError_Call
- func (_c *EvmTxStore_UpdateTxFatalError_Call) Run(run func(ctx context.Context, ...)) *EvmTxStore_UpdateTxFatalError_Call
- func (_c *EvmTxStore_UpdateTxFatalError_Call) RunAndReturn(run func(context.Context, ...) error) *EvmTxStore_UpdateTxFatalError_Call
- type EvmTxStore_UpdateTxForRebroadcast_Call
- func (_c *EvmTxStore_UpdateTxForRebroadcast_Call) Return(_a0 error) *EvmTxStore_UpdateTxForRebroadcast_Call
- func (_c *EvmTxStore_UpdateTxForRebroadcast_Call) Run(run func(ctx context.Context, ...)) *EvmTxStore_UpdateTxForRebroadcast_Call
- func (_c *EvmTxStore_UpdateTxForRebroadcast_Call) RunAndReturn(run func(context.Context, ...) error) *EvmTxStore_UpdateTxForRebroadcast_Call
- type EvmTxStore_UpdateTxUnstartedToInProgress_Call
- func (_c *EvmTxStore_UpdateTxUnstartedToInProgress_Call) Return(_a0 error) *EvmTxStore_UpdateTxUnstartedToInProgress_Call
- func (_c *EvmTxStore_UpdateTxUnstartedToInProgress_Call) Run(run func(ctx context.Context, ...)) *EvmTxStore_UpdateTxUnstartedToInProgress_Call
- func (_c *EvmTxStore_UpdateTxUnstartedToInProgress_Call) RunAndReturn(run func(context.Context, ...) error) *EvmTxStore_UpdateTxUnstartedToInProgress_Call
- type EvmTxStore_UpdateTxsUnconfirmed_Call
- func (_c *EvmTxStore_UpdateTxsUnconfirmed_Call) Return(_a0 error) *EvmTxStore_UpdateTxsUnconfirmed_Call
- func (_c *EvmTxStore_UpdateTxsUnconfirmed_Call) Run(run func(ctx context.Context, ids []int64)) *EvmTxStore_UpdateTxsUnconfirmed_Call
- func (_c *EvmTxStore_UpdateTxsUnconfirmed_Call) RunAndReturn(run func(context.Context, []int64) error) *EvmTxStore_UpdateTxsUnconfirmed_Call
- 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 ¶
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. The first argument is typically a *testing.T value.
func (*Config) EXPECT ¶ added in v2.15.0
func (_m *Config) EXPECT() *Config_Expecter
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 Config_ChainType_Call ¶ added in v2.15.0
Config_ChainType_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ChainType'
func (*Config_ChainType_Call) Return ¶ added in v2.15.0
func (_c *Config_ChainType_Call) Return(_a0 chaintype.ChainType) *Config_ChainType_Call
func (*Config_ChainType_Call) Run ¶ added in v2.15.0
func (_c *Config_ChainType_Call) Run(run func()) *Config_ChainType_Call
func (*Config_ChainType_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Config_ChainType_Call) RunAndReturn(run func() chaintype.ChainType) *Config_ChainType_Call
type Config_Expecter ¶ added in v2.15.0
type Config_Expecter struct {
// contains filtered or unexported fields
}
func (*Config_Expecter) ChainType ¶ added in v2.15.0
func (_e *Config_Expecter) ChainType() *Config_ChainType_Call
ChainType is a helper method to define mock.On call
func (*Config_Expecter) FinalityDepth ¶ added in v2.15.0
func (_e *Config_Expecter) FinalityDepth() *Config_FinalityDepth_Call
FinalityDepth is a helper method to define mock.On call
func (*Config_Expecter) FinalityTagEnabled ¶ added in v2.15.0
func (_e *Config_Expecter) FinalityTagEnabled() *Config_FinalityTagEnabled_Call
FinalityTagEnabled is a helper method to define mock.On call
func (*Config_Expecter) NonceAutoSync ¶ added in v2.15.0
func (_e *Config_Expecter) NonceAutoSync() *Config_NonceAutoSync_Call
NonceAutoSync is a helper method to define mock.On call
func (*Config_Expecter) RPCDefaultBatchSize ¶ added in v2.15.0
func (_e *Config_Expecter) RPCDefaultBatchSize() *Config_RPCDefaultBatchSize_Call
RPCDefaultBatchSize is a helper method to define mock.On call
type Config_FinalityDepth_Call ¶ added in v2.15.0
Config_FinalityDepth_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FinalityDepth'
func (*Config_FinalityDepth_Call) Return ¶ added in v2.15.0
func (_c *Config_FinalityDepth_Call) Return(_a0 uint32) *Config_FinalityDepth_Call
func (*Config_FinalityDepth_Call) Run ¶ added in v2.15.0
func (_c *Config_FinalityDepth_Call) Run(run func()) *Config_FinalityDepth_Call
func (*Config_FinalityDepth_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Config_FinalityDepth_Call) RunAndReturn(run func() uint32) *Config_FinalityDepth_Call
type Config_FinalityTagEnabled_Call ¶ added in v2.15.0
Config_FinalityTagEnabled_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FinalityTagEnabled'
func (*Config_FinalityTagEnabled_Call) Return ¶ added in v2.15.0
func (_c *Config_FinalityTagEnabled_Call) Return(_a0 bool) *Config_FinalityTagEnabled_Call
func (*Config_FinalityTagEnabled_Call) Run ¶ added in v2.15.0
func (_c *Config_FinalityTagEnabled_Call) Run(run func()) *Config_FinalityTagEnabled_Call
func (*Config_FinalityTagEnabled_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Config_FinalityTagEnabled_Call) RunAndReturn(run func() bool) *Config_FinalityTagEnabled_Call
type Config_NonceAutoSync_Call ¶ added in v2.15.0
Config_NonceAutoSync_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NonceAutoSync'
func (*Config_NonceAutoSync_Call) Return ¶ added in v2.15.0
func (_c *Config_NonceAutoSync_Call) Return(_a0 bool) *Config_NonceAutoSync_Call
func (*Config_NonceAutoSync_Call) Run ¶ added in v2.15.0
func (_c *Config_NonceAutoSync_Call) Run(run func()) *Config_NonceAutoSync_Call
func (*Config_NonceAutoSync_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Config_NonceAutoSync_Call) RunAndReturn(run func() bool) *Config_NonceAutoSync_Call
type Config_RPCDefaultBatchSize_Call ¶ added in v2.15.0
Config_RPCDefaultBatchSize_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RPCDefaultBatchSize'
func (*Config_RPCDefaultBatchSize_Call) Return ¶ added in v2.15.0
func (_c *Config_RPCDefaultBatchSize_Call) Return(_a0 uint32) *Config_RPCDefaultBatchSize_Call
func (*Config_RPCDefaultBatchSize_Call) Run ¶ added in v2.15.0
func (_c *Config_RPCDefaultBatchSize_Call) Run(run func()) *Config_RPCDefaultBatchSize_Call
func (*Config_RPCDefaultBatchSize_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Config_RPCDefaultBatchSize_Call) RunAndReturn(run func() uint32) *Config_RPCDefaultBatchSize_Call
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 interface { mock.TestingT Cleanup(func()) }) *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. The first argument is typically a *testing.T value.
func (*EvmTxStore) Abandon ¶ added in v2.3.0
Abandon provides a mock function with given fields: ctx, id, addr
func (*EvmTxStore) CheckTxQueueCapacity ¶ added in v2.3.0
func (_m *EvmTxStore) CheckTxQueueCapacity(ctx context.Context, fromAddress common.Address, maxQueuedTransactions uint64, chainID *big.Int) error
CheckTxQueueCapacity provides a mock function with given fields: ctx, fromAddress, maxQueuedTransactions, chainID
func (*EvmTxStore) Close ¶ added in v2.3.0
func (_m *EvmTxStore) Close()
Close provides a mock function with given fields:
func (*EvmTxStore) CountTransactionsByState ¶ added in v2.8.0
func (_m *EvmTxStore) CountTransactionsByState(ctx context.Context, state types.TxState, chainID *big.Int) (uint32, error)
CountTransactionsByState provides a mock function with given fields: ctx, state, chainID
func (*EvmTxStore) CountUnconfirmedTransactions ¶ added in v2.3.0
func (_m *EvmTxStore) CountUnconfirmedTransactions(ctx context.Context, fromAddress common.Address, chainID *big.Int) (uint32, error)
CountUnconfirmedTransactions provides a mock function with given fields: ctx, fromAddress, chainID
func (*EvmTxStore) CountUnstartedTransactions ¶ added in v2.3.0
func (_m *EvmTxStore) CountUnstartedTransactions(ctx context.Context, fromAddress common.Address, chainID *big.Int) (uint32, error)
CountUnstartedTransactions provides a mock function with given fields: ctx, fromAddress, chainID
func (*EvmTxStore) CreateTransaction ¶ added in v2.3.0
func (_m *EvmTxStore) CreateTransaction(ctx context.Context, txRequest types.TxRequest[common.Address, common.Hash], chainID *big.Int) (types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
CreateTransaction provides a mock function with given fields: ctx, txRequest, chainID
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) EXPECT ¶ added in v2.15.0
func (_m *EvmTxStore) EXPECT() *EvmTxStore_Expecter
func (*EvmTxStore) FindEarliestUnconfirmedBroadcastTime ¶ added in v2.8.0
func (_m *EvmTxStore) FindEarliestUnconfirmedBroadcastTime(ctx context.Context, chainID *big.Int) (null.Time, error)
FindEarliestUnconfirmedBroadcastTime provides a mock function with given fields: ctx, chainID
func (*EvmTxStore) FindEarliestUnconfirmedTxAttemptBlock ¶ added in v2.8.0
func (_m *EvmTxStore) FindEarliestUnconfirmedTxAttemptBlock(ctx context.Context, chainID *big.Int) (null.Int, error)
FindEarliestUnconfirmedTxAttemptBlock provides a mock function with given fields: ctx, chainID
func (*EvmTxStore) FindLatestSequence ¶ added in v2.7.0
func (_m *EvmTxStore) FindLatestSequence(ctx context.Context, fromAddress common.Address, chainId *big.Int) (evmtypes.Nonce, error)
FindLatestSequence provides a mock function with given fields: ctx, fromAddress, chainId
func (*EvmTxStore) FindNextUnstartedTransactionFromAddress ¶ added in v2.3.0
func (_m *EvmTxStore) FindNextUnstartedTransactionFromAddress(ctx context.Context, fromAddress common.Address, chainID *big.Int) (*types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
FindNextUnstartedTransactionFromAddress provides a mock function with given fields: ctx, fromAddress, chainID
func (*EvmTxStore) FindTransactionsConfirmedInBlockRange ¶ added in v2.3.0
func (_m *EvmTxStore) FindTransactionsConfirmedInBlockRange(ctx context.Context, 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: ctx, highBlockNumber, lowBlockNumber, chainID
func (*EvmTxStore) FindTxAttempt ¶ added in v2.3.0
func (_m *EvmTxStore) FindTxAttempt(ctx context.Context, 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: ctx, hash
func (*EvmTxStore) FindTxAttemptConfirmedByTxIDs ¶ added in v2.3.0
func (_m *EvmTxStore) FindTxAttemptConfirmedByTxIDs(ctx context.Context, 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: ctx, ids
func (*EvmTxStore) FindTxAttemptsConfirmedMissingReceipt ¶ added in v2.3.0
func (_m *EvmTxStore) FindTxAttemptsConfirmedMissingReceipt(ctx context.Context, 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: ctx, chainID
func (*EvmTxStore) FindTxAttemptsRequiringReceiptFetch ¶ added in v2.3.0
func (_m *EvmTxStore) FindTxAttemptsRequiringReceiptFetch(ctx context.Context, 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: ctx, chainID
func (*EvmTxStore) FindTxAttemptsRequiringResend ¶ added in v2.3.0
func (_m *EvmTxStore) FindTxAttemptsRequiringResend(ctx context.Context, 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: ctx, olderThan, maxInFlightTransactions, chainID, address
func (*EvmTxStore) FindTxByHash ¶ added in v2.3.0
func (_m *EvmTxStore) FindTxByHash(ctx context.Context, 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: ctx, hash
func (*EvmTxStore) FindTxWithAttempts ¶ added in v2.6.0
func (_m *EvmTxStore) FindTxWithAttempts(ctx context.Context, etxID int64) (types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
FindTxWithAttempts provides a mock function with given fields: ctx, etxID
func (*EvmTxStore) FindTxWithIdempotencyKey ¶ added in v2.6.0
func (_m *EvmTxStore) FindTxWithIdempotencyKey(ctx context.Context, idempotencyKey string, chainID *big.Int) (*types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
FindTxWithIdempotencyKey provides a mock function with given fields: ctx, idempotencyKey, chainID
func (*EvmTxStore) FindTxWithSequence ¶ added in v2.3.0
func (_m *EvmTxStore) FindTxWithSequence(ctx context.Context, 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: ctx, fromAddress, seq
func (*EvmTxStore) FindTxesByMetaFieldAndStates ¶ added in v2.8.0
func (_m *EvmTxStore) FindTxesByMetaFieldAndStates(ctx context.Context, metaField string, metaValue string, states []types.TxState, chainID *big.Int) ([]*types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
FindTxesByMetaFieldAndStates provides a mock function with given fields: ctx, metaField, metaValue, states, chainID
func (*EvmTxStore) FindTxesPendingCallback ¶ added in v2.8.0
func (_m *EvmTxStore) FindTxesPendingCallback(ctx context.Context, blockNum int64, chainID *big.Int) ([]types.ReceiptPlus[*evmtypes.Receipt], error)
FindTxesPendingCallback provides a mock function with given fields: ctx, blockNum, chainID
func (*EvmTxStore) FindTxesWithAttemptsAndReceiptsByIdsAndState ¶ added in v2.8.0
func (_m *EvmTxStore) FindTxesWithAttemptsAndReceiptsByIdsAndState(ctx context.Context, ids []int64, states []types.TxState, chainID *big.Int) ([]*types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
FindTxesWithAttemptsAndReceiptsByIdsAndState provides a mock function with given fields: ctx, ids, states, chainID
func (*EvmTxStore) FindTxesWithMetaFieldByReceiptBlockNum ¶ added in v2.8.0
func (_m *EvmTxStore) FindTxesWithMetaFieldByReceiptBlockNum(ctx context.Context, metaField string, blockNum int64, chainID *big.Int) ([]*types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
FindTxesWithMetaFieldByReceiptBlockNum provides a mock function with given fields: ctx, metaField, blockNum, chainID
func (*EvmTxStore) FindTxesWithMetaFieldByStates ¶ added in v2.8.0
func (_m *EvmTxStore) FindTxesWithMetaFieldByStates(ctx context.Context, metaField string, states []types.TxState, chainID *big.Int) ([]*types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
FindTxesWithMetaFieldByStates provides a mock function with given fields: ctx, metaField, states, chainID
func (*EvmTxStore) FindTxsByStateAndFromAddresses ¶ added in v2.13.0
func (_m *EvmTxStore) FindTxsByStateAndFromAddresses(ctx context.Context, addresses []common.Address, state types.TxState, chainID *big.Int) ([]*types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
FindTxsByStateAndFromAddresses provides a mock function with given fields: ctx, addresses, state, chainID
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(ctx context.Context, address common.Address, chainID *big.Int) ([]*types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
FindTxsRequiringResubmissionDueToInsufficientFunds provides a mock function with given fields: ctx, address, chainID
func (*EvmTxStore) GetAbandonedTransactionsByBatch ¶ added in v2.12.0
func (_m *EvmTxStore) GetAbandonedTransactionsByBatch(ctx context.Context, chainID *big.Int, enabledAddrs []common.Address, offset uint, limit uint) ([]*types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
GetAbandonedTransactionsByBatch provides a mock function with given fields: ctx, chainID, enabledAddrs, offset, limit
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) GetTxByID ¶ added in v2.8.0
func (_m *EvmTxStore) GetTxByID(ctx context.Context, id int64) (*types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
GetTxByID provides a mock function with given fields: ctx, id
func (*EvmTxStore) GetTxInProgress ¶ added in v2.3.0
func (_m *EvmTxStore) GetTxInProgress(ctx context.Context, fromAddress common.Address) (*types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)
GetTxInProgress provides a mock function with given fields: ctx, fromAddress
func (*EvmTxStore) HasInProgressTransaction ¶ added in v2.3.0
func (_m *EvmTxStore) HasInProgressTransaction(ctx context.Context, account common.Address, chainID *big.Int) (bool, error)
HasInProgressTransaction provides a mock function with given fields: ctx, account, chainID
func (*EvmTxStore) IsTxFinalized ¶ added in v2.8.0
func (_m *EvmTxStore) IsTxFinalized(ctx context.Context, blockHeight int64, txID int64, chainID *big.Int) (bool, error)
IsTxFinalized provides a mock function with given fields: ctx, blockHeight, txID, chainID
func (*EvmTxStore) LoadTxAttempts ¶ added in v2.3.0
func (_m *EvmTxStore) LoadTxAttempts(ctx context.Context, etx *types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee]) error
LoadTxAttempts provides a mock function with given fields: ctx, etx
func (*EvmTxStore) MarkAllConfirmedMissingReceipt ¶ added in v2.3.0
MarkAllConfirmedMissingReceipt provides a mock function with given fields: ctx, chainID
func (*EvmTxStore) MarkOldTxesMissingReceiptAsErrored ¶ added in v2.3.0
func (_m *EvmTxStore) MarkOldTxesMissingReceiptAsErrored(ctx context.Context, blockNum int64, finalityDepth uint32, chainID *big.Int) error
MarkOldTxesMissingReceiptAsErrored provides a mock function with given fields: ctx, blockNum, finalityDepth, chainID
func (*EvmTxStore) PreloadTxes ¶ added in v2.3.0
func (_m *EvmTxStore) PreloadTxes(ctx context.Context, attempts []types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee]) error
PreloadTxes provides a mock function with given fields: ctx, attempts
func (*EvmTxStore) PruneUnstartedTxQueue ¶ added in v2.3.0
func (_m *EvmTxStore) PruneUnstartedTxQueue(ctx context.Context, queueSize uint32, subject uuid.UUID) ([]int64, error)
PruneUnstartedTxQueue provides a mock function with given fields: ctx, queueSize, subject
func (*EvmTxStore) ReapTxHistory ¶ added in v2.3.0
func (_m *EvmTxStore) ReapTxHistory(ctx context.Context, minBlockNumberToKeep int64, timeThreshold time.Time, chainID *big.Int) error
ReapTxHistory provides a mock function with given fields: ctx, 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
func (_m *EvmTxStore) SaveFetchedReceipts(ctx context.Context, r []*evmtypes.Receipt, state types.TxState, errorMsg *string, chainID *big.Int) error
SaveFetchedReceipts provides a mock function with given fields: ctx, r, state, errorMsg, chainID
func (*EvmTxStore) SaveInProgressAttempt ¶ added in v2.3.0
func (_m *EvmTxStore) SaveInProgressAttempt(ctx context.Context, attempt *types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee]) error
SaveInProgressAttempt provides a mock function with given fields: ctx, attempt
func (*EvmTxStore) SaveInsufficientFundsAttempt ¶ added in v2.3.0
func (_m *EvmTxStore) SaveInsufficientFundsAttempt(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
SaveInsufficientFundsAttempt provides a mock function with given fields: ctx, timeout, attempt, broadcastAt
func (*EvmTxStore) SaveReplacementInProgressAttempt ¶ added in v2.3.0
func (_m *EvmTxStore) SaveReplacementInProgressAttempt(ctx context.Context, 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]) error
SaveReplacementInProgressAttempt provides a mock function with given fields: ctx, oldAttempt, replacementAttempt
func (*EvmTxStore) SaveSentAttempt ¶ added in v2.3.0
func (_m *EvmTxStore) SaveSentAttempt(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
SaveSentAttempt provides a mock function with given fields: ctx, timeout, attempt, broadcastAt
func (*EvmTxStore) SetBroadcastBeforeBlockNum ¶ added in v2.3.0
func (_m *EvmTxStore) SetBroadcastBeforeBlockNum(ctx context.Context, blockNum int64, chainID *big.Int) error
SetBroadcastBeforeBlockNum provides a mock function with given fields: ctx, blockNum, chainID
func (*EvmTxStore) Transactions ¶ added in v2.3.0
func (_m *EvmTxStore) Transactions(ctx context.Context, 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: ctx, offset, limit
func (*EvmTxStore) TransactionsWithAttempts ¶ added in v2.3.0
func (_m *EvmTxStore) TransactionsWithAttempts(ctx context.Context, 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: ctx, offset, limit
func (*EvmTxStore) TxAttempts ¶ added in v2.3.0
func (_m *EvmTxStore) TxAttempts(ctx context.Context, 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: ctx, offset, limit
func (*EvmTxStore) UpdateBroadcastAts ¶ added in v2.3.0
UpdateBroadcastAts provides a mock function with given fields: ctx, now, etxIDs
func (*EvmTxStore) UpdateTxAttemptInProgressToBroadcast ¶ added in v2.3.0
func (_m *EvmTxStore) UpdateTxAttemptInProgressToBroadcast(ctx context.Context, 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) error
UpdateTxAttemptInProgressToBroadcast provides a mock function with given fields: ctx, etx, attempt, NewAttemptState
func (*EvmTxStore) UpdateTxCallbackCompleted ¶ added in v2.8.0
func (_m *EvmTxStore) UpdateTxCallbackCompleted(ctx context.Context, pipelineTaskRunRid uuid.UUID, chainId *big.Int) error
UpdateTxCallbackCompleted provides a mock function with given fields: ctx, pipelineTaskRunRid, chainId
func (*EvmTxStore) UpdateTxFatalError ¶ added in v2.3.0
func (_m *EvmTxStore) UpdateTxFatalError(ctx context.Context, etx *types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee]) error
UpdateTxFatalError provides a mock function with given fields: ctx, etx
func (*EvmTxStore) UpdateTxForRebroadcast ¶ added in v2.3.0
func (_m *EvmTxStore) UpdateTxForRebroadcast(ctx context.Context, 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: ctx, etx, etxAttempt
func (*EvmTxStore) UpdateTxUnstartedToInProgress ¶ added in v2.3.0
func (_m *EvmTxStore) UpdateTxUnstartedToInProgress(ctx context.Context, 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]) error
UpdateTxUnstartedToInProgress provides a mock function with given fields: ctx, etx, attempt
func (*EvmTxStore) UpdateTxsUnconfirmed ¶ added in v2.3.0
func (_m *EvmTxStore) UpdateTxsUnconfirmed(ctx context.Context, ids []int64) error
UpdateTxsUnconfirmed provides a mock function with given fields: ctx, ids
type EvmTxStore_Abandon_Call ¶ added in v2.15.0
EvmTxStore_Abandon_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Abandon'
func (*EvmTxStore_Abandon_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_Abandon_Call) Return(_a0 error) *EvmTxStore_Abandon_Call
func (*EvmTxStore_Abandon_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_Abandon_Call) Run(run func(ctx context.Context, id *big.Int, addr common.Address)) *EvmTxStore_Abandon_Call
func (*EvmTxStore_Abandon_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_Abandon_Call) RunAndReturn(run func(context.Context, *big.Int, common.Address) error) *EvmTxStore_Abandon_Call
type EvmTxStore_CheckTxQueueCapacity_Call ¶ added in v2.15.0
EvmTxStore_CheckTxQueueCapacity_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CheckTxQueueCapacity'
func (*EvmTxStore_CheckTxQueueCapacity_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_CheckTxQueueCapacity_Call) Return(err error) *EvmTxStore_CheckTxQueueCapacity_Call
func (*EvmTxStore_CheckTxQueueCapacity_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_CheckTxQueueCapacity_Call) Run(run func(ctx context.Context, fromAddress common.Address, maxQueuedTransactions uint64, chainID *big.Int)) *EvmTxStore_CheckTxQueueCapacity_Call
func (*EvmTxStore_CheckTxQueueCapacity_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_CheckTxQueueCapacity_Call) RunAndReturn(run func(context.Context, common.Address, uint64, *big.Int) error) *EvmTxStore_CheckTxQueueCapacity_Call
type EvmTxStore_Close_Call ¶ added in v2.15.0
EvmTxStore_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*EvmTxStore_Close_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_Close_Call) Return() *EvmTxStore_Close_Call
func (*EvmTxStore_Close_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_Close_Call) Run(run func()) *EvmTxStore_Close_Call
func (*EvmTxStore_Close_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_Close_Call) RunAndReturn(run func()) *EvmTxStore_Close_Call
type EvmTxStore_CountTransactionsByState_Call ¶ added in v2.15.0
EvmTxStore_CountTransactionsByState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CountTransactionsByState'
func (*EvmTxStore_CountTransactionsByState_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_CountTransactionsByState_Call) Return(count uint32, err error) *EvmTxStore_CountTransactionsByState_Call
func (*EvmTxStore_CountTransactionsByState_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_CountTransactionsByState_Call) Run(run func(ctx context.Context, state types.TxState, chainID *big.Int)) *EvmTxStore_CountTransactionsByState_Call
func (*EvmTxStore_CountTransactionsByState_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_CountTransactionsByState_Call) RunAndReturn(run func(context.Context, types.TxState, *big.Int) (uint32, error)) *EvmTxStore_CountTransactionsByState_Call
type EvmTxStore_CountUnconfirmedTransactions_Call ¶ added in v2.15.0
EvmTxStore_CountUnconfirmedTransactions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CountUnconfirmedTransactions'
func (*EvmTxStore_CountUnconfirmedTransactions_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_CountUnconfirmedTransactions_Call) Return(count uint32, err error) *EvmTxStore_CountUnconfirmedTransactions_Call
func (*EvmTxStore_CountUnconfirmedTransactions_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_CountUnconfirmedTransactions_Call) Run(run func(ctx context.Context, fromAddress common.Address, chainID *big.Int)) *EvmTxStore_CountUnconfirmedTransactions_Call
func (*EvmTxStore_CountUnconfirmedTransactions_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_CountUnconfirmedTransactions_Call) RunAndReturn(run func(context.Context, common.Address, *big.Int) (uint32, error)) *EvmTxStore_CountUnconfirmedTransactions_Call
type EvmTxStore_CountUnstartedTransactions_Call ¶ added in v2.15.0
EvmTxStore_CountUnstartedTransactions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CountUnstartedTransactions'
func (*EvmTxStore_CountUnstartedTransactions_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_CountUnstartedTransactions_Call) Return(count uint32, err error) *EvmTxStore_CountUnstartedTransactions_Call
func (*EvmTxStore_CountUnstartedTransactions_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_CountUnstartedTransactions_Call) Run(run func(ctx context.Context, fromAddress common.Address, chainID *big.Int)) *EvmTxStore_CountUnstartedTransactions_Call
func (*EvmTxStore_CountUnstartedTransactions_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_CountUnstartedTransactions_Call) RunAndReturn(run func(context.Context, common.Address, *big.Int) (uint32, error)) *EvmTxStore_CountUnstartedTransactions_Call
type EvmTxStore_CreateTransaction_Call ¶ added in v2.15.0
EvmTxStore_CreateTransaction_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateTransaction'
func (*EvmTxStore_CreateTransaction_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_DeleteInProgressAttempt_Call ¶ added in v2.15.0
EvmTxStore_DeleteInProgressAttempt_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteInProgressAttempt'
func (*EvmTxStore_DeleteInProgressAttempt_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_DeleteInProgressAttempt_Call) Return(_a0 error) *EvmTxStore_DeleteInProgressAttempt_Call
func (*EvmTxStore_DeleteInProgressAttempt_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_Expecter ¶ added in v2.15.0
type EvmTxStore_Expecter struct {
// contains filtered or unexported fields
}
func (*EvmTxStore_Expecter) Abandon ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) Abandon(ctx interface{}, id interface{}, addr interface{}) *EvmTxStore_Abandon_Call
Abandon is a helper method to define mock.On call
- ctx context.Context
- id *big.Int
- addr common.Address
func (*EvmTxStore_Expecter) CheckTxQueueCapacity ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) CheckTxQueueCapacity(ctx interface{}, fromAddress interface{}, maxQueuedTransactions interface{}, chainID interface{}) *EvmTxStore_CheckTxQueueCapacity_Call
CheckTxQueueCapacity is a helper method to define mock.On call
- ctx context.Context
- fromAddress common.Address
- maxQueuedTransactions uint64
- chainID *big.Int
func (*EvmTxStore_Expecter) Close ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) Close() *EvmTxStore_Close_Call
Close is a helper method to define mock.On call
func (*EvmTxStore_Expecter) CountTransactionsByState ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) CountTransactionsByState(ctx interface{}, state interface{}, chainID interface{}) *EvmTxStore_CountTransactionsByState_Call
CountTransactionsByState is a helper method to define mock.On call
- ctx context.Context
- state types.TxState
- chainID *big.Int
func (*EvmTxStore_Expecter) CountUnconfirmedTransactions ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) CountUnconfirmedTransactions(ctx interface{}, fromAddress interface{}, chainID interface{}) *EvmTxStore_CountUnconfirmedTransactions_Call
CountUnconfirmedTransactions is a helper method to define mock.On call
- ctx context.Context
- fromAddress common.Address
- chainID *big.Int
func (*EvmTxStore_Expecter) CountUnstartedTransactions ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) CountUnstartedTransactions(ctx interface{}, fromAddress interface{}, chainID interface{}) *EvmTxStore_CountUnstartedTransactions_Call
CountUnstartedTransactions is a helper method to define mock.On call
- ctx context.Context
- fromAddress common.Address
- chainID *big.Int
func (*EvmTxStore_Expecter) CreateTransaction ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) CreateTransaction(ctx interface{}, txRequest interface{}, chainID interface{}) *EvmTxStore_CreateTransaction_Call
CreateTransaction is a helper method to define mock.On call
- ctx context.Context
- txRequest types.TxRequest[common.Address,common.Hash]
- chainID *big.Int
func (*EvmTxStore_Expecter) DeleteInProgressAttempt ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) DeleteInProgressAttempt(ctx interface{}, attempt interface{}) *EvmTxStore_DeleteInProgressAttempt_Call
DeleteInProgressAttempt is a helper method to define mock.On call
- ctx context.Context
- attempt types.TxAttempt[*big.Int,common.Address,common.Hash,common.Hash,evmtypes.Nonce,gas.EvmFee]
func (*EvmTxStore_Expecter) FindEarliestUnconfirmedBroadcastTime ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindEarliestUnconfirmedBroadcastTime(ctx interface{}, chainID interface{}) *EvmTxStore_FindEarliestUnconfirmedBroadcastTime_Call
FindEarliestUnconfirmedBroadcastTime is a helper method to define mock.On call
- ctx context.Context
- chainID *big.Int
func (*EvmTxStore_Expecter) FindEarliestUnconfirmedTxAttemptBlock ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindEarliestUnconfirmedTxAttemptBlock(ctx interface{}, chainID interface{}) *EvmTxStore_FindEarliestUnconfirmedTxAttemptBlock_Call
FindEarliestUnconfirmedTxAttemptBlock is a helper method to define mock.On call
- ctx context.Context
- chainID *big.Int
func (*EvmTxStore_Expecter) FindLatestSequence ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindLatestSequence(ctx interface{}, fromAddress interface{}, chainId interface{}) *EvmTxStore_FindLatestSequence_Call
FindLatestSequence is a helper method to define mock.On call
- ctx context.Context
- fromAddress common.Address
- chainId *big.Int
func (*EvmTxStore_Expecter) FindNextUnstartedTransactionFromAddress ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindNextUnstartedTransactionFromAddress(ctx interface{}, fromAddress interface{}, chainID interface{}) *EvmTxStore_FindNextUnstartedTransactionFromAddress_Call
FindNextUnstartedTransactionFromAddress is a helper method to define mock.On call
- ctx context.Context
- fromAddress common.Address
- chainID *big.Int
func (*EvmTxStore_Expecter) FindTransactionsConfirmedInBlockRange ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindTransactionsConfirmedInBlockRange(ctx interface{}, highBlockNumber interface{}, lowBlockNumber interface{}, chainID interface{}) *EvmTxStore_FindTransactionsConfirmedInBlockRange_Call
FindTransactionsConfirmedInBlockRange is a helper method to define mock.On call
- ctx context.Context
- highBlockNumber int64
- lowBlockNumber int64
- chainID *big.Int
func (*EvmTxStore_Expecter) FindTxAttempt ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindTxAttempt(ctx interface{}, hash interface{}) *EvmTxStore_FindTxAttempt_Call
FindTxAttempt is a helper method to define mock.On call
- ctx context.Context
- hash common.Hash
func (*EvmTxStore_Expecter) FindTxAttemptConfirmedByTxIDs ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindTxAttemptConfirmedByTxIDs(ctx interface{}, ids interface{}) *EvmTxStore_FindTxAttemptConfirmedByTxIDs_Call
FindTxAttemptConfirmedByTxIDs is a helper method to define mock.On call
- ctx context.Context
- ids []int64
func (*EvmTxStore_Expecter) FindTxAttemptsConfirmedMissingReceipt ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindTxAttemptsConfirmedMissingReceipt(ctx interface{}, chainID interface{}) *EvmTxStore_FindTxAttemptsConfirmedMissingReceipt_Call
FindTxAttemptsConfirmedMissingReceipt is a helper method to define mock.On call
- ctx context.Context
- chainID *big.Int
func (*EvmTxStore_Expecter) FindTxAttemptsRequiringReceiptFetch ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindTxAttemptsRequiringReceiptFetch(ctx interface{}, chainID interface{}) *EvmTxStore_FindTxAttemptsRequiringReceiptFetch_Call
FindTxAttemptsRequiringReceiptFetch is a helper method to define mock.On call
- ctx context.Context
- chainID *big.Int
func (*EvmTxStore_Expecter) FindTxAttemptsRequiringResend ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindTxAttemptsRequiringResend(ctx interface{}, olderThan interface{}, maxInFlightTransactions interface{}, chainID interface{}, address interface{}) *EvmTxStore_FindTxAttemptsRequiringResend_Call
FindTxAttemptsRequiringResend is a helper method to define mock.On call
- ctx context.Context
- olderThan time.Time
- maxInFlightTransactions uint32
- chainID *big.Int
- address common.Address
func (*EvmTxStore_Expecter) FindTxByHash ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindTxByHash(ctx interface{}, hash interface{}) *EvmTxStore_FindTxByHash_Call
FindTxByHash is a helper method to define mock.On call
- ctx context.Context
- hash common.Hash
func (*EvmTxStore_Expecter) FindTxWithAttempts ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindTxWithAttempts(ctx interface{}, etxID interface{}) *EvmTxStore_FindTxWithAttempts_Call
FindTxWithAttempts is a helper method to define mock.On call
- ctx context.Context
- etxID int64
func (*EvmTxStore_Expecter) FindTxWithIdempotencyKey ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindTxWithIdempotencyKey(ctx interface{}, idempotencyKey interface{}, chainID interface{}) *EvmTxStore_FindTxWithIdempotencyKey_Call
FindTxWithIdempotencyKey is a helper method to define mock.On call
- ctx context.Context
- idempotencyKey string
- chainID *big.Int
func (*EvmTxStore_Expecter) FindTxWithSequence ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindTxWithSequence(ctx interface{}, fromAddress interface{}, seq interface{}) *EvmTxStore_FindTxWithSequence_Call
FindTxWithSequence is a helper method to define mock.On call
- ctx context.Context
- fromAddress common.Address
- seq evmtypes.Nonce
func (*EvmTxStore_Expecter) FindTxesByMetaFieldAndStates ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindTxesByMetaFieldAndStates(ctx interface{}, metaField interface{}, metaValue interface{}, states interface{}, chainID interface{}) *EvmTxStore_FindTxesByMetaFieldAndStates_Call
FindTxesByMetaFieldAndStates is a helper method to define mock.On call
- ctx context.Context
- metaField string
- metaValue string
- states []types.TxState
- chainID *big.Int
func (*EvmTxStore_Expecter) FindTxesPendingCallback ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindTxesPendingCallback(ctx interface{}, blockNum interface{}, chainID interface{}) *EvmTxStore_FindTxesPendingCallback_Call
FindTxesPendingCallback is a helper method to define mock.On call
- ctx context.Context
- blockNum int64
- chainID *big.Int
func (*EvmTxStore_Expecter) FindTxesWithAttemptsAndReceiptsByIdsAndState ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindTxesWithAttemptsAndReceiptsByIdsAndState(ctx interface{}, ids interface{}, states interface{}, chainID interface{}) *EvmTxStore_FindTxesWithAttemptsAndReceiptsByIdsAndState_Call
FindTxesWithAttemptsAndReceiptsByIdsAndState is a helper method to define mock.On call
- ctx context.Context
- ids []int64
- states []types.TxState
- chainID *big.Int
func (*EvmTxStore_Expecter) FindTxesWithMetaFieldByReceiptBlockNum ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindTxesWithMetaFieldByReceiptBlockNum(ctx interface{}, metaField interface{}, blockNum interface{}, chainID interface{}) *EvmTxStore_FindTxesWithMetaFieldByReceiptBlockNum_Call
FindTxesWithMetaFieldByReceiptBlockNum is a helper method to define mock.On call
- ctx context.Context
- metaField string
- blockNum int64
- chainID *big.Int
func (*EvmTxStore_Expecter) FindTxesWithMetaFieldByStates ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindTxesWithMetaFieldByStates(ctx interface{}, metaField interface{}, states interface{}, chainID interface{}) *EvmTxStore_FindTxesWithMetaFieldByStates_Call
FindTxesWithMetaFieldByStates is a helper method to define mock.On call
- ctx context.Context
- metaField string
- states []types.TxState
- chainID *big.Int
func (*EvmTxStore_Expecter) FindTxsByStateAndFromAddresses ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindTxsByStateAndFromAddresses(ctx interface{}, addresses interface{}, state interface{}, chainID interface{}) *EvmTxStore_FindTxsByStateAndFromAddresses_Call
FindTxsByStateAndFromAddresses is a helper method to define mock.On call
- ctx context.Context
- addresses []common.Address
- state types.TxState
- chainID *big.Int
func (*EvmTxStore_Expecter) FindTxsRequiringGasBump ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindTxsRequiringGasBump(ctx interface{}, address interface{}, blockNum interface{}, gasBumpThreshold interface{}, depth interface{}, chainID interface{}) *EvmTxStore_FindTxsRequiringGasBump_Call
FindTxsRequiringGasBump is a helper method to define mock.On call
- ctx context.Context
- address common.Address
- blockNum int64
- gasBumpThreshold int64
- depth int64
- chainID *big.Int
func (*EvmTxStore_Expecter) FindTxsRequiringResubmissionDueToInsufficientFunds ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) FindTxsRequiringResubmissionDueToInsufficientFunds(ctx interface{}, address interface{}, chainID interface{}) *EvmTxStore_FindTxsRequiringResubmissionDueToInsufficientFunds_Call
FindTxsRequiringResubmissionDueToInsufficientFunds is a helper method to define mock.On call
- ctx context.Context
- address common.Address
- chainID *big.Int
func (*EvmTxStore_Expecter) GetAbandonedTransactionsByBatch ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) GetAbandonedTransactionsByBatch(ctx interface{}, chainID interface{}, enabledAddrs interface{}, offset interface{}, limit interface{}) *EvmTxStore_GetAbandonedTransactionsByBatch_Call
GetAbandonedTransactionsByBatch is a helper method to define mock.On call
- ctx context.Context
- chainID *big.Int
- enabledAddrs []common.Address
- offset uint
- limit uint
func (*EvmTxStore_Expecter) GetInProgressTxAttempts ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) GetInProgressTxAttempts(ctx interface{}, address interface{}, chainID interface{}) *EvmTxStore_GetInProgressTxAttempts_Call
GetInProgressTxAttempts is a helper method to define mock.On call
- ctx context.Context
- address common.Address
- chainID *big.Int
func (*EvmTxStore_Expecter) GetTxByID ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) GetTxByID(ctx interface{}, id interface{}) *EvmTxStore_GetTxByID_Call
GetTxByID is a helper method to define mock.On call
- ctx context.Context
- id int64
func (*EvmTxStore_Expecter) GetTxInProgress ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) GetTxInProgress(ctx interface{}, fromAddress interface{}) *EvmTxStore_GetTxInProgress_Call
GetTxInProgress is a helper method to define mock.On call
- ctx context.Context
- fromAddress common.Address
func (*EvmTxStore_Expecter) HasInProgressTransaction ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) HasInProgressTransaction(ctx interface{}, account interface{}, chainID interface{}) *EvmTxStore_HasInProgressTransaction_Call
HasInProgressTransaction is a helper method to define mock.On call
- ctx context.Context
- account common.Address
- chainID *big.Int
func (*EvmTxStore_Expecter) IsTxFinalized ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) IsTxFinalized(ctx interface{}, blockHeight interface{}, txID interface{}, chainID interface{}) *EvmTxStore_IsTxFinalized_Call
IsTxFinalized is a helper method to define mock.On call
- ctx context.Context
- blockHeight int64
- txID int64
- chainID *big.Int
func (*EvmTxStore_Expecter) LoadTxAttempts ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) LoadTxAttempts(ctx interface{}, etx interface{}) *EvmTxStore_LoadTxAttempts_Call
LoadTxAttempts is a helper method to define mock.On call
- ctx context.Context
- etx *types.Tx[*big.Int,common.Address,common.Hash,common.Hash,evmtypes.Nonce,gas.EvmFee]
func (*EvmTxStore_Expecter) MarkAllConfirmedMissingReceipt ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) MarkAllConfirmedMissingReceipt(ctx interface{}, chainID interface{}) *EvmTxStore_MarkAllConfirmedMissingReceipt_Call
MarkAllConfirmedMissingReceipt is a helper method to define mock.On call
- ctx context.Context
- chainID *big.Int
func (*EvmTxStore_Expecter) MarkOldTxesMissingReceiptAsErrored ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) MarkOldTxesMissingReceiptAsErrored(ctx interface{}, blockNum interface{}, finalityDepth interface{}, chainID interface{}) *EvmTxStore_MarkOldTxesMissingReceiptAsErrored_Call
MarkOldTxesMissingReceiptAsErrored is a helper method to define mock.On call
- ctx context.Context
- blockNum int64
- finalityDepth uint32
- chainID *big.Int
func (*EvmTxStore_Expecter) PreloadTxes ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) PreloadTxes(ctx interface{}, attempts interface{}) *EvmTxStore_PreloadTxes_Call
PreloadTxes is a helper method to define mock.On call
- ctx context.Context
- attempts []types.TxAttempt[*big.Int,common.Address,common.Hash,common.Hash,evmtypes.Nonce,gas.EvmFee]
func (*EvmTxStore_Expecter) PruneUnstartedTxQueue ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) PruneUnstartedTxQueue(ctx interface{}, queueSize interface{}, subject interface{}) *EvmTxStore_PruneUnstartedTxQueue_Call
PruneUnstartedTxQueue is a helper method to define mock.On call
- ctx context.Context
- queueSize uint32
- subject uuid.UUID
func (*EvmTxStore_Expecter) ReapTxHistory ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) ReapTxHistory(ctx interface{}, minBlockNumberToKeep interface{}, timeThreshold interface{}, chainID interface{}) *EvmTxStore_ReapTxHistory_Call
ReapTxHistory is a helper method to define mock.On call
- ctx context.Context
- minBlockNumberToKeep int64
- timeThreshold time.Time
- chainID *big.Int
func (*EvmTxStore_Expecter) SaveConfirmedMissingReceiptAttempt ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) SaveConfirmedMissingReceiptAttempt(ctx interface{}, timeout interface{}, attempt interface{}, broadcastAt interface{}) *EvmTxStore_SaveConfirmedMissingReceiptAttempt_Call
SaveConfirmedMissingReceiptAttempt is a helper method to define mock.On call
- ctx context.Context
- timeout time.Duration
- attempt *types.TxAttempt[*big.Int,common.Address,common.Hash,common.Hash,evmtypes.Nonce,gas.EvmFee]
- broadcastAt time.Time
func (*EvmTxStore_Expecter) SaveFetchedReceipts ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) SaveFetchedReceipts(ctx interface{}, r interface{}, state interface{}, errorMsg interface{}, chainID interface{}) *EvmTxStore_SaveFetchedReceipts_Call
SaveFetchedReceipts is a helper method to define mock.On call
- ctx context.Context
- r []*evmtypes.Receipt
- state types.TxState
- errorMsg *string
- chainID *big.Int
func (*EvmTxStore_Expecter) SaveInProgressAttempt ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) SaveInProgressAttempt(ctx interface{}, attempt interface{}) *EvmTxStore_SaveInProgressAttempt_Call
SaveInProgressAttempt is a helper method to define mock.On call
- ctx context.Context
- attempt *types.TxAttempt[*big.Int,common.Address,common.Hash,common.Hash,evmtypes.Nonce,gas.EvmFee]
func (*EvmTxStore_Expecter) SaveInsufficientFundsAttempt ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) SaveInsufficientFundsAttempt(ctx interface{}, timeout interface{}, attempt interface{}, broadcastAt interface{}) *EvmTxStore_SaveInsufficientFundsAttempt_Call
SaveInsufficientFundsAttempt is a helper method to define mock.On call
- ctx context.Context
- timeout time.Duration
- attempt *types.TxAttempt[*big.Int,common.Address,common.Hash,common.Hash,evmtypes.Nonce,gas.EvmFee]
- broadcastAt time.Time
func (*EvmTxStore_Expecter) SaveReplacementInProgressAttempt ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) SaveReplacementInProgressAttempt(ctx interface{}, oldAttempt interface{}, replacementAttempt interface{}) *EvmTxStore_SaveReplacementInProgressAttempt_Call
SaveReplacementInProgressAttempt is a helper method to define mock.On call
- ctx context.Context
- 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]
func (*EvmTxStore_Expecter) SaveSentAttempt ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) SaveSentAttempt(ctx interface{}, timeout interface{}, attempt interface{}, broadcastAt interface{}) *EvmTxStore_SaveSentAttempt_Call
SaveSentAttempt is a helper method to define mock.On call
- ctx context.Context
- timeout time.Duration
- attempt *types.TxAttempt[*big.Int,common.Address,common.Hash,common.Hash,evmtypes.Nonce,gas.EvmFee]
- broadcastAt time.Time
func (*EvmTxStore_Expecter) SetBroadcastBeforeBlockNum ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) SetBroadcastBeforeBlockNum(ctx interface{}, blockNum interface{}, chainID interface{}) *EvmTxStore_SetBroadcastBeforeBlockNum_Call
SetBroadcastBeforeBlockNum is a helper method to define mock.On call
- ctx context.Context
- blockNum int64
- chainID *big.Int
func (*EvmTxStore_Expecter) Transactions ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) Transactions(ctx interface{}, offset interface{}, limit interface{}) *EvmTxStore_Transactions_Call
Transactions is a helper method to define mock.On call
- ctx context.Context
- offset int
- limit int
func (*EvmTxStore_Expecter) TransactionsWithAttempts ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) TransactionsWithAttempts(ctx interface{}, offset interface{}, limit interface{}) *EvmTxStore_TransactionsWithAttempts_Call
TransactionsWithAttempts is a helper method to define mock.On call
- ctx context.Context
- offset int
- limit int
func (*EvmTxStore_Expecter) TxAttempts ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) TxAttempts(ctx interface{}, offset interface{}, limit interface{}) *EvmTxStore_TxAttempts_Call
TxAttempts is a helper method to define mock.On call
- ctx context.Context
- offset int
- limit int
func (*EvmTxStore_Expecter) UpdateBroadcastAts ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) UpdateBroadcastAts(ctx interface{}, now interface{}, etxIDs interface{}) *EvmTxStore_UpdateBroadcastAts_Call
UpdateBroadcastAts is a helper method to define mock.On call
- ctx context.Context
- now time.Time
- etxIDs []int64
func (*EvmTxStore_Expecter) UpdateTxAttemptInProgressToBroadcast ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) UpdateTxAttemptInProgressToBroadcast(ctx interface{}, etx interface{}, attempt interface{}, NewAttemptState interface{}) *EvmTxStore_UpdateTxAttemptInProgressToBroadcast_Call
UpdateTxAttemptInProgressToBroadcast is a helper method to define mock.On call
- ctx context.Context
- 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
func (*EvmTxStore_Expecter) UpdateTxCallbackCompleted ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) UpdateTxCallbackCompleted(ctx interface{}, pipelineTaskRunRid interface{}, chainId interface{}) *EvmTxStore_UpdateTxCallbackCompleted_Call
UpdateTxCallbackCompleted is a helper method to define mock.On call
- ctx context.Context
- pipelineTaskRunRid uuid.UUID
- chainId *big.Int
func (*EvmTxStore_Expecter) UpdateTxFatalError ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) UpdateTxFatalError(ctx interface{}, etx interface{}) *EvmTxStore_UpdateTxFatalError_Call
UpdateTxFatalError is a helper method to define mock.On call
- ctx context.Context
- etx *types.Tx[*big.Int,common.Address,common.Hash,common.Hash,evmtypes.Nonce,gas.EvmFee]
func (*EvmTxStore_Expecter) UpdateTxForRebroadcast ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) UpdateTxForRebroadcast(ctx interface{}, etx interface{}, etxAttempt interface{}) *EvmTxStore_UpdateTxForRebroadcast_Call
UpdateTxForRebroadcast is a helper method to define mock.On call
- ctx context.Context
- 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]
func (*EvmTxStore_Expecter) UpdateTxUnstartedToInProgress ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) UpdateTxUnstartedToInProgress(ctx interface{}, etx interface{}, attempt interface{}) *EvmTxStore_UpdateTxUnstartedToInProgress_Call
UpdateTxUnstartedToInProgress is a helper method to define mock.On call
- ctx context.Context
- 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]
func (*EvmTxStore_Expecter) UpdateTxsUnconfirmed ¶ added in v2.15.0
func (_e *EvmTxStore_Expecter) UpdateTxsUnconfirmed(ctx interface{}, ids interface{}) *EvmTxStore_UpdateTxsUnconfirmed_Call
UpdateTxsUnconfirmed is a helper method to define mock.On call
- ctx context.Context
- ids []int64
type EvmTxStore_FindEarliestUnconfirmedBroadcastTime_Call ¶ added in v2.15.0
EvmTxStore_FindEarliestUnconfirmedBroadcastTime_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindEarliestUnconfirmedBroadcastTime'
func (*EvmTxStore_FindEarliestUnconfirmedBroadcastTime_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_FindEarliestUnconfirmedBroadcastTime_Call) Return(_a0 null.Time, _a1 error) *EvmTxStore_FindEarliestUnconfirmedBroadcastTime_Call
func (*EvmTxStore_FindEarliestUnconfirmedBroadcastTime_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_FindEarliestUnconfirmedBroadcastTime_Call) Run(run func(ctx context.Context, chainID *big.Int)) *EvmTxStore_FindEarliestUnconfirmedBroadcastTime_Call
func (*EvmTxStore_FindEarliestUnconfirmedBroadcastTime_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_FindEarliestUnconfirmedBroadcastTime_Call) RunAndReturn(run func(context.Context, *big.Int) (null.Time, error)) *EvmTxStore_FindEarliestUnconfirmedBroadcastTime_Call
type EvmTxStore_FindEarliestUnconfirmedTxAttemptBlock_Call ¶ added in v2.15.0
EvmTxStore_FindEarliestUnconfirmedTxAttemptBlock_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindEarliestUnconfirmedTxAttemptBlock'
func (*EvmTxStore_FindEarliestUnconfirmedTxAttemptBlock_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_FindEarliestUnconfirmedTxAttemptBlock_Call) Return(_a0 null.Int, _a1 error) *EvmTxStore_FindEarliestUnconfirmedTxAttemptBlock_Call
func (*EvmTxStore_FindEarliestUnconfirmedTxAttemptBlock_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_FindEarliestUnconfirmedTxAttemptBlock_Call) Run(run func(ctx context.Context, chainID *big.Int)) *EvmTxStore_FindEarliestUnconfirmedTxAttemptBlock_Call
func (*EvmTxStore_FindEarliestUnconfirmedTxAttemptBlock_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_FindEarliestUnconfirmedTxAttemptBlock_Call) RunAndReturn(run func(context.Context, *big.Int) (null.Int, error)) *EvmTxStore_FindEarliestUnconfirmedTxAttemptBlock_Call
type EvmTxStore_FindLatestSequence_Call ¶ added in v2.15.0
EvmTxStore_FindLatestSequence_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindLatestSequence'
func (*EvmTxStore_FindLatestSequence_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_FindLatestSequence_Call) Return(_a0 evmtypes.Nonce, _a1 error) *EvmTxStore_FindLatestSequence_Call
func (*EvmTxStore_FindLatestSequence_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_FindLatestSequence_Call) Run(run func(ctx context.Context, fromAddress common.Address, chainId *big.Int)) *EvmTxStore_FindLatestSequence_Call
func (*EvmTxStore_FindLatestSequence_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_FindNextUnstartedTransactionFromAddress_Call ¶ added in v2.15.0
EvmTxStore_FindNextUnstartedTransactionFromAddress_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindNextUnstartedTransactionFromAddress'
func (*EvmTxStore_FindNextUnstartedTransactionFromAddress_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_FindNextUnstartedTransactionFromAddress_Call) Run(run func(ctx context.Context, fromAddress common.Address, chainID *big.Int)) *EvmTxStore_FindNextUnstartedTransactionFromAddress_Call
func (*EvmTxStore_FindNextUnstartedTransactionFromAddress_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_FindTransactionsConfirmedInBlockRange_Call ¶ added in v2.15.0
EvmTxStore_FindTransactionsConfirmedInBlockRange_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindTransactionsConfirmedInBlockRange'
func (*EvmTxStore_FindTransactionsConfirmedInBlockRange_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_FindTransactionsConfirmedInBlockRange_Call) Run(run func(ctx context.Context, highBlockNumber int64, lowBlockNumber int64, chainID *big.Int)) *EvmTxStore_FindTransactionsConfirmedInBlockRange_Call
func (*EvmTxStore_FindTransactionsConfirmedInBlockRange_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_FindTxAttemptConfirmedByTxIDs_Call ¶ added in v2.15.0
EvmTxStore_FindTxAttemptConfirmedByTxIDs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindTxAttemptConfirmedByTxIDs'
func (*EvmTxStore_FindTxAttemptConfirmedByTxIDs_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_FindTxAttemptConfirmedByTxIDs_Call) Run(run func(ctx context.Context, ids []int64)) *EvmTxStore_FindTxAttemptConfirmedByTxIDs_Call
func (*EvmTxStore_FindTxAttemptConfirmedByTxIDs_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_FindTxAttempt_Call ¶ added in v2.15.0
EvmTxStore_FindTxAttempt_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindTxAttempt'
func (*EvmTxStore_FindTxAttempt_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_FindTxAttempt_Call) Run(run func(ctx context.Context, hash common.Hash)) *EvmTxStore_FindTxAttempt_Call
func (*EvmTxStore_FindTxAttempt_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_FindTxAttemptsConfirmedMissingReceipt_Call ¶ added in v2.15.0
EvmTxStore_FindTxAttemptsConfirmedMissingReceipt_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindTxAttemptsConfirmedMissingReceipt'
func (*EvmTxStore_FindTxAttemptsConfirmedMissingReceipt_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_FindTxAttemptsConfirmedMissingReceipt_Call) Run(run func(ctx context.Context, chainID *big.Int)) *EvmTxStore_FindTxAttemptsConfirmedMissingReceipt_Call
func (*EvmTxStore_FindTxAttemptsConfirmedMissingReceipt_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_FindTxAttemptsRequiringReceiptFetch_Call ¶ added in v2.15.0
EvmTxStore_FindTxAttemptsRequiringReceiptFetch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindTxAttemptsRequiringReceiptFetch'
func (*EvmTxStore_FindTxAttemptsRequiringReceiptFetch_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_FindTxAttemptsRequiringReceiptFetch_Call) Run(run func(ctx context.Context, chainID *big.Int)) *EvmTxStore_FindTxAttemptsRequiringReceiptFetch_Call
func (*EvmTxStore_FindTxAttemptsRequiringReceiptFetch_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_FindTxAttemptsRequiringResend_Call ¶ added in v2.15.0
EvmTxStore_FindTxAttemptsRequiringResend_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindTxAttemptsRequiringResend'
func (*EvmTxStore_FindTxAttemptsRequiringResend_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_FindTxByHash_Call ¶ added in v2.15.0
EvmTxStore_FindTxByHash_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindTxByHash'
func (*EvmTxStore_FindTxByHash_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_FindTxByHash_Call) Run(run func(ctx context.Context, hash common.Hash)) *EvmTxStore_FindTxByHash_Call
type EvmTxStore_FindTxWithAttempts_Call ¶ added in v2.15.0
EvmTxStore_FindTxWithAttempts_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindTxWithAttempts'
func (*EvmTxStore_FindTxWithAttempts_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_FindTxWithAttempts_Call) Run(run func(ctx context.Context, etxID int64)) *EvmTxStore_FindTxWithAttempts_Call
func (*EvmTxStore_FindTxWithAttempts_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_FindTxWithIdempotencyKey_Call ¶ added in v2.15.0
EvmTxStore_FindTxWithIdempotencyKey_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindTxWithIdempotencyKey'
func (*EvmTxStore_FindTxWithIdempotencyKey_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_FindTxWithIdempotencyKey_Call) Run(run func(ctx context.Context, idempotencyKey string, chainID *big.Int)) *EvmTxStore_FindTxWithIdempotencyKey_Call
func (*EvmTxStore_FindTxWithIdempotencyKey_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_FindTxWithSequence_Call ¶ added in v2.15.0
EvmTxStore_FindTxWithSequence_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindTxWithSequence'
func (*EvmTxStore_FindTxWithSequence_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_FindTxWithSequence_Call) Run(run func(ctx context.Context, fromAddress common.Address, seq evmtypes.Nonce)) *EvmTxStore_FindTxWithSequence_Call
func (*EvmTxStore_FindTxWithSequence_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_FindTxesByMetaFieldAndStates_Call ¶ added in v2.15.0
EvmTxStore_FindTxesByMetaFieldAndStates_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindTxesByMetaFieldAndStates'
func (*EvmTxStore_FindTxesByMetaFieldAndStates_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_FindTxesByMetaFieldAndStates_Call) Run(run func(ctx context.Context, metaField string, metaValue string, states []types.TxState, chainID *big.Int)) *EvmTxStore_FindTxesByMetaFieldAndStates_Call
func (*EvmTxStore_FindTxesByMetaFieldAndStates_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_FindTxesPendingCallback_Call ¶ added in v2.15.0
EvmTxStore_FindTxesPendingCallback_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindTxesPendingCallback'
func (*EvmTxStore_FindTxesPendingCallback_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_FindTxesPendingCallback_Call) Return(receiptsPlus []types.ReceiptPlus[*evmtypes.Receipt], err error) *EvmTxStore_FindTxesPendingCallback_Call
func (*EvmTxStore_FindTxesPendingCallback_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_FindTxesPendingCallback_Call) Run(run func(ctx context.Context, blockNum int64, chainID *big.Int)) *EvmTxStore_FindTxesPendingCallback_Call
func (*EvmTxStore_FindTxesPendingCallback_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_FindTxesPendingCallback_Call) RunAndReturn(run func(context.Context, int64, *big.Int) ([]types.ReceiptPlus[*evmtypes.Receipt], error)) *EvmTxStore_FindTxesPendingCallback_Call
type EvmTxStore_FindTxesWithAttemptsAndReceiptsByIdsAndState_Call ¶ added in v2.15.0
EvmTxStore_FindTxesWithAttemptsAndReceiptsByIdsAndState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindTxesWithAttemptsAndReceiptsByIdsAndState'
func (*EvmTxStore_FindTxesWithAttemptsAndReceiptsByIdsAndState_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_FindTxesWithAttemptsAndReceiptsByIdsAndState_Call) Run(run func(ctx context.Context, ids []int64, states []types.TxState, chainID *big.Int)) *EvmTxStore_FindTxesWithAttemptsAndReceiptsByIdsAndState_Call
func (*EvmTxStore_FindTxesWithAttemptsAndReceiptsByIdsAndState_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_FindTxesWithAttemptsAndReceiptsByIdsAndState_Call) RunAndReturn(run func(context.Context, []int64, []types.TxState, *big.Int) ([]*types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)) *EvmTxStore_FindTxesWithAttemptsAndReceiptsByIdsAndState_Call
type EvmTxStore_FindTxesWithMetaFieldByReceiptBlockNum_Call ¶ added in v2.15.0
EvmTxStore_FindTxesWithMetaFieldByReceiptBlockNum_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindTxesWithMetaFieldByReceiptBlockNum'
func (*EvmTxStore_FindTxesWithMetaFieldByReceiptBlockNum_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_FindTxesWithMetaFieldByReceiptBlockNum_Call) Run(run func(ctx context.Context, metaField string, blockNum int64, chainID *big.Int)) *EvmTxStore_FindTxesWithMetaFieldByReceiptBlockNum_Call
func (*EvmTxStore_FindTxesWithMetaFieldByReceiptBlockNum_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_FindTxesWithMetaFieldByStates_Call ¶ added in v2.15.0
EvmTxStore_FindTxesWithMetaFieldByStates_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindTxesWithMetaFieldByStates'
func (*EvmTxStore_FindTxesWithMetaFieldByStates_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_FindTxesWithMetaFieldByStates_Call) Run(run func(ctx context.Context, metaField string, states []types.TxState, chainID *big.Int)) *EvmTxStore_FindTxesWithMetaFieldByStates_Call
func (*EvmTxStore_FindTxesWithMetaFieldByStates_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_FindTxsByStateAndFromAddresses_Call ¶ added in v2.15.0
EvmTxStore_FindTxsByStateAndFromAddresses_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindTxsByStateAndFromAddresses'
func (*EvmTxStore_FindTxsByStateAndFromAddresses_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_FindTxsByStateAndFromAddresses_Call) Run(run func(ctx context.Context, addresses []common.Address, state types.TxState, chainID *big.Int)) *EvmTxStore_FindTxsByStateAndFromAddresses_Call
func (*EvmTxStore_FindTxsByStateAndFromAddresses_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_FindTxsRequiringGasBump_Call ¶ added in v2.15.0
EvmTxStore_FindTxsRequiringGasBump_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindTxsRequiringGasBump'
func (*EvmTxStore_FindTxsRequiringGasBump_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_FindTxsRequiringResubmissionDueToInsufficientFunds_Call ¶ added in v2.15.0
EvmTxStore_FindTxsRequiringResubmissionDueToInsufficientFunds_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindTxsRequiringResubmissionDueToInsufficientFunds'
func (*EvmTxStore_FindTxsRequiringResubmissionDueToInsufficientFunds_Call) Return ¶ added in v2.15.0
func (*EvmTxStore_FindTxsRequiringResubmissionDueToInsufficientFunds_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_FindTxsRequiringResubmissionDueToInsufficientFunds_Call) Run(run func(ctx context.Context, address common.Address, chainID *big.Int)) *EvmTxStore_FindTxsRequiringResubmissionDueToInsufficientFunds_Call
func (*EvmTxStore_FindTxsRequiringResubmissionDueToInsufficientFunds_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_FindTxsRequiringResubmissionDueToInsufficientFunds_Call) RunAndReturn(run func(context.Context, common.Address, *big.Int) ([]*types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], error)) *EvmTxStore_FindTxsRequiringResubmissionDueToInsufficientFunds_Call
type EvmTxStore_GetAbandonedTransactionsByBatch_Call ¶ added in v2.15.0
EvmTxStore_GetAbandonedTransactionsByBatch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAbandonedTransactionsByBatch'
func (*EvmTxStore_GetAbandonedTransactionsByBatch_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_GetAbandonedTransactionsByBatch_Call) Run(run func(ctx context.Context, chainID *big.Int, enabledAddrs []common.Address, offset uint, limit uint)) *EvmTxStore_GetAbandonedTransactionsByBatch_Call
func (*EvmTxStore_GetAbandonedTransactionsByBatch_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_GetInProgressTxAttempts_Call ¶ added in v2.15.0
EvmTxStore_GetInProgressTxAttempts_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetInProgressTxAttempts'
func (*EvmTxStore_GetInProgressTxAttempts_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_GetInProgressTxAttempts_Call) Run(run func(ctx context.Context, address common.Address, chainID *big.Int)) *EvmTxStore_GetInProgressTxAttempts_Call
func (*EvmTxStore_GetInProgressTxAttempts_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_GetTxByID_Call ¶ added in v2.15.0
EvmTxStore_GetTxByID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTxByID'
func (*EvmTxStore_GetTxByID_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_GetTxByID_Call) Run(run func(ctx context.Context, id int64)) *EvmTxStore_GetTxByID_Call
type EvmTxStore_GetTxInProgress_Call ¶ added in v2.15.0
EvmTxStore_GetTxInProgress_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTxInProgress'
func (*EvmTxStore_GetTxInProgress_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_GetTxInProgress_Call) Run(run func(ctx context.Context, fromAddress common.Address)) *EvmTxStore_GetTxInProgress_Call
func (*EvmTxStore_GetTxInProgress_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_HasInProgressTransaction_Call ¶ added in v2.15.0
EvmTxStore_HasInProgressTransaction_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HasInProgressTransaction'
func (*EvmTxStore_HasInProgressTransaction_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_HasInProgressTransaction_Call) Return(exists bool, err error) *EvmTxStore_HasInProgressTransaction_Call
func (*EvmTxStore_HasInProgressTransaction_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_HasInProgressTransaction_Call) Run(run func(ctx context.Context, account common.Address, chainID *big.Int)) *EvmTxStore_HasInProgressTransaction_Call
func (*EvmTxStore_HasInProgressTransaction_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_HasInProgressTransaction_Call) RunAndReturn(run func(context.Context, common.Address, *big.Int) (bool, error)) *EvmTxStore_HasInProgressTransaction_Call
type EvmTxStore_IsTxFinalized_Call ¶ added in v2.15.0
EvmTxStore_IsTxFinalized_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsTxFinalized'
func (*EvmTxStore_IsTxFinalized_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_IsTxFinalized_Call) Return(finalized bool, err error) *EvmTxStore_IsTxFinalized_Call
func (*EvmTxStore_IsTxFinalized_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_IsTxFinalized_Call) Run(run func(ctx context.Context, blockHeight int64, txID int64, chainID *big.Int)) *EvmTxStore_IsTxFinalized_Call
func (*EvmTxStore_IsTxFinalized_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_IsTxFinalized_Call) RunAndReturn(run func(context.Context, int64, int64, *big.Int) (bool, error)) *EvmTxStore_IsTxFinalized_Call
type EvmTxStore_LoadTxAttempts_Call ¶ added in v2.15.0
EvmTxStore_LoadTxAttempts_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LoadTxAttempts'
func (*EvmTxStore_LoadTxAttempts_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_LoadTxAttempts_Call) Return(_a0 error) *EvmTxStore_LoadTxAttempts_Call
type EvmTxStore_MarkAllConfirmedMissingReceipt_Call ¶ added in v2.15.0
EvmTxStore_MarkAllConfirmedMissingReceipt_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkAllConfirmedMissingReceipt'
func (*EvmTxStore_MarkAllConfirmedMissingReceipt_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_MarkAllConfirmedMissingReceipt_Call) Return(err error) *EvmTxStore_MarkAllConfirmedMissingReceipt_Call
func (*EvmTxStore_MarkAllConfirmedMissingReceipt_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_MarkAllConfirmedMissingReceipt_Call) Run(run func(ctx context.Context, chainID *big.Int)) *EvmTxStore_MarkAllConfirmedMissingReceipt_Call
func (*EvmTxStore_MarkAllConfirmedMissingReceipt_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_MarkAllConfirmedMissingReceipt_Call) RunAndReturn(run func(context.Context, *big.Int) error) *EvmTxStore_MarkAllConfirmedMissingReceipt_Call
type EvmTxStore_MarkOldTxesMissingReceiptAsErrored_Call ¶ added in v2.15.0
EvmTxStore_MarkOldTxesMissingReceiptAsErrored_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkOldTxesMissingReceiptAsErrored'
func (*EvmTxStore_MarkOldTxesMissingReceiptAsErrored_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_MarkOldTxesMissingReceiptAsErrored_Call) Run(run func(ctx context.Context, blockNum int64, finalityDepth uint32, chainID *big.Int)) *EvmTxStore_MarkOldTxesMissingReceiptAsErrored_Call
func (*EvmTxStore_MarkOldTxesMissingReceiptAsErrored_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_MarkOldTxesMissingReceiptAsErrored_Call) RunAndReturn(run func(context.Context, int64, uint32, *big.Int) error) *EvmTxStore_MarkOldTxesMissingReceiptAsErrored_Call
type EvmTxStore_PreloadTxes_Call ¶ added in v2.15.0
EvmTxStore_PreloadTxes_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PreloadTxes'
func (*EvmTxStore_PreloadTxes_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_PreloadTxes_Call) Return(_a0 error) *EvmTxStore_PreloadTxes_Call
type EvmTxStore_PruneUnstartedTxQueue_Call ¶ added in v2.15.0
EvmTxStore_PruneUnstartedTxQueue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PruneUnstartedTxQueue'
func (*EvmTxStore_PruneUnstartedTxQueue_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_PruneUnstartedTxQueue_Call) Return(ids []int64, err error) *EvmTxStore_PruneUnstartedTxQueue_Call
func (*EvmTxStore_PruneUnstartedTxQueue_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_PruneUnstartedTxQueue_Call) Run(run func(ctx context.Context, queueSize uint32, subject uuid.UUID)) *EvmTxStore_PruneUnstartedTxQueue_Call
func (*EvmTxStore_PruneUnstartedTxQueue_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_PruneUnstartedTxQueue_Call) RunAndReturn(run func(context.Context, uint32, uuid.UUID) ([]int64, error)) *EvmTxStore_PruneUnstartedTxQueue_Call
type EvmTxStore_ReapTxHistory_Call ¶ added in v2.15.0
EvmTxStore_ReapTxHistory_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReapTxHistory'
func (*EvmTxStore_ReapTxHistory_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_ReapTxHistory_Call) Return(_a0 error) *EvmTxStore_ReapTxHistory_Call
func (*EvmTxStore_ReapTxHistory_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_ReapTxHistory_Call) Run(run func(ctx context.Context, minBlockNumberToKeep int64, timeThreshold time.Time, chainID *big.Int)) *EvmTxStore_ReapTxHistory_Call
func (*EvmTxStore_ReapTxHistory_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_ReapTxHistory_Call) RunAndReturn(run func(context.Context, int64, time.Time, *big.Int) error) *EvmTxStore_ReapTxHistory_Call
type EvmTxStore_SaveConfirmedMissingReceiptAttempt_Call ¶ added in v2.15.0
EvmTxStore_SaveConfirmedMissingReceiptAttempt_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SaveConfirmedMissingReceiptAttempt'
func (*EvmTxStore_SaveConfirmedMissingReceiptAttempt_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_SaveConfirmedMissingReceiptAttempt_Call) Run(run func(ctx context.Context, timeout time.Duration, attempt *types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], broadcastAt time.Time)) *EvmTxStore_SaveConfirmedMissingReceiptAttempt_Call
func (*EvmTxStore_SaveConfirmedMissingReceiptAttempt_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_SaveFetchedReceipts_Call ¶ added in v2.15.0
EvmTxStore_SaveFetchedReceipts_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SaveFetchedReceipts'
func (*EvmTxStore_SaveFetchedReceipts_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_SaveFetchedReceipts_Call) Return(_a0 error) *EvmTxStore_SaveFetchedReceipts_Call
func (*EvmTxStore_SaveFetchedReceipts_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_SaveInProgressAttempt_Call ¶ added in v2.15.0
EvmTxStore_SaveInProgressAttempt_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SaveInProgressAttempt'
func (*EvmTxStore_SaveInProgressAttempt_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_SaveInProgressAttempt_Call) Return(_a0 error) *EvmTxStore_SaveInProgressAttempt_Call
func (*EvmTxStore_SaveInProgressAttempt_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_SaveInsufficientFundsAttempt_Call ¶ added in v2.15.0
EvmTxStore_SaveInsufficientFundsAttempt_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SaveInsufficientFundsAttempt'
func (*EvmTxStore_SaveInsufficientFundsAttempt_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_SaveInsufficientFundsAttempt_Call) Return(_a0 error) *EvmTxStore_SaveInsufficientFundsAttempt_Call
func (*EvmTxStore_SaveInsufficientFundsAttempt_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_SaveReplacementInProgressAttempt_Call ¶ added in v2.15.0
EvmTxStore_SaveReplacementInProgressAttempt_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SaveReplacementInProgressAttempt'
func (*EvmTxStore_SaveReplacementInProgressAttempt_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_SaveReplacementInProgressAttempt_Call) Return(_a0 error) *EvmTxStore_SaveReplacementInProgressAttempt_Call
func (*EvmTxStore_SaveReplacementInProgressAttempt_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_SaveReplacementInProgressAttempt_Call) Run(run func(ctx context.Context, 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])) *EvmTxStore_SaveReplacementInProgressAttempt_Call
func (*EvmTxStore_SaveReplacementInProgressAttempt_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_SaveReplacementInProgressAttempt_Call) RunAndReturn(run func(context.Context, types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], *types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee]) error) *EvmTxStore_SaveReplacementInProgressAttempt_Call
type EvmTxStore_SaveSentAttempt_Call ¶ added in v2.15.0
EvmTxStore_SaveSentAttempt_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SaveSentAttempt'
func (*EvmTxStore_SaveSentAttempt_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_SaveSentAttempt_Call) Return(_a0 error) *EvmTxStore_SaveSentAttempt_Call
func (*EvmTxStore_SaveSentAttempt_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_SetBroadcastBeforeBlockNum_Call ¶ added in v2.15.0
EvmTxStore_SetBroadcastBeforeBlockNum_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetBroadcastBeforeBlockNum'
func (*EvmTxStore_SetBroadcastBeforeBlockNum_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_SetBroadcastBeforeBlockNum_Call) Return(_a0 error) *EvmTxStore_SetBroadcastBeforeBlockNum_Call
func (*EvmTxStore_SetBroadcastBeforeBlockNum_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_SetBroadcastBeforeBlockNum_Call) Run(run func(ctx context.Context, blockNum int64, chainID *big.Int)) *EvmTxStore_SetBroadcastBeforeBlockNum_Call
func (*EvmTxStore_SetBroadcastBeforeBlockNum_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_SetBroadcastBeforeBlockNum_Call) RunAndReturn(run func(context.Context, int64, *big.Int) error) *EvmTxStore_SetBroadcastBeforeBlockNum_Call
type EvmTxStore_TransactionsWithAttempts_Call ¶ added in v2.15.0
EvmTxStore_TransactionsWithAttempts_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TransactionsWithAttempts'
func (*EvmTxStore_TransactionsWithAttempts_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_TransactionsWithAttempts_Call) Run(run func(ctx context.Context, offset int, limit int)) *EvmTxStore_TransactionsWithAttempts_Call
func (*EvmTxStore_TransactionsWithAttempts_Call) RunAndReturn ¶ added in v2.15.0
type EvmTxStore_Transactions_Call ¶ added in v2.15.0
EvmTxStore_Transactions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Transactions'
func (*EvmTxStore_Transactions_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_Transactions_Call) Run(run func(ctx context.Context, offset int, limit int)) *EvmTxStore_Transactions_Call
type EvmTxStore_TxAttempts_Call ¶ added in v2.15.0
EvmTxStore_TxAttempts_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TxAttempts'
func (*EvmTxStore_TxAttempts_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_TxAttempts_Call) Run(run func(ctx context.Context, offset int, limit int)) *EvmTxStore_TxAttempts_Call
type EvmTxStore_UpdateBroadcastAts_Call ¶ added in v2.15.0
EvmTxStore_UpdateBroadcastAts_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateBroadcastAts'
func (*EvmTxStore_UpdateBroadcastAts_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_UpdateBroadcastAts_Call) Return(_a0 error) *EvmTxStore_UpdateBroadcastAts_Call
func (*EvmTxStore_UpdateBroadcastAts_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_UpdateBroadcastAts_Call) Run(run func(ctx context.Context, now time.Time, etxIDs []int64)) *EvmTxStore_UpdateBroadcastAts_Call
func (*EvmTxStore_UpdateBroadcastAts_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_UpdateBroadcastAts_Call) RunAndReturn(run func(context.Context, time.Time, []int64) error) *EvmTxStore_UpdateBroadcastAts_Call
type EvmTxStore_UpdateTxAttemptInProgressToBroadcast_Call ¶ added in v2.15.0
EvmTxStore_UpdateTxAttemptInProgressToBroadcast_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateTxAttemptInProgressToBroadcast'
func (*EvmTxStore_UpdateTxAttemptInProgressToBroadcast_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_UpdateTxAttemptInProgressToBroadcast_Call) Run(run func(ctx context.Context, 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)) *EvmTxStore_UpdateTxAttemptInProgressToBroadcast_Call
func (*EvmTxStore_UpdateTxAttemptInProgressToBroadcast_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_UpdateTxAttemptInProgressToBroadcast_Call) RunAndReturn(run func(context.Context, *types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], types.TxAttemptState) error) *EvmTxStore_UpdateTxAttemptInProgressToBroadcast_Call
type EvmTxStore_UpdateTxCallbackCompleted_Call ¶ added in v2.15.0
EvmTxStore_UpdateTxCallbackCompleted_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateTxCallbackCompleted'
func (*EvmTxStore_UpdateTxCallbackCompleted_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_UpdateTxCallbackCompleted_Call) Return(_a0 error) *EvmTxStore_UpdateTxCallbackCompleted_Call
func (*EvmTxStore_UpdateTxCallbackCompleted_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_UpdateTxCallbackCompleted_Call) Run(run func(ctx context.Context, pipelineTaskRunRid uuid.UUID, chainId *big.Int)) *EvmTxStore_UpdateTxCallbackCompleted_Call
func (*EvmTxStore_UpdateTxCallbackCompleted_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_UpdateTxCallbackCompleted_Call) RunAndReturn(run func(context.Context, uuid.UUID, *big.Int) error) *EvmTxStore_UpdateTxCallbackCompleted_Call
type EvmTxStore_UpdateTxFatalError_Call ¶ added in v2.15.0
EvmTxStore_UpdateTxFatalError_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateTxFatalError'
func (*EvmTxStore_UpdateTxFatalError_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_UpdateTxFatalError_Call) Return(_a0 error) *EvmTxStore_UpdateTxFatalError_Call
type EvmTxStore_UpdateTxForRebroadcast_Call ¶ added in v2.15.0
EvmTxStore_UpdateTxForRebroadcast_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateTxForRebroadcast'
func (*EvmTxStore_UpdateTxForRebroadcast_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_UpdateTxForRebroadcast_Call) Return(_a0 error) *EvmTxStore_UpdateTxForRebroadcast_Call
func (*EvmTxStore_UpdateTxForRebroadcast_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_UpdateTxForRebroadcast_Call) Run(run func(ctx context.Context, 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])) *EvmTxStore_UpdateTxForRebroadcast_Call
func (*EvmTxStore_UpdateTxForRebroadcast_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_UpdateTxForRebroadcast_Call) RunAndReturn(run func(context.Context, types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee]) error) *EvmTxStore_UpdateTxForRebroadcast_Call
type EvmTxStore_UpdateTxUnstartedToInProgress_Call ¶ added in v2.15.0
EvmTxStore_UpdateTxUnstartedToInProgress_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateTxUnstartedToInProgress'
func (*EvmTxStore_UpdateTxUnstartedToInProgress_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_UpdateTxUnstartedToInProgress_Call) Return(_a0 error) *EvmTxStore_UpdateTxUnstartedToInProgress_Call
func (*EvmTxStore_UpdateTxUnstartedToInProgress_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_UpdateTxUnstartedToInProgress_Call) Run(run func(ctx context.Context, 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])) *EvmTxStore_UpdateTxUnstartedToInProgress_Call
func (*EvmTxStore_UpdateTxUnstartedToInProgress_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_UpdateTxUnstartedToInProgress_Call) RunAndReturn(run func(context.Context, *types.Tx[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee], *types.TxAttempt[*big.Int, common.Address, common.Hash, common.Hash, evmtypes.Nonce, gas.EvmFee]) error) *EvmTxStore_UpdateTxUnstartedToInProgress_Call
type EvmTxStore_UpdateTxsUnconfirmed_Call ¶ added in v2.15.0
EvmTxStore_UpdateTxsUnconfirmed_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateTxsUnconfirmed'
func (*EvmTxStore_UpdateTxsUnconfirmed_Call) Return ¶ added in v2.15.0
func (_c *EvmTxStore_UpdateTxsUnconfirmed_Call) Return(_a0 error) *EvmTxStore_UpdateTxsUnconfirmed_Call
func (*EvmTxStore_UpdateTxsUnconfirmed_Call) Run ¶ added in v2.15.0
func (_c *EvmTxStore_UpdateTxsUnconfirmed_Call) Run(run func(ctx context.Context, ids []int64)) *EvmTxStore_UpdateTxsUnconfirmed_Call
func (*EvmTxStore_UpdateTxsUnconfirmed_Call) RunAndReturn ¶ added in v2.15.0
func (_c *EvmTxStore_UpdateTxsUnconfirmed_Call) RunAndReturn(run func(context.Context, []int64) error) *EvmTxStore_UpdateTxsUnconfirmed_Call