Documentation ¶
Index ¶
- Constants
- Variables
- func UnhaltIfAffectedRows(halted *bool, haltedReason *string, mu *sync.RWMutex, rowsAffected int64)
- type Block
- type EVMBlock
- type EVMBlockHeader
- type EVMDownloader
- type EVMDownloaderImplementation
- func (d *EVMDownloaderImplementation) GetBlockHeader(ctx context.Context, blockNum uint64) (EVMBlockHeader, bool)
- func (d *EVMDownloaderImplementation) GetEventsByBlockRange(ctx context.Context, fromBlock, toBlock uint64) []EVMBlock
- func (d *EVMDownloaderImplementation) GetLogs(ctx context.Context, fromBlock, toBlock uint64) []types.Log
- func (d *EVMDownloaderImplementation) WaitForNewBlocks(ctx context.Context, lastBlockSeen uint64) (newLastBlock uint64)
- type EVMDownloaderInterface
- type EVMDownloaderMock
- func (_m *EVMDownloaderMock) Download(ctx context.Context, fromBlock uint64, downloadedCh chan EVMBlock)
- func (_m *EVMDownloaderMock) EXPECT() *EVMDownloaderMock_Expecter
- func (_m *EVMDownloaderMock) GetBlockHeader(ctx context.Context, blockNum uint64) (EVMBlockHeader, bool)
- func (_m *EVMDownloaderMock) GetEventsByBlockRange(ctx context.Context, fromBlock uint64, toBlock uint64) []EVMBlock
- func (_m *EVMDownloaderMock) GetLogs(ctx context.Context, fromBlock uint64, toBlock uint64) []types.Log
- func (_m *EVMDownloaderMock) WaitForNewBlocks(ctx context.Context, lastBlockSeen uint64) uint64
- type EVMDownloaderMock_Download_Call
- func (_c *EVMDownloaderMock_Download_Call) Return() *EVMDownloaderMock_Download_Call
- func (_c *EVMDownloaderMock_Download_Call) Run(run func(ctx context.Context, fromBlock uint64, downloadedCh chan EVMBlock)) *EVMDownloaderMock_Download_Call
- func (_c *EVMDownloaderMock_Download_Call) RunAndReturn(run func(context.Context, uint64, chan EVMBlock)) *EVMDownloaderMock_Download_Call
- type EVMDownloaderMock_Expecter
- func (_e *EVMDownloaderMock_Expecter) Download(ctx interface{}, fromBlock interface{}, downloadedCh interface{}) *EVMDownloaderMock_Download_Call
- func (_e *EVMDownloaderMock_Expecter) GetBlockHeader(ctx interface{}, blockNum interface{}) *EVMDownloaderMock_GetBlockHeader_Call
- func (_e *EVMDownloaderMock_Expecter) GetEventsByBlockRange(ctx interface{}, fromBlock interface{}, toBlock interface{}) *EVMDownloaderMock_GetEventsByBlockRange_Call
- func (_e *EVMDownloaderMock_Expecter) GetLogs(ctx interface{}, fromBlock interface{}, toBlock interface{}) *EVMDownloaderMock_GetLogs_Call
- func (_e *EVMDownloaderMock_Expecter) WaitForNewBlocks(ctx interface{}, lastBlockSeen interface{}) *EVMDownloaderMock_WaitForNewBlocks_Call
- type EVMDownloaderMock_GetBlockHeader_Call
- func (_c *EVMDownloaderMock_GetBlockHeader_Call) Return(_a0 EVMBlockHeader, _a1 bool) *EVMDownloaderMock_GetBlockHeader_Call
- func (_c *EVMDownloaderMock_GetBlockHeader_Call) Run(run func(ctx context.Context, blockNum uint64)) *EVMDownloaderMock_GetBlockHeader_Call
- func (_c *EVMDownloaderMock_GetBlockHeader_Call) RunAndReturn(run func(context.Context, uint64) (EVMBlockHeader, bool)) *EVMDownloaderMock_GetBlockHeader_Call
- type EVMDownloaderMock_GetEventsByBlockRange_Call
- func (_c *EVMDownloaderMock_GetEventsByBlockRange_Call) Return(_a0 []EVMBlock) *EVMDownloaderMock_GetEventsByBlockRange_Call
- func (_c *EVMDownloaderMock_GetEventsByBlockRange_Call) Run(run func(ctx context.Context, fromBlock uint64, toBlock uint64)) *EVMDownloaderMock_GetEventsByBlockRange_Call
- func (_c *EVMDownloaderMock_GetEventsByBlockRange_Call) RunAndReturn(run func(context.Context, uint64, uint64) []EVMBlock) *EVMDownloaderMock_GetEventsByBlockRange_Call
- type EVMDownloaderMock_GetLogs_Call
- func (_c *EVMDownloaderMock_GetLogs_Call) Return(_a0 []types.Log) *EVMDownloaderMock_GetLogs_Call
- func (_c *EVMDownloaderMock_GetLogs_Call) Run(run func(ctx context.Context, fromBlock uint64, toBlock uint64)) *EVMDownloaderMock_GetLogs_Call
- func (_c *EVMDownloaderMock_GetLogs_Call) RunAndReturn(run func(context.Context, uint64, uint64) []types.Log) *EVMDownloaderMock_GetLogs_Call
- type EVMDownloaderMock_WaitForNewBlocks_Call
- func (_c *EVMDownloaderMock_WaitForNewBlocks_Call) Return(newLastBlock uint64) *EVMDownloaderMock_WaitForNewBlocks_Call
- func (_c *EVMDownloaderMock_WaitForNewBlocks_Call) Run(run func(ctx context.Context, lastBlockSeen uint64)) *EVMDownloaderMock_WaitForNewBlocks_Call
- func (_c *EVMDownloaderMock_WaitForNewBlocks_Call) RunAndReturn(run func(context.Context, uint64) uint64) *EVMDownloaderMock_WaitForNewBlocks_Call
- type EVMDriver
- type EthClienter
- type L2Mock
- func (_m *L2Mock) BlockByHash(ctx context.Context, hash common.Hash) (*types.Block, error)
- func (_m *L2Mock) BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)
- func (_m *L2Mock) BlockNumber(ctx context.Context) (uint64, error)
- func (_m *L2Mock) CallContract(ctx context.Context, call ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)
- func (_m *L2Mock) CodeAt(ctx context.Context, contract common.Address, blockNumber *big.Int) ([]byte, error)
- func (_m *L2Mock) EXPECT() *L2Mock_Expecter
- func (_m *L2Mock) EstimateGas(ctx context.Context, call ethereum.CallMsg) (uint64, error)
- func (_m *L2Mock) FilterLogs(ctx context.Context, q ethereum.FilterQuery) ([]types.Log, error)
- func (_m *L2Mock) HeaderByHash(ctx context.Context, hash common.Hash) (*types.Header, error)
- func (_m *L2Mock) HeaderByNumber(ctx context.Context, number *big.Int) (*types.Header, error)
- func (_m *L2Mock) PendingCodeAt(ctx context.Context, account common.Address) ([]byte, error)
- func (_m *L2Mock) PendingNonceAt(ctx context.Context, account common.Address) (uint64, error)
- func (_m *L2Mock) SendTransaction(ctx context.Context, tx *types.Transaction) error
- func (_m *L2Mock) SubscribeFilterLogs(ctx context.Context, q ethereum.FilterQuery, ch chan<- types.Log) (ethereum.Subscription, error)
- func (_m *L2Mock) SubscribeNewHead(ctx context.Context, ch chan<- *types.Header) (ethereum.Subscription, error)
- func (_m *L2Mock) SuggestGasPrice(ctx context.Context) (*big.Int, error)
- func (_m *L2Mock) SuggestGasTipCap(ctx context.Context) (*big.Int, error)
- func (_m *L2Mock) TransactionCount(ctx context.Context, blockHash common.Hash) (uint, error)
- func (_m *L2Mock) TransactionInBlock(ctx context.Context, blockHash common.Hash, index uint) (*types.Transaction, error)
- type L2Mock_BlockByHash_Call
- func (_c *L2Mock_BlockByHash_Call) Return(_a0 *types.Block, _a1 error) *L2Mock_BlockByHash_Call
- func (_c *L2Mock_BlockByHash_Call) Run(run func(ctx context.Context, hash common.Hash)) *L2Mock_BlockByHash_Call
- func (_c *L2Mock_BlockByHash_Call) RunAndReturn(run func(context.Context, common.Hash) (*types.Block, error)) *L2Mock_BlockByHash_Call
- type L2Mock_BlockByNumber_Call
- func (_c *L2Mock_BlockByNumber_Call) Return(_a0 *types.Block, _a1 error) *L2Mock_BlockByNumber_Call
- func (_c *L2Mock_BlockByNumber_Call) Run(run func(ctx context.Context, number *big.Int)) *L2Mock_BlockByNumber_Call
- func (_c *L2Mock_BlockByNumber_Call) RunAndReturn(run func(context.Context, *big.Int) (*types.Block, error)) *L2Mock_BlockByNumber_Call
- type L2Mock_BlockNumber_Call
- func (_c *L2Mock_BlockNumber_Call) Return(_a0 uint64, _a1 error) *L2Mock_BlockNumber_Call
- func (_c *L2Mock_BlockNumber_Call) Run(run func(ctx context.Context)) *L2Mock_BlockNumber_Call
- func (_c *L2Mock_BlockNumber_Call) RunAndReturn(run func(context.Context) (uint64, error)) *L2Mock_BlockNumber_Call
- type L2Mock_CallContract_Call
- func (_c *L2Mock_CallContract_Call) Return(_a0 []byte, _a1 error) *L2Mock_CallContract_Call
- func (_c *L2Mock_CallContract_Call) Run(run func(ctx context.Context, call ethereum.CallMsg, blockNumber *big.Int)) *L2Mock_CallContract_Call
- func (_c *L2Mock_CallContract_Call) RunAndReturn(run func(context.Context, ethereum.CallMsg, *big.Int) ([]byte, error)) *L2Mock_CallContract_Call
- type L2Mock_CodeAt_Call
- func (_c *L2Mock_CodeAt_Call) Return(_a0 []byte, _a1 error) *L2Mock_CodeAt_Call
- func (_c *L2Mock_CodeAt_Call) Run(run func(ctx context.Context, contract common.Address, blockNumber *big.Int)) *L2Mock_CodeAt_Call
- func (_c *L2Mock_CodeAt_Call) RunAndReturn(run func(context.Context, common.Address, *big.Int) ([]byte, error)) *L2Mock_CodeAt_Call
- type L2Mock_EstimateGas_Call
- func (_c *L2Mock_EstimateGas_Call) Return(_a0 uint64, _a1 error) *L2Mock_EstimateGas_Call
- func (_c *L2Mock_EstimateGas_Call) Run(run func(ctx context.Context, call ethereum.CallMsg)) *L2Mock_EstimateGas_Call
- func (_c *L2Mock_EstimateGas_Call) RunAndReturn(run func(context.Context, ethereum.CallMsg) (uint64, error)) *L2Mock_EstimateGas_Call
- type L2Mock_Expecter
- func (_e *L2Mock_Expecter) BlockByHash(ctx interface{}, hash interface{}) *L2Mock_BlockByHash_Call
- func (_e *L2Mock_Expecter) BlockByNumber(ctx interface{}, number interface{}) *L2Mock_BlockByNumber_Call
- func (_e *L2Mock_Expecter) BlockNumber(ctx interface{}) *L2Mock_BlockNumber_Call
- func (_e *L2Mock_Expecter) CallContract(ctx interface{}, call interface{}, blockNumber interface{}) *L2Mock_CallContract_Call
- func (_e *L2Mock_Expecter) CodeAt(ctx interface{}, contract interface{}, blockNumber interface{}) *L2Mock_CodeAt_Call
- func (_e *L2Mock_Expecter) EstimateGas(ctx interface{}, call interface{}) *L2Mock_EstimateGas_Call
- func (_e *L2Mock_Expecter) FilterLogs(ctx interface{}, q interface{}) *L2Mock_FilterLogs_Call
- func (_e *L2Mock_Expecter) HeaderByHash(ctx interface{}, hash interface{}) *L2Mock_HeaderByHash_Call
- func (_e *L2Mock_Expecter) HeaderByNumber(ctx interface{}, number interface{}) *L2Mock_HeaderByNumber_Call
- func (_e *L2Mock_Expecter) PendingCodeAt(ctx interface{}, account interface{}) *L2Mock_PendingCodeAt_Call
- func (_e *L2Mock_Expecter) PendingNonceAt(ctx interface{}, account interface{}) *L2Mock_PendingNonceAt_Call
- func (_e *L2Mock_Expecter) SendTransaction(ctx interface{}, tx interface{}) *L2Mock_SendTransaction_Call
- func (_e *L2Mock_Expecter) SubscribeFilterLogs(ctx interface{}, q interface{}, ch interface{}) *L2Mock_SubscribeFilterLogs_Call
- func (_e *L2Mock_Expecter) SubscribeNewHead(ctx interface{}, ch interface{}) *L2Mock_SubscribeNewHead_Call
- func (_e *L2Mock_Expecter) SuggestGasPrice(ctx interface{}) *L2Mock_SuggestGasPrice_Call
- func (_e *L2Mock_Expecter) SuggestGasTipCap(ctx interface{}) *L2Mock_SuggestGasTipCap_Call
- func (_e *L2Mock_Expecter) TransactionCount(ctx interface{}, blockHash interface{}) *L2Mock_TransactionCount_Call
- func (_e *L2Mock_Expecter) TransactionInBlock(ctx interface{}, blockHash interface{}, index interface{}) *L2Mock_TransactionInBlock_Call
- type L2Mock_FilterLogs_Call
- func (_c *L2Mock_FilterLogs_Call) Return(_a0 []types.Log, _a1 error) *L2Mock_FilterLogs_Call
- func (_c *L2Mock_FilterLogs_Call) Run(run func(ctx context.Context, q ethereum.FilterQuery)) *L2Mock_FilterLogs_Call
- func (_c *L2Mock_FilterLogs_Call) RunAndReturn(run func(context.Context, ethereum.FilterQuery) ([]types.Log, error)) *L2Mock_FilterLogs_Call
- type L2Mock_HeaderByHash_Call
- func (_c *L2Mock_HeaderByHash_Call) Return(_a0 *types.Header, _a1 error) *L2Mock_HeaderByHash_Call
- func (_c *L2Mock_HeaderByHash_Call) Run(run func(ctx context.Context, hash common.Hash)) *L2Mock_HeaderByHash_Call
- func (_c *L2Mock_HeaderByHash_Call) RunAndReturn(run func(context.Context, common.Hash) (*types.Header, error)) *L2Mock_HeaderByHash_Call
- type L2Mock_HeaderByNumber_Call
- func (_c *L2Mock_HeaderByNumber_Call) Return(_a0 *types.Header, _a1 error) *L2Mock_HeaderByNumber_Call
- func (_c *L2Mock_HeaderByNumber_Call) Run(run func(ctx context.Context, number *big.Int)) *L2Mock_HeaderByNumber_Call
- func (_c *L2Mock_HeaderByNumber_Call) RunAndReturn(run func(context.Context, *big.Int) (*types.Header, error)) *L2Mock_HeaderByNumber_Call
- type L2Mock_PendingCodeAt_Call
- func (_c *L2Mock_PendingCodeAt_Call) Return(_a0 []byte, _a1 error) *L2Mock_PendingCodeAt_Call
- func (_c *L2Mock_PendingCodeAt_Call) Run(run func(ctx context.Context, account common.Address)) *L2Mock_PendingCodeAt_Call
- func (_c *L2Mock_PendingCodeAt_Call) RunAndReturn(run func(context.Context, common.Address) ([]byte, error)) *L2Mock_PendingCodeAt_Call
- type L2Mock_PendingNonceAt_Call
- func (_c *L2Mock_PendingNonceAt_Call) Return(_a0 uint64, _a1 error) *L2Mock_PendingNonceAt_Call
- func (_c *L2Mock_PendingNonceAt_Call) Run(run func(ctx context.Context, account common.Address)) *L2Mock_PendingNonceAt_Call
- func (_c *L2Mock_PendingNonceAt_Call) RunAndReturn(run func(context.Context, common.Address) (uint64, error)) *L2Mock_PendingNonceAt_Call
- type L2Mock_SendTransaction_Call
- func (_c *L2Mock_SendTransaction_Call) Return(_a0 error) *L2Mock_SendTransaction_Call
- func (_c *L2Mock_SendTransaction_Call) Run(run func(ctx context.Context, tx *types.Transaction)) *L2Mock_SendTransaction_Call
- func (_c *L2Mock_SendTransaction_Call) RunAndReturn(run func(context.Context, *types.Transaction) error) *L2Mock_SendTransaction_Call
- type L2Mock_SubscribeFilterLogs_Call
- func (_c *L2Mock_SubscribeFilterLogs_Call) Return(_a0 ethereum.Subscription, _a1 error) *L2Mock_SubscribeFilterLogs_Call
- func (_c *L2Mock_SubscribeFilterLogs_Call) Run(run func(ctx context.Context, q ethereum.FilterQuery, ch chan<- types.Log)) *L2Mock_SubscribeFilterLogs_Call
- func (_c *L2Mock_SubscribeFilterLogs_Call) RunAndReturn(...) *L2Mock_SubscribeFilterLogs_Call
- type L2Mock_SubscribeNewHead_Call
- func (_c *L2Mock_SubscribeNewHead_Call) Return(_a0 ethereum.Subscription, _a1 error) *L2Mock_SubscribeNewHead_Call
- func (_c *L2Mock_SubscribeNewHead_Call) Run(run func(ctx context.Context, ch chan<- *types.Header)) *L2Mock_SubscribeNewHead_Call
- func (_c *L2Mock_SubscribeNewHead_Call) RunAndReturn(run func(context.Context, chan<- *types.Header) (ethereum.Subscription, error)) *L2Mock_SubscribeNewHead_Call
- type L2Mock_SuggestGasPrice_Call
- func (_c *L2Mock_SuggestGasPrice_Call) Return(_a0 *big.Int, _a1 error) *L2Mock_SuggestGasPrice_Call
- func (_c *L2Mock_SuggestGasPrice_Call) Run(run func(ctx context.Context)) *L2Mock_SuggestGasPrice_Call
- func (_c *L2Mock_SuggestGasPrice_Call) RunAndReturn(run func(context.Context) (*big.Int, error)) *L2Mock_SuggestGasPrice_Call
- type L2Mock_SuggestGasTipCap_Call
- func (_c *L2Mock_SuggestGasTipCap_Call) Return(_a0 *big.Int, _a1 error) *L2Mock_SuggestGasTipCap_Call
- func (_c *L2Mock_SuggestGasTipCap_Call) Run(run func(ctx context.Context)) *L2Mock_SuggestGasTipCap_Call
- func (_c *L2Mock_SuggestGasTipCap_Call) RunAndReturn(run func(context.Context) (*big.Int, error)) *L2Mock_SuggestGasTipCap_Call
- type L2Mock_TransactionCount_Call
- func (_c *L2Mock_TransactionCount_Call) Return(_a0 uint, _a1 error) *L2Mock_TransactionCount_Call
- func (_c *L2Mock_TransactionCount_Call) Run(run func(ctx context.Context, blockHash common.Hash)) *L2Mock_TransactionCount_Call
- func (_c *L2Mock_TransactionCount_Call) RunAndReturn(run func(context.Context, common.Hash) (uint, error)) *L2Mock_TransactionCount_Call
- type L2Mock_TransactionInBlock_Call
- func (_c *L2Mock_TransactionInBlock_Call) Return(_a0 *types.Transaction, _a1 error) *L2Mock_TransactionInBlock_Call
- func (_c *L2Mock_TransactionInBlock_Call) Run(run func(ctx context.Context, blockHash common.Hash, index uint)) *L2Mock_TransactionInBlock_Call
- func (_c *L2Mock_TransactionInBlock_Call) RunAndReturn(run func(context.Context, common.Hash, uint) (*types.Transaction, error)) *L2Mock_TransactionInBlock_Call
- type LogAppenderMap
- type ProcessorMock
- func (_m *ProcessorMock) EXPECT() *ProcessorMock_Expecter
- func (_m *ProcessorMock) GetLastProcessedBlock(ctx context.Context) (uint64, error)
- func (_m *ProcessorMock) ProcessBlock(ctx context.Context, block Block) error
- func (_m *ProcessorMock) Reorg(ctx context.Context, firstReorgedBlock uint64) error
- type ProcessorMock_Expecter
- func (_e *ProcessorMock_Expecter) GetLastProcessedBlock(ctx interface{}) *ProcessorMock_GetLastProcessedBlock_Call
- func (_e *ProcessorMock_Expecter) ProcessBlock(ctx interface{}, block interface{}) *ProcessorMock_ProcessBlock_Call
- func (_e *ProcessorMock_Expecter) Reorg(ctx interface{}, firstReorgedBlock interface{}) *ProcessorMock_Reorg_Call
- type ProcessorMock_GetLastProcessedBlock_Call
- func (_c *ProcessorMock_GetLastProcessedBlock_Call) Return(_a0 uint64, _a1 error) *ProcessorMock_GetLastProcessedBlock_Call
- func (_c *ProcessorMock_GetLastProcessedBlock_Call) Run(run func(ctx context.Context)) *ProcessorMock_GetLastProcessedBlock_Call
- func (_c *ProcessorMock_GetLastProcessedBlock_Call) RunAndReturn(run func(context.Context) (uint64, error)) *ProcessorMock_GetLastProcessedBlock_Call
- type ProcessorMock_ProcessBlock_Call
- func (_c *ProcessorMock_ProcessBlock_Call) Return(_a0 error) *ProcessorMock_ProcessBlock_Call
- func (_c *ProcessorMock_ProcessBlock_Call) Run(run func(ctx context.Context, block Block)) *ProcessorMock_ProcessBlock_Call
- func (_c *ProcessorMock_ProcessBlock_Call) RunAndReturn(run func(context.Context, Block) error) *ProcessorMock_ProcessBlock_Call
- type ProcessorMock_Reorg_Call
- func (_c *ProcessorMock_Reorg_Call) Return(_a0 error) *ProcessorMock_Reorg_Call
- func (_c *ProcessorMock_Reorg_Call) Run(run func(ctx context.Context, firstReorgedBlock uint64)) *ProcessorMock_Reorg_Call
- func (_c *ProcessorMock_Reorg_Call) RunAndReturn(run func(context.Context, uint64) error) *ProcessorMock_Reorg_Call
- type ReorgDetector
- type ReorgDetectorMock
- type ReorgDetectorMock_AddBlockToTrack_Call
- func (_c *ReorgDetectorMock_AddBlockToTrack_Call) Return(_a0 error) *ReorgDetectorMock_AddBlockToTrack_Call
- func (_c *ReorgDetectorMock_AddBlockToTrack_Call) Run(...) *ReorgDetectorMock_AddBlockToTrack_Call
- func (_c *ReorgDetectorMock_AddBlockToTrack_Call) RunAndReturn(run func(context.Context, string, uint64, common.Hash) error) *ReorgDetectorMock_AddBlockToTrack_Call
- type ReorgDetectorMock_Expecter
- type ReorgDetectorMock_Subscribe_Call
- func (_c *ReorgDetectorMock_Subscribe_Call) Return(_a0 *reorgdetector.Subscription, _a1 error) *ReorgDetectorMock_Subscribe_Call
- func (_c *ReorgDetectorMock_Subscribe_Call) Run(run func(id string)) *ReorgDetectorMock_Subscribe_Call
- func (_c *ReorgDetectorMock_Subscribe_Call) RunAndReturn(run func(string) (*reorgdetector.Subscription, error)) *ReorgDetectorMock_Subscribe_Call
- type RetryHandler
Constants ¶
const (
DefaultWaitPeriodBlockNotFound = time.Millisecond * 100
)
Variables ¶
var ErrInconsistentState = errors.New("state is inconsistent, try again later once the state is consolidated")
Functions ¶
Types ¶
type EVMBlock ¶
type EVMBlock struct { EVMBlockHeader Events []interface{} }
type EVMBlockHeader ¶
type EVMDownloader ¶
type EVMDownloader struct { EVMDownloaderInterface // contains filtered or unexported fields }
func NewEVMDownloader ¶
func NewEVMDownloader( syncerID string, ethClient EthClienter, syncBlockChunkSize uint64, blockFinalityType etherman.BlockNumberFinality, waitForNewBlocksPeriod time.Duration, appender LogAppenderMap, adressessToQuery []common.Address, rh *RetryHandler, ) (*EVMDownloader, error)
type EVMDownloaderImplementation ¶
type EVMDownloaderImplementation struct {
// contains filtered or unexported fields
}
func NewEVMDownloaderImplementation ¶
func NewEVMDownloaderImplementation( syncerID string, ethClient EthClienter, blockFinality *big.Int, waitForNewBlocksPeriod time.Duration, appender LogAppenderMap, topicsToQuery []common.Hash, adressessToQuery []common.Address, rh *RetryHandler, ) *EVMDownloaderImplementation
func (*EVMDownloaderImplementation) GetBlockHeader ¶
func (d *EVMDownloaderImplementation) GetBlockHeader(ctx context.Context, blockNum uint64) (EVMBlockHeader, bool)
func (*EVMDownloaderImplementation) GetEventsByBlockRange ¶
func (d *EVMDownloaderImplementation) GetEventsByBlockRange(ctx context.Context, fromBlock, toBlock uint64) []EVMBlock
func (*EVMDownloaderImplementation) WaitForNewBlocks ¶
func (d *EVMDownloaderImplementation) WaitForNewBlocks( ctx context.Context, lastBlockSeen uint64, ) (newLastBlock uint64)
type EVMDownloaderInterface ¶
type EVMDownloaderInterface interface { WaitForNewBlocks(ctx context.Context, lastBlockSeen uint64) (newLastBlock uint64) GetEventsByBlockRange(ctx context.Context, fromBlock, toBlock uint64) []EVMBlock GetLogs(ctx context.Context, fromBlock, toBlock uint64) []types.Log GetBlockHeader(ctx context.Context, blockNum uint64) (EVMBlockHeader, bool) }
type EVMDownloaderMock ¶
EVMDownloaderMock is an autogenerated mock type for the evmDownloaderFull type
func NewEVMDownloaderMock ¶
func NewEVMDownloaderMock(t interface { mock.TestingT Cleanup(func()) }) *EVMDownloaderMock
NewEVMDownloaderMock creates a new instance of EVMDownloaderMock. 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 (*EVMDownloaderMock) Download ¶
func (_m *EVMDownloaderMock) Download(ctx context.Context, fromBlock uint64, downloadedCh chan EVMBlock)
Download provides a mock function with given fields: ctx, fromBlock, downloadedCh
func (*EVMDownloaderMock) EXPECT ¶
func (_m *EVMDownloaderMock) EXPECT() *EVMDownloaderMock_Expecter
func (*EVMDownloaderMock) GetBlockHeader ¶
func (_m *EVMDownloaderMock) GetBlockHeader(ctx context.Context, blockNum uint64) (EVMBlockHeader, bool)
GetBlockHeader provides a mock function with given fields: ctx, blockNum
func (*EVMDownloaderMock) GetEventsByBlockRange ¶
func (_m *EVMDownloaderMock) GetEventsByBlockRange(ctx context.Context, fromBlock uint64, toBlock uint64) []EVMBlock
GetEventsByBlockRange provides a mock function with given fields: ctx, fromBlock, toBlock
func (*EVMDownloaderMock) GetLogs ¶
func (_m *EVMDownloaderMock) GetLogs(ctx context.Context, fromBlock uint64, toBlock uint64) []types.Log
GetLogs provides a mock function with given fields: ctx, fromBlock, toBlock
func (*EVMDownloaderMock) WaitForNewBlocks ¶
func (_m *EVMDownloaderMock) WaitForNewBlocks(ctx context.Context, lastBlockSeen uint64) uint64
WaitForNewBlocks provides a mock function with given fields: ctx, lastBlockSeen
type EVMDownloaderMock_Download_Call ¶
EVMDownloaderMock_Download_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Download'
func (*EVMDownloaderMock_Download_Call) Return ¶
func (_c *EVMDownloaderMock_Download_Call) Return() *EVMDownloaderMock_Download_Call
func (*EVMDownloaderMock_Download_Call) Run ¶
func (_c *EVMDownloaderMock_Download_Call) Run(run func(ctx context.Context, fromBlock uint64, downloadedCh chan EVMBlock)) *EVMDownloaderMock_Download_Call
func (*EVMDownloaderMock_Download_Call) RunAndReturn ¶
func (_c *EVMDownloaderMock_Download_Call) RunAndReturn(run func(context.Context, uint64, chan EVMBlock)) *EVMDownloaderMock_Download_Call
type EVMDownloaderMock_Expecter ¶
type EVMDownloaderMock_Expecter struct {
// contains filtered or unexported fields
}
func (*EVMDownloaderMock_Expecter) Download ¶
func (_e *EVMDownloaderMock_Expecter) Download(ctx interface{}, fromBlock interface{}, downloadedCh interface{}) *EVMDownloaderMock_Download_Call
Download is a helper method to define mock.On call
- ctx context.Context
- fromBlock uint64
- downloadedCh chan EVMBlock
func (*EVMDownloaderMock_Expecter) GetBlockHeader ¶
func (_e *EVMDownloaderMock_Expecter) GetBlockHeader(ctx interface{}, blockNum interface{}) *EVMDownloaderMock_GetBlockHeader_Call
GetBlockHeader is a helper method to define mock.On call
- ctx context.Context
- blockNum uint64
func (*EVMDownloaderMock_Expecter) GetEventsByBlockRange ¶
func (_e *EVMDownloaderMock_Expecter) GetEventsByBlockRange(ctx interface{}, fromBlock interface{}, toBlock interface{}) *EVMDownloaderMock_GetEventsByBlockRange_Call
GetEventsByBlockRange is a helper method to define mock.On call
- ctx context.Context
- fromBlock uint64
- toBlock uint64
func (*EVMDownloaderMock_Expecter) GetLogs ¶
func (_e *EVMDownloaderMock_Expecter) GetLogs(ctx interface{}, fromBlock interface{}, toBlock interface{}) *EVMDownloaderMock_GetLogs_Call
GetLogs is a helper method to define mock.On call
- ctx context.Context
- fromBlock uint64
- toBlock uint64
func (*EVMDownloaderMock_Expecter) WaitForNewBlocks ¶
func (_e *EVMDownloaderMock_Expecter) WaitForNewBlocks(ctx interface{}, lastBlockSeen interface{}) *EVMDownloaderMock_WaitForNewBlocks_Call
WaitForNewBlocks is a helper method to define mock.On call
- ctx context.Context
- lastBlockSeen uint64
type EVMDownloaderMock_GetBlockHeader_Call ¶
EVMDownloaderMock_GetBlockHeader_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetBlockHeader'
func (*EVMDownloaderMock_GetBlockHeader_Call) Return ¶
func (_c *EVMDownloaderMock_GetBlockHeader_Call) Return(_a0 EVMBlockHeader, _a1 bool) *EVMDownloaderMock_GetBlockHeader_Call
func (*EVMDownloaderMock_GetBlockHeader_Call) Run ¶
func (_c *EVMDownloaderMock_GetBlockHeader_Call) Run(run func(ctx context.Context, blockNum uint64)) *EVMDownloaderMock_GetBlockHeader_Call
func (*EVMDownloaderMock_GetBlockHeader_Call) RunAndReturn ¶
func (_c *EVMDownloaderMock_GetBlockHeader_Call) RunAndReturn(run func(context.Context, uint64) (EVMBlockHeader, bool)) *EVMDownloaderMock_GetBlockHeader_Call
type EVMDownloaderMock_GetEventsByBlockRange_Call ¶
EVMDownloaderMock_GetEventsByBlockRange_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetEventsByBlockRange'
func (*EVMDownloaderMock_GetEventsByBlockRange_Call) Return ¶
func (_c *EVMDownloaderMock_GetEventsByBlockRange_Call) Return(_a0 []EVMBlock) *EVMDownloaderMock_GetEventsByBlockRange_Call
func (*EVMDownloaderMock_GetEventsByBlockRange_Call) Run ¶
func (_c *EVMDownloaderMock_GetEventsByBlockRange_Call) Run(run func(ctx context.Context, fromBlock uint64, toBlock uint64)) *EVMDownloaderMock_GetEventsByBlockRange_Call
func (*EVMDownloaderMock_GetEventsByBlockRange_Call) RunAndReturn ¶
func (_c *EVMDownloaderMock_GetEventsByBlockRange_Call) RunAndReturn(run func(context.Context, uint64, uint64) []EVMBlock) *EVMDownloaderMock_GetEventsByBlockRange_Call
type EVMDownloaderMock_GetLogs_Call ¶
EVMDownloaderMock_GetLogs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLogs'
func (*EVMDownloaderMock_GetLogs_Call) Return ¶
func (_c *EVMDownloaderMock_GetLogs_Call) Return(_a0 []types.Log) *EVMDownloaderMock_GetLogs_Call
func (*EVMDownloaderMock_GetLogs_Call) Run ¶
func (_c *EVMDownloaderMock_GetLogs_Call) Run(run func(ctx context.Context, fromBlock uint64, toBlock uint64)) *EVMDownloaderMock_GetLogs_Call
func (*EVMDownloaderMock_GetLogs_Call) RunAndReturn ¶
func (_c *EVMDownloaderMock_GetLogs_Call) RunAndReturn(run func(context.Context, uint64, uint64) []types.Log) *EVMDownloaderMock_GetLogs_Call
type EVMDownloaderMock_WaitForNewBlocks_Call ¶
EVMDownloaderMock_WaitForNewBlocks_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WaitForNewBlocks'
func (*EVMDownloaderMock_WaitForNewBlocks_Call) Return ¶
func (_c *EVMDownloaderMock_WaitForNewBlocks_Call) Return(newLastBlock uint64) *EVMDownloaderMock_WaitForNewBlocks_Call
func (*EVMDownloaderMock_WaitForNewBlocks_Call) Run ¶
func (_c *EVMDownloaderMock_WaitForNewBlocks_Call) Run(run func(ctx context.Context, lastBlockSeen uint64)) *EVMDownloaderMock_WaitForNewBlocks_Call
func (*EVMDownloaderMock_WaitForNewBlocks_Call) RunAndReturn ¶
func (_c *EVMDownloaderMock_WaitForNewBlocks_Call) RunAndReturn(run func(context.Context, uint64) uint64) *EVMDownloaderMock_WaitForNewBlocks_Call
type EVMDriver ¶
type EVMDriver struct {
// contains filtered or unexported fields
}
func NewEVMDriver ¶
func NewEVMDriver( reorgDetector ReorgDetector, processor processorInterface, downloader downloader, reorgDetectorID string, downloadBufferSize int, rh *RetryHandler, ) (*EVMDriver, error)
type EthClienter ¶
type EthClienter interface { ethereum.LogFilterer ethereum.BlockNumberReader ethereum.ChainReader bind.ContractBackend }
type L2Mock ¶
L2Mock is an autogenerated mock type for the EthClienter type
func NewL2Mock ¶
NewL2Mock creates a new instance of L2Mock. 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 (*L2Mock) BlockByHash ¶
BlockByHash provides a mock function with given fields: ctx, hash
func (*L2Mock) BlockByNumber ¶
BlockByNumber provides a mock function with given fields: ctx, number
func (*L2Mock) BlockNumber ¶
BlockNumber provides a mock function with given fields: ctx
func (*L2Mock) CallContract ¶
func (_m *L2Mock) CallContract(ctx context.Context, call ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)
CallContract provides a mock function with given fields: ctx, call, blockNumber
func (*L2Mock) CodeAt ¶
func (_m *L2Mock) CodeAt(ctx context.Context, contract common.Address, blockNumber *big.Int) ([]byte, error)
CodeAt provides a mock function with given fields: ctx, contract, blockNumber
func (*L2Mock) EXPECT ¶
func (_m *L2Mock) EXPECT() *L2Mock_Expecter
func (*L2Mock) EstimateGas ¶
EstimateGas provides a mock function with given fields: ctx, call
func (*L2Mock) FilterLogs ¶
FilterLogs provides a mock function with given fields: ctx, q
func (*L2Mock) HeaderByHash ¶
HeaderByHash provides a mock function with given fields: ctx, hash
func (*L2Mock) HeaderByNumber ¶
HeaderByNumber provides a mock function with given fields: ctx, number
func (*L2Mock) PendingCodeAt ¶
PendingCodeAt provides a mock function with given fields: ctx, account
func (*L2Mock) PendingNonceAt ¶
PendingNonceAt provides a mock function with given fields: ctx, account
func (*L2Mock) SendTransaction ¶
SendTransaction provides a mock function with given fields: ctx, tx
func (*L2Mock) SubscribeFilterLogs ¶
func (_m *L2Mock) SubscribeFilterLogs(ctx context.Context, q ethereum.FilterQuery, ch chan<- types.Log) (ethereum.Subscription, error)
SubscribeFilterLogs provides a mock function with given fields: ctx, q, ch
func (*L2Mock) SubscribeNewHead ¶
func (_m *L2Mock) SubscribeNewHead(ctx context.Context, ch chan<- *types.Header) (ethereum.Subscription, error)
SubscribeNewHead provides a mock function with given fields: ctx, ch
func (*L2Mock) SuggestGasPrice ¶
SuggestGasPrice provides a mock function with given fields: ctx
func (*L2Mock) SuggestGasTipCap ¶
SuggestGasTipCap provides a mock function with given fields: ctx
func (*L2Mock) TransactionCount ¶
TransactionCount provides a mock function with given fields: ctx, blockHash
type L2Mock_BlockByHash_Call ¶
L2Mock_BlockByHash_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BlockByHash'
func (*L2Mock_BlockByHash_Call) Return ¶
func (_c *L2Mock_BlockByHash_Call) Return(_a0 *types.Block, _a1 error) *L2Mock_BlockByHash_Call
func (*L2Mock_BlockByHash_Call) Run ¶
func (_c *L2Mock_BlockByHash_Call) Run(run func(ctx context.Context, hash common.Hash)) *L2Mock_BlockByHash_Call
func (*L2Mock_BlockByHash_Call) RunAndReturn ¶
func (_c *L2Mock_BlockByHash_Call) RunAndReturn(run func(context.Context, common.Hash) (*types.Block, error)) *L2Mock_BlockByHash_Call
type L2Mock_BlockByNumber_Call ¶
L2Mock_BlockByNumber_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BlockByNumber'
func (*L2Mock_BlockByNumber_Call) Return ¶
func (_c *L2Mock_BlockByNumber_Call) Return(_a0 *types.Block, _a1 error) *L2Mock_BlockByNumber_Call
func (*L2Mock_BlockByNumber_Call) Run ¶
func (_c *L2Mock_BlockByNumber_Call) Run(run func(ctx context.Context, number *big.Int)) *L2Mock_BlockByNumber_Call
func (*L2Mock_BlockByNumber_Call) RunAndReturn ¶
func (_c *L2Mock_BlockByNumber_Call) RunAndReturn(run func(context.Context, *big.Int) (*types.Block, error)) *L2Mock_BlockByNumber_Call
type L2Mock_BlockNumber_Call ¶
L2Mock_BlockNumber_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BlockNumber'
func (*L2Mock_BlockNumber_Call) Return ¶
func (_c *L2Mock_BlockNumber_Call) Return(_a0 uint64, _a1 error) *L2Mock_BlockNumber_Call
func (*L2Mock_BlockNumber_Call) Run ¶
func (_c *L2Mock_BlockNumber_Call) Run(run func(ctx context.Context)) *L2Mock_BlockNumber_Call
func (*L2Mock_BlockNumber_Call) RunAndReturn ¶
func (_c *L2Mock_BlockNumber_Call) RunAndReturn(run func(context.Context) (uint64, error)) *L2Mock_BlockNumber_Call
type L2Mock_CallContract_Call ¶
L2Mock_CallContract_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CallContract'
func (*L2Mock_CallContract_Call) Return ¶
func (_c *L2Mock_CallContract_Call) Return(_a0 []byte, _a1 error) *L2Mock_CallContract_Call
func (*L2Mock_CallContract_Call) Run ¶
func (_c *L2Mock_CallContract_Call) Run(run func(ctx context.Context, call ethereum.CallMsg, blockNumber *big.Int)) *L2Mock_CallContract_Call
func (*L2Mock_CallContract_Call) RunAndReturn ¶
func (_c *L2Mock_CallContract_Call) RunAndReturn(run func(context.Context, ethereum.CallMsg, *big.Int) ([]byte, error)) *L2Mock_CallContract_Call
type L2Mock_CodeAt_Call ¶
L2Mock_CodeAt_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CodeAt'
func (*L2Mock_CodeAt_Call) Return ¶
func (_c *L2Mock_CodeAt_Call) Return(_a0 []byte, _a1 error) *L2Mock_CodeAt_Call
func (*L2Mock_CodeAt_Call) Run ¶
func (_c *L2Mock_CodeAt_Call) Run(run func(ctx context.Context, contract common.Address, blockNumber *big.Int)) *L2Mock_CodeAt_Call
func (*L2Mock_CodeAt_Call) RunAndReturn ¶
func (_c *L2Mock_CodeAt_Call) RunAndReturn(run func(context.Context, common.Address, *big.Int) ([]byte, error)) *L2Mock_CodeAt_Call
type L2Mock_EstimateGas_Call ¶
L2Mock_EstimateGas_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EstimateGas'
func (*L2Mock_EstimateGas_Call) Return ¶
func (_c *L2Mock_EstimateGas_Call) Return(_a0 uint64, _a1 error) *L2Mock_EstimateGas_Call
func (*L2Mock_EstimateGas_Call) Run ¶
func (_c *L2Mock_EstimateGas_Call) Run(run func(ctx context.Context, call ethereum.CallMsg)) *L2Mock_EstimateGas_Call
func (*L2Mock_EstimateGas_Call) RunAndReturn ¶
func (_c *L2Mock_EstimateGas_Call) RunAndReturn(run func(context.Context, ethereum.CallMsg) (uint64, error)) *L2Mock_EstimateGas_Call
type L2Mock_Expecter ¶
type L2Mock_Expecter struct {
// contains filtered or unexported fields
}
func (*L2Mock_Expecter) BlockByHash ¶
func (_e *L2Mock_Expecter) BlockByHash(ctx interface{}, hash interface{}) *L2Mock_BlockByHash_Call
BlockByHash is a helper method to define mock.On call
- ctx context.Context
- hash common.Hash
func (*L2Mock_Expecter) BlockByNumber ¶
func (_e *L2Mock_Expecter) BlockByNumber(ctx interface{}, number interface{}) *L2Mock_BlockByNumber_Call
BlockByNumber is a helper method to define mock.On call
- ctx context.Context
- number *big.Int
func (*L2Mock_Expecter) BlockNumber ¶
func (_e *L2Mock_Expecter) BlockNumber(ctx interface{}) *L2Mock_BlockNumber_Call
BlockNumber is a helper method to define mock.On call
- ctx context.Context
func (*L2Mock_Expecter) CallContract ¶
func (_e *L2Mock_Expecter) CallContract(ctx interface{}, call interface{}, blockNumber interface{}) *L2Mock_CallContract_Call
CallContract is a helper method to define mock.On call
- ctx context.Context
- call ethereum.CallMsg
- blockNumber *big.Int
func (*L2Mock_Expecter) CodeAt ¶
func (_e *L2Mock_Expecter) CodeAt(ctx interface{}, contract interface{}, blockNumber interface{}) *L2Mock_CodeAt_Call
CodeAt is a helper method to define mock.On call
- ctx context.Context
- contract common.Address
- blockNumber *big.Int
func (*L2Mock_Expecter) EstimateGas ¶
func (_e *L2Mock_Expecter) EstimateGas(ctx interface{}, call interface{}) *L2Mock_EstimateGas_Call
EstimateGas is a helper method to define mock.On call
- ctx context.Context
- call ethereum.CallMsg
func (*L2Mock_Expecter) FilterLogs ¶
func (_e *L2Mock_Expecter) FilterLogs(ctx interface{}, q interface{}) *L2Mock_FilterLogs_Call
FilterLogs is a helper method to define mock.On call
- ctx context.Context
- q ethereum.FilterQuery
func (*L2Mock_Expecter) HeaderByHash ¶
func (_e *L2Mock_Expecter) HeaderByHash(ctx interface{}, hash interface{}) *L2Mock_HeaderByHash_Call
HeaderByHash is a helper method to define mock.On call
- ctx context.Context
- hash common.Hash
func (*L2Mock_Expecter) HeaderByNumber ¶
func (_e *L2Mock_Expecter) HeaderByNumber(ctx interface{}, number interface{}) *L2Mock_HeaderByNumber_Call
HeaderByNumber is a helper method to define mock.On call
- ctx context.Context
- number *big.Int
func (*L2Mock_Expecter) PendingCodeAt ¶
func (_e *L2Mock_Expecter) PendingCodeAt(ctx interface{}, account interface{}) *L2Mock_PendingCodeAt_Call
PendingCodeAt is a helper method to define mock.On call
- ctx context.Context
- account common.Address
func (*L2Mock_Expecter) PendingNonceAt ¶
func (_e *L2Mock_Expecter) PendingNonceAt(ctx interface{}, account interface{}) *L2Mock_PendingNonceAt_Call
PendingNonceAt is a helper method to define mock.On call
- ctx context.Context
- account common.Address
func (*L2Mock_Expecter) SendTransaction ¶
func (_e *L2Mock_Expecter) SendTransaction(ctx interface{}, tx interface{}) *L2Mock_SendTransaction_Call
SendTransaction is a helper method to define mock.On call
- ctx context.Context
- tx *types.Transaction
func (*L2Mock_Expecter) SubscribeFilterLogs ¶
func (_e *L2Mock_Expecter) SubscribeFilterLogs(ctx interface{}, q interface{}, ch interface{}) *L2Mock_SubscribeFilterLogs_Call
SubscribeFilterLogs is a helper method to define mock.On call
- ctx context.Context
- q ethereum.FilterQuery
- ch chan<- types.Log
func (*L2Mock_Expecter) SubscribeNewHead ¶
func (_e *L2Mock_Expecter) SubscribeNewHead(ctx interface{}, ch interface{}) *L2Mock_SubscribeNewHead_Call
SubscribeNewHead is a helper method to define mock.On call
- ctx context.Context
- ch chan<- *types.Header
func (*L2Mock_Expecter) SuggestGasPrice ¶
func (_e *L2Mock_Expecter) SuggestGasPrice(ctx interface{}) *L2Mock_SuggestGasPrice_Call
SuggestGasPrice is a helper method to define mock.On call
- ctx context.Context
func (*L2Mock_Expecter) SuggestGasTipCap ¶
func (_e *L2Mock_Expecter) SuggestGasTipCap(ctx interface{}) *L2Mock_SuggestGasTipCap_Call
SuggestGasTipCap is a helper method to define mock.On call
- ctx context.Context
func (*L2Mock_Expecter) TransactionCount ¶
func (_e *L2Mock_Expecter) TransactionCount(ctx interface{}, blockHash interface{}) *L2Mock_TransactionCount_Call
TransactionCount is a helper method to define mock.On call
- ctx context.Context
- blockHash common.Hash
func (*L2Mock_Expecter) TransactionInBlock ¶
func (_e *L2Mock_Expecter) TransactionInBlock(ctx interface{}, blockHash interface{}, index interface{}) *L2Mock_TransactionInBlock_Call
TransactionInBlock is a helper method to define mock.On call
- ctx context.Context
- blockHash common.Hash
- index uint
type L2Mock_FilterLogs_Call ¶
L2Mock_FilterLogs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FilterLogs'
func (*L2Mock_FilterLogs_Call) Return ¶
func (_c *L2Mock_FilterLogs_Call) Return(_a0 []types.Log, _a1 error) *L2Mock_FilterLogs_Call
func (*L2Mock_FilterLogs_Call) Run ¶
func (_c *L2Mock_FilterLogs_Call) Run(run func(ctx context.Context, q ethereum.FilterQuery)) *L2Mock_FilterLogs_Call
func (*L2Mock_FilterLogs_Call) RunAndReturn ¶
func (_c *L2Mock_FilterLogs_Call) RunAndReturn(run func(context.Context, ethereum.FilterQuery) ([]types.Log, error)) *L2Mock_FilterLogs_Call
type L2Mock_HeaderByHash_Call ¶
L2Mock_HeaderByHash_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HeaderByHash'
func (*L2Mock_HeaderByHash_Call) Return ¶
func (_c *L2Mock_HeaderByHash_Call) Return(_a0 *types.Header, _a1 error) *L2Mock_HeaderByHash_Call
func (*L2Mock_HeaderByHash_Call) Run ¶
func (_c *L2Mock_HeaderByHash_Call) Run(run func(ctx context.Context, hash common.Hash)) *L2Mock_HeaderByHash_Call
func (*L2Mock_HeaderByHash_Call) RunAndReturn ¶
func (_c *L2Mock_HeaderByHash_Call) RunAndReturn(run func(context.Context, common.Hash) (*types.Header, error)) *L2Mock_HeaderByHash_Call
type L2Mock_HeaderByNumber_Call ¶
L2Mock_HeaderByNumber_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HeaderByNumber'
func (*L2Mock_HeaderByNumber_Call) Return ¶
func (_c *L2Mock_HeaderByNumber_Call) Return(_a0 *types.Header, _a1 error) *L2Mock_HeaderByNumber_Call
func (*L2Mock_HeaderByNumber_Call) Run ¶
func (_c *L2Mock_HeaderByNumber_Call) Run(run func(ctx context.Context, number *big.Int)) *L2Mock_HeaderByNumber_Call
func (*L2Mock_HeaderByNumber_Call) RunAndReturn ¶
func (_c *L2Mock_HeaderByNumber_Call) RunAndReturn(run func(context.Context, *big.Int) (*types.Header, error)) *L2Mock_HeaderByNumber_Call
type L2Mock_PendingCodeAt_Call ¶
L2Mock_PendingCodeAt_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PendingCodeAt'
func (*L2Mock_PendingCodeAt_Call) Return ¶
func (_c *L2Mock_PendingCodeAt_Call) Return(_a0 []byte, _a1 error) *L2Mock_PendingCodeAt_Call
func (*L2Mock_PendingCodeAt_Call) Run ¶
func (_c *L2Mock_PendingCodeAt_Call) Run(run func(ctx context.Context, account common.Address)) *L2Mock_PendingCodeAt_Call
func (*L2Mock_PendingCodeAt_Call) RunAndReturn ¶
func (_c *L2Mock_PendingCodeAt_Call) RunAndReturn(run func(context.Context, common.Address) ([]byte, error)) *L2Mock_PendingCodeAt_Call
type L2Mock_PendingNonceAt_Call ¶
L2Mock_PendingNonceAt_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PendingNonceAt'
func (*L2Mock_PendingNonceAt_Call) Return ¶
func (_c *L2Mock_PendingNonceAt_Call) Return(_a0 uint64, _a1 error) *L2Mock_PendingNonceAt_Call
func (*L2Mock_PendingNonceAt_Call) Run ¶
func (_c *L2Mock_PendingNonceAt_Call) Run(run func(ctx context.Context, account common.Address)) *L2Mock_PendingNonceAt_Call
func (*L2Mock_PendingNonceAt_Call) RunAndReturn ¶
func (_c *L2Mock_PendingNonceAt_Call) RunAndReturn(run func(context.Context, common.Address) (uint64, error)) *L2Mock_PendingNonceAt_Call
type L2Mock_SendTransaction_Call ¶
L2Mock_SendTransaction_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendTransaction'
func (*L2Mock_SendTransaction_Call) Return ¶
func (_c *L2Mock_SendTransaction_Call) Return(_a0 error) *L2Mock_SendTransaction_Call
func (*L2Mock_SendTransaction_Call) Run ¶
func (_c *L2Mock_SendTransaction_Call) Run(run func(ctx context.Context, tx *types.Transaction)) *L2Mock_SendTransaction_Call
func (*L2Mock_SendTransaction_Call) RunAndReturn ¶
func (_c *L2Mock_SendTransaction_Call) RunAndReturn(run func(context.Context, *types.Transaction) error) *L2Mock_SendTransaction_Call
type L2Mock_SubscribeFilterLogs_Call ¶
L2Mock_SubscribeFilterLogs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SubscribeFilterLogs'
func (*L2Mock_SubscribeFilterLogs_Call) Return ¶
func (_c *L2Mock_SubscribeFilterLogs_Call) Return(_a0 ethereum.Subscription, _a1 error) *L2Mock_SubscribeFilterLogs_Call
func (*L2Mock_SubscribeFilterLogs_Call) Run ¶
func (_c *L2Mock_SubscribeFilterLogs_Call) Run(run func(ctx context.Context, q ethereum.FilterQuery, ch chan<- types.Log)) *L2Mock_SubscribeFilterLogs_Call
func (*L2Mock_SubscribeFilterLogs_Call) RunAndReturn ¶
func (_c *L2Mock_SubscribeFilterLogs_Call) RunAndReturn(run func(context.Context, ethereum.FilterQuery, chan<- types.Log) (ethereum.Subscription, error)) *L2Mock_SubscribeFilterLogs_Call
type L2Mock_SubscribeNewHead_Call ¶
L2Mock_SubscribeNewHead_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SubscribeNewHead'
func (*L2Mock_SubscribeNewHead_Call) Return ¶
func (_c *L2Mock_SubscribeNewHead_Call) Return(_a0 ethereum.Subscription, _a1 error) *L2Mock_SubscribeNewHead_Call
func (*L2Mock_SubscribeNewHead_Call) Run ¶
func (_c *L2Mock_SubscribeNewHead_Call) Run(run func(ctx context.Context, ch chan<- *types.Header)) *L2Mock_SubscribeNewHead_Call
func (*L2Mock_SubscribeNewHead_Call) RunAndReturn ¶
func (_c *L2Mock_SubscribeNewHead_Call) RunAndReturn(run func(context.Context, chan<- *types.Header) (ethereum.Subscription, error)) *L2Mock_SubscribeNewHead_Call
type L2Mock_SuggestGasPrice_Call ¶
L2Mock_SuggestGasPrice_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SuggestGasPrice'
func (*L2Mock_SuggestGasPrice_Call) Return ¶
func (_c *L2Mock_SuggestGasPrice_Call) Return(_a0 *big.Int, _a1 error) *L2Mock_SuggestGasPrice_Call
func (*L2Mock_SuggestGasPrice_Call) Run ¶
func (_c *L2Mock_SuggestGasPrice_Call) Run(run func(ctx context.Context)) *L2Mock_SuggestGasPrice_Call
func (*L2Mock_SuggestGasPrice_Call) RunAndReturn ¶
func (_c *L2Mock_SuggestGasPrice_Call) RunAndReturn(run func(context.Context) (*big.Int, error)) *L2Mock_SuggestGasPrice_Call
type L2Mock_SuggestGasTipCap_Call ¶
L2Mock_SuggestGasTipCap_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SuggestGasTipCap'
func (*L2Mock_SuggestGasTipCap_Call) Return ¶
func (_c *L2Mock_SuggestGasTipCap_Call) Return(_a0 *big.Int, _a1 error) *L2Mock_SuggestGasTipCap_Call
func (*L2Mock_SuggestGasTipCap_Call) Run ¶
func (_c *L2Mock_SuggestGasTipCap_Call) Run(run func(ctx context.Context)) *L2Mock_SuggestGasTipCap_Call
func (*L2Mock_SuggestGasTipCap_Call) RunAndReturn ¶
func (_c *L2Mock_SuggestGasTipCap_Call) RunAndReturn(run func(context.Context) (*big.Int, error)) *L2Mock_SuggestGasTipCap_Call
type L2Mock_TransactionCount_Call ¶
L2Mock_TransactionCount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TransactionCount'
func (*L2Mock_TransactionCount_Call) Return ¶
func (_c *L2Mock_TransactionCount_Call) Return(_a0 uint, _a1 error) *L2Mock_TransactionCount_Call
func (*L2Mock_TransactionCount_Call) Run ¶
func (_c *L2Mock_TransactionCount_Call) Run(run func(ctx context.Context, blockHash common.Hash)) *L2Mock_TransactionCount_Call
func (*L2Mock_TransactionCount_Call) RunAndReturn ¶
func (_c *L2Mock_TransactionCount_Call) RunAndReturn(run func(context.Context, common.Hash) (uint, error)) *L2Mock_TransactionCount_Call
type L2Mock_TransactionInBlock_Call ¶
L2Mock_TransactionInBlock_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TransactionInBlock'
func (*L2Mock_TransactionInBlock_Call) Return ¶
func (_c *L2Mock_TransactionInBlock_Call) Return(_a0 *types.Transaction, _a1 error) *L2Mock_TransactionInBlock_Call
func (*L2Mock_TransactionInBlock_Call) Run ¶
func (_c *L2Mock_TransactionInBlock_Call) Run(run func(ctx context.Context, blockHash common.Hash, index uint)) *L2Mock_TransactionInBlock_Call
func (*L2Mock_TransactionInBlock_Call) RunAndReturn ¶
func (_c *L2Mock_TransactionInBlock_Call) RunAndReturn(run func(context.Context, common.Hash, uint) (*types.Transaction, error)) *L2Mock_TransactionInBlock_Call
type ProcessorMock ¶
ProcessorMock is an autogenerated mock type for the processorInterface type
func NewProcessorMock ¶
func NewProcessorMock(t interface { mock.TestingT Cleanup(func()) }) *ProcessorMock
NewProcessorMock creates a new instance of ProcessorMock. 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 (*ProcessorMock) EXPECT ¶
func (_m *ProcessorMock) EXPECT() *ProcessorMock_Expecter
func (*ProcessorMock) GetLastProcessedBlock ¶
func (_m *ProcessorMock) GetLastProcessedBlock(ctx context.Context) (uint64, error)
GetLastProcessedBlock provides a mock function with given fields: ctx
func (*ProcessorMock) ProcessBlock ¶
func (_m *ProcessorMock) ProcessBlock(ctx context.Context, block Block) error
ProcessBlock provides a mock function with given fields: ctx, block
type ProcessorMock_Expecter ¶
type ProcessorMock_Expecter struct {
// contains filtered or unexported fields
}
func (*ProcessorMock_Expecter) GetLastProcessedBlock ¶
func (_e *ProcessorMock_Expecter) GetLastProcessedBlock(ctx interface{}) *ProcessorMock_GetLastProcessedBlock_Call
GetLastProcessedBlock is a helper method to define mock.On call
- ctx context.Context
func (*ProcessorMock_Expecter) ProcessBlock ¶
func (_e *ProcessorMock_Expecter) ProcessBlock(ctx interface{}, block interface{}) *ProcessorMock_ProcessBlock_Call
ProcessBlock is a helper method to define mock.On call
- ctx context.Context
- block Block
func (*ProcessorMock_Expecter) Reorg ¶
func (_e *ProcessorMock_Expecter) Reorg(ctx interface{}, firstReorgedBlock interface{}) *ProcessorMock_Reorg_Call
Reorg is a helper method to define mock.On call
- ctx context.Context
- firstReorgedBlock uint64
type ProcessorMock_GetLastProcessedBlock_Call ¶
ProcessorMock_GetLastProcessedBlock_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLastProcessedBlock'
func (*ProcessorMock_GetLastProcessedBlock_Call) Return ¶
func (_c *ProcessorMock_GetLastProcessedBlock_Call) Return(_a0 uint64, _a1 error) *ProcessorMock_GetLastProcessedBlock_Call
func (*ProcessorMock_GetLastProcessedBlock_Call) Run ¶
func (_c *ProcessorMock_GetLastProcessedBlock_Call) Run(run func(ctx context.Context)) *ProcessorMock_GetLastProcessedBlock_Call
func (*ProcessorMock_GetLastProcessedBlock_Call) RunAndReturn ¶
func (_c *ProcessorMock_GetLastProcessedBlock_Call) RunAndReturn(run func(context.Context) (uint64, error)) *ProcessorMock_GetLastProcessedBlock_Call
type ProcessorMock_ProcessBlock_Call ¶
ProcessorMock_ProcessBlock_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ProcessBlock'
func (*ProcessorMock_ProcessBlock_Call) Return ¶
func (_c *ProcessorMock_ProcessBlock_Call) Return(_a0 error) *ProcessorMock_ProcessBlock_Call
func (*ProcessorMock_ProcessBlock_Call) Run ¶
func (_c *ProcessorMock_ProcessBlock_Call) Run(run func(ctx context.Context, block Block)) *ProcessorMock_ProcessBlock_Call
func (*ProcessorMock_ProcessBlock_Call) RunAndReturn ¶
func (_c *ProcessorMock_ProcessBlock_Call) RunAndReturn(run func(context.Context, Block) error) *ProcessorMock_ProcessBlock_Call
type ProcessorMock_Reorg_Call ¶
ProcessorMock_Reorg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Reorg'
func (*ProcessorMock_Reorg_Call) Return ¶
func (_c *ProcessorMock_Reorg_Call) Return(_a0 error) *ProcessorMock_Reorg_Call
func (*ProcessorMock_Reorg_Call) Run ¶
func (_c *ProcessorMock_Reorg_Call) Run(run func(ctx context.Context, firstReorgedBlock uint64)) *ProcessorMock_Reorg_Call
func (*ProcessorMock_Reorg_Call) RunAndReturn ¶
func (_c *ProcessorMock_Reorg_Call) RunAndReturn(run func(context.Context, uint64) error) *ProcessorMock_Reorg_Call
type ReorgDetector ¶
type ReorgDetectorMock ¶
ReorgDetectorMock is an autogenerated mock type for the ReorgDetector type
func NewReorgDetectorMock ¶
func NewReorgDetectorMock(t interface { mock.TestingT Cleanup(func()) }) *ReorgDetectorMock
NewReorgDetectorMock creates a new instance of ReorgDetectorMock. 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 (*ReorgDetectorMock) AddBlockToTrack ¶
func (_m *ReorgDetectorMock) AddBlockToTrack(ctx context.Context, id string, blockNum uint64, blockHash common.Hash) error
AddBlockToTrack provides a mock function with given fields: ctx, id, blockNum, blockHash
func (*ReorgDetectorMock) EXPECT ¶
func (_m *ReorgDetectorMock) EXPECT() *ReorgDetectorMock_Expecter
func (*ReorgDetectorMock) Subscribe ¶
func (_m *ReorgDetectorMock) Subscribe(id string) (*reorgdetector.Subscription, error)
Subscribe provides a mock function with given fields: id
type ReorgDetectorMock_AddBlockToTrack_Call ¶
ReorgDetectorMock_AddBlockToTrack_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddBlockToTrack'
func (*ReorgDetectorMock_AddBlockToTrack_Call) Return ¶
func (_c *ReorgDetectorMock_AddBlockToTrack_Call) Return(_a0 error) *ReorgDetectorMock_AddBlockToTrack_Call
func (*ReorgDetectorMock_AddBlockToTrack_Call) Run ¶
func (_c *ReorgDetectorMock_AddBlockToTrack_Call) Run(run func(ctx context.Context, id string, blockNum uint64, blockHash common.Hash)) *ReorgDetectorMock_AddBlockToTrack_Call
func (*ReorgDetectorMock_AddBlockToTrack_Call) RunAndReturn ¶
func (_c *ReorgDetectorMock_AddBlockToTrack_Call) RunAndReturn(run func(context.Context, string, uint64, common.Hash) error) *ReorgDetectorMock_AddBlockToTrack_Call
type ReorgDetectorMock_Expecter ¶
type ReorgDetectorMock_Expecter struct {
// contains filtered or unexported fields
}
func (*ReorgDetectorMock_Expecter) AddBlockToTrack ¶
func (_e *ReorgDetectorMock_Expecter) AddBlockToTrack(ctx interface{}, id interface{}, blockNum interface{}, blockHash interface{}) *ReorgDetectorMock_AddBlockToTrack_Call
AddBlockToTrack is a helper method to define mock.On call
- ctx context.Context
- id string
- blockNum uint64
- blockHash common.Hash
func (*ReorgDetectorMock_Expecter) Subscribe ¶
func (_e *ReorgDetectorMock_Expecter) Subscribe(id interface{}) *ReorgDetectorMock_Subscribe_Call
Subscribe is a helper method to define mock.On call
- id string
type ReorgDetectorMock_Subscribe_Call ¶
ReorgDetectorMock_Subscribe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Subscribe'
func (*ReorgDetectorMock_Subscribe_Call) Return ¶
func (_c *ReorgDetectorMock_Subscribe_Call) Return(_a0 *reorgdetector.Subscription, _a1 error) *ReorgDetectorMock_Subscribe_Call
func (*ReorgDetectorMock_Subscribe_Call) Run ¶
func (_c *ReorgDetectorMock_Subscribe_Call) Run(run func(id string)) *ReorgDetectorMock_Subscribe_Call
func (*ReorgDetectorMock_Subscribe_Call) RunAndReturn ¶
func (_c *ReorgDetectorMock_Subscribe_Call) RunAndReturn(run func(string) (*reorgdetector.Subscription, error)) *ReorgDetectorMock_Subscribe_Call
type RetryHandler ¶
func (*RetryHandler) Handle ¶
func (h *RetryHandler) Handle(funcName string, attempts int)