sync

Jan 13, 2026

Changes in this version

+ type AdaptEthClientToMultidownloader struct

+ func NewAdapterEthClientToMultidownloader(ethClient aggkittypes.BaseEthereumClienter) *AdaptEthClientToMultidownloader

+ func (a *AdaptEthClientToMultidownloader) BlockHeader(ctx context.Context, finality aggkittypes.BlockNumberFinality) (*aggkittypes.BlockHeader, error)

+ func (a *AdaptEthClientToMultidownloader) BlockNumber(ctx context.Context, finality aggkittypes.BlockNumberFinality) (uint64, error)

+ func (a *AdaptEthClientToMultidownloader) ChainID(ctx context.Context) (uint64, error)

+ func (a *AdaptEthClientToMultidownloader) EthClient() aggkittypes.BaseEthereumClienter

+ func (a *AdaptEthClientToMultidownloader) FilterLogs(ctx context.Context, query ethereum.FilterQuery) ([]types.Log, error)

+ func (a *AdaptEthClientToMultidownloader) HeaderByNumber(ctx context.Context, number *big.Int) (*aggkittypes.BlockHeader, error)

+ func (a *AdaptEthClientToMultidownloader) RegisterSyncer(data aggkittypes.SyncerConfig) error

+ func (a *AdaptEthClientToMultidownloader) Start(ctx context.Context) error

type Block

+ func (b Block) String() string

type EVMDownloader

+ func (d *EVMDownloader) SetStopOnFinalizedBlockReachedFlag()

type EVMDriver

+ func (d *EVMDriver) SubscribeToNewBlocks(subscriberName string) <-chan Block

Nov 6, 2025

Changes in this version

type ReorgDetector

+ GetTrackedBlockByBlockNumber func(id string, blockNumber uint64) (*reorgdetector.Header, error)

type ReorgDetectorMock

+ func (_m *ReorgDetectorMock) GetTrackedBlockByBlockNumber(id string, blockNumber uint64) (*reorgdetector.Header, error)

type ReorgDetectorMock_Expecter

+ func (_e *ReorgDetectorMock_Expecter) GetTrackedBlockByBlockNumber(id interface{}, blockNumber interface{}) *ReorgDetectorMock_GetTrackedBlockByBlockNumber_Call

+ type ReorgDetectorMock_GetTrackedBlockByBlockNumber_Call struct

+ func (_c *ReorgDetectorMock_GetTrackedBlockByBlockNumber_Call) Return(_a0 *reorgdetector.Header, _a1 error) *ReorgDetectorMock_GetTrackedBlockByBlockNumber_Call

+ func (_c *ReorgDetectorMock_GetTrackedBlockByBlockNumber_Call) Run(run func(id string, blockNumber uint64)) *ReorgDetectorMock_GetTrackedBlockByBlockNumber_Call

+ func (_c *ReorgDetectorMock_GetTrackedBlockByBlockNumber_Call) RunAndReturn(run func(string, uint64) (*reorgdetector.Header, error)) *ReorgDetectorMock_GetTrackedBlockByBlockNumber_Call

Oct 13, 2025

Changes in this version

+ const DefaultFilterLogsTimeout

Aug 8, 2025

Changes in this version

+ const MaxRetryCountBlockHashMismatch

+ type Downloader interface

+ Download func(ctx context.Context, fromBlock uint64, downloadedCh chan EVMBlock)

+ RuntimeData func(ctx context.Context) (RuntimeData, error)

type LogAppenderMap

+ func (m LogAppenderMap) GetTopics() []common.Hash

May 21, 2025

Changes in this version

+ type DownloaderMock struct

+ func NewDownloaderMock(t interface{ ... }) *DownloaderMock

+ func (_m *DownloaderMock) Download(ctx context.Context, fromBlock uint64, downloadedCh chan EVMBlock)

+ func (_m *DownloaderMock) EXPECT() *DownloaderMock_Expecter

+ func (_m *DownloaderMock) RuntimeData(ctx context.Context) (RuntimeData, error)

+ type DownloaderMock_Download_Call struct

+ func (_c *DownloaderMock_Download_Call) Return() *DownloaderMock_Download_Call

+ func (_c *DownloaderMock_Download_Call) Run(run func(ctx context.Context, fromBlock uint64, downloadedCh chan EVMBlock)) *DownloaderMock_Download_Call

+ func (_c *DownloaderMock_Download_Call) RunAndReturn(run func(context.Context, uint64, chan EVMBlock)) *DownloaderMock_Download_Call

+ type DownloaderMock_Expecter struct

+ func (_e *DownloaderMock_Expecter) Download(ctx interface{}, fromBlock interface{}, downloadedCh interface{}) *DownloaderMock_Download_Call

+ func (_e *DownloaderMock_Expecter) RuntimeData(ctx interface{}) *DownloaderMock_RuntimeData_Call

+ type DownloaderMock_RuntimeData_Call struct

+ func (_c *DownloaderMock_RuntimeData_Call) Return(_a0 RuntimeData, _a1 error) *DownloaderMock_RuntimeData_Call

+ func (_c *DownloaderMock_RuntimeData_Call) Run(run func(ctx context.Context)) *DownloaderMock_RuntimeData_Call

+ func (_c *DownloaderMock_RuntimeData_Call) RunAndReturn(run func(context.Context) (RuntimeData, error)) *DownloaderMock_RuntimeData_Call

+ type EVMDownloaderMock_ChainID_Call struct

+ func (_c *EVMDownloaderMock_ChainID_Call) Return(_a0 uint64, _a1 error) *EVMDownloaderMock_ChainID_Call

+ func (_c *EVMDownloaderMock_ChainID_Call) Run(run func(ctx context.Context)) *EVMDownloaderMock_ChainID_Call

+ func (_c *EVMDownloaderMock_ChainID_Call) RunAndReturn(run func(context.Context) (uint64, error)) *EVMDownloaderMock_ChainID_Call

type EVMDownloaderMock_Expecter

+ func (_e *EVMDownloaderMock_Expecter) ChainID(ctx interface{}) *EVMDownloaderMock_ChainID_Call

May 6, 2025

Changes in this version

+ var LogFatalf = log.Fatalf

type EVMDownloader

+ func (d *EVMDownloader) RuntimeData(ctx context.Context) (RuntimeData, error)

type EVMDownloaderImplementation

+ func (d *EVMDownloaderImplementation) ChainID(ctx context.Context) (uint64, error)

type EVMDownloaderInterface

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

type EVMDownloaderMock

+ func (_m *EVMDownloaderMock) ChainID(ctx context.Context) (uint64, error)

+ func (_m *EVMDownloaderMock) RuntimeData(ctx context.Context) (RuntimeData, error)

type EVMDownloaderMock_Expecter

+ func (_e *EVMDownloaderMock_Expecter) GetChainID(ctx interface{}) *EVMDownloaderMock_GetChainID_Call

+ func (_e *EVMDownloaderMock_Expecter) GetRuntimeData(ctx interface{}) *EVMDownloaderMock_GetRuntimeData_Call

+ type EVMDownloaderMock_GetChainID_Call struct

+ func (_c *EVMDownloaderMock_GetChainID_Call) Return(_a0 uint64, _a1 error) *EVMDownloaderMock_GetChainID_Call

+ func (_c *EVMDownloaderMock_GetChainID_Call) Run(run func(ctx context.Context)) *EVMDownloaderMock_GetChainID_Call

+ func (_c *EVMDownloaderMock_GetChainID_Call) RunAndReturn(run func(context.Context) (uint64, error)) *EVMDownloaderMock_GetChainID_Call

+ type EVMDownloaderMock_GetRuntimeData_Call struct

+ func (_c *EVMDownloaderMock_GetRuntimeData_Call) Return(_a0 RuntimeData, _a1 error) *EVMDownloaderMock_GetRuntimeData_Call

+ func (_c *EVMDownloaderMock_GetRuntimeData_Call) Run(run func(ctx context.Context)) *EVMDownloaderMock_GetRuntimeData_Call

+ func (_c *EVMDownloaderMock_GetRuntimeData_Call) RunAndReturn(run func(context.Context) (RuntimeData, error)) *EVMDownloaderMock_GetRuntimeData_Call

type EthClienter

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

type L2Mock

+ func (_m *L2Mock) ChainID(ctx context.Context) (*big.Int, error)

+ type L2Mock_ChainID_Call struct

+ func (_c *L2Mock_ChainID_Call) Return(_a0 *big.Int, _a1 error) *L2Mock_ChainID_Call

+ func (_c *L2Mock_ChainID_Call) Run(run func(ctx context.Context)) *L2Mock_ChainID_Call

+ func (_c *L2Mock_ChainID_Call) RunAndReturn(run func(context.Context) (*big.Int, error)) *L2Mock_ChainID_Call

type L2Mock_Expecter

+ func (_e *L2Mock_Expecter) ChainID(ctx interface{}) *L2Mock_ChainID_Call

type ProcessorMock

+ func (_m *ProcessorMock) GetCompatibilityData(ctx context.Context, tx db.Querier) (bool, RuntimeData, error)

+ func (_m *ProcessorMock) SetCompatibilityData(ctx context.Context, tx db.Querier, data RuntimeData) error

type ProcessorMock_Expecter

+ func (_e *ProcessorMock_Expecter) GetCompatibilityData(ctx interface{}, tx interface{}) *ProcessorMock_GetCompatibilityData_Call

+ func (_e *ProcessorMock_Expecter) SetCompatibilityData(ctx interface{}, tx interface{}, data interface{}) *ProcessorMock_SetCompatibilityData_Call

+ type ProcessorMock_GetCompatibilityData_Call struct

+ func (_c *ProcessorMock_GetCompatibilityData_Call) Return(_a0 bool, _a1 RuntimeData, _a2 error) *ProcessorMock_GetCompatibilityData_Call

+ func (_c *ProcessorMock_GetCompatibilityData_Call) Run(run func(ctx context.Context, tx db.Querier)) *ProcessorMock_GetCompatibilityData_Call

+ func (_c *ProcessorMock_GetCompatibilityData_Call) RunAndReturn(run func(context.Context, db.Querier) (bool, RuntimeData, error)) *ProcessorMock_GetCompatibilityData_Call

+ type ProcessorMock_SetCompatibilityData_Call struct

+ func (_c *ProcessorMock_SetCompatibilityData_Call) Return(_a0 error) *ProcessorMock_SetCompatibilityData_Call

+ func (_c *ProcessorMock_SetCompatibilityData_Call) Run(run func(ctx context.Context, tx db.Querier, data RuntimeData)) *ProcessorMock_SetCompatibilityData_Call

+ func (_c *ProcessorMock_SetCompatibilityData_Call) RunAndReturn(run func(context.Context, db.Querier, RuntimeData) error) *ProcessorMock_SetCompatibilityData_Call

+ type RuntimeData struct

+ Addresses []common.Address

+ ChainID uint64

+ func (r RuntimeData) IsCompatible(other RuntimeData) error

+ func (r RuntimeData) String() string

Mar 14, 2025

Changes in this version

type EthClienter

+ FilterLogs func(ctx context.Context, q ethereum.FilterQuery) ([]types.Log, error)

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

Feb 11, 2025

Changes in this version

type Block

+ Hash common.Hash

type EVMBlock

+ IsFinalizedBlock bool

+ type EVMBlocks []*EVMBlock

+ func (e EVMBlocks) Len() int

type EVMDownloaderImplementation

+ func (d *EVMDownloaderImplementation) GetLastFinalizedBlock(ctx context.Context) (*types.Header, error)

type EVMDownloaderInterface

+ GetLastFinalizedBlock func(ctx context.Context) (*types.Header, error)

type EVMDownloaderMock

+ func (_m *EVMDownloaderMock) GetLastFinalizedBlock(ctx context.Context) (*types.Header, error)

type EVMDownloaderMock_Expecter

+ func (_e *EVMDownloaderMock_Expecter) GetLastFinalizedBlock(ctx interface{}) *EVMDownloaderMock_GetLastFinalizedBlock_Call

+ type EVMDownloaderMock_GetLastFinalizedBlock_Call struct

+ func (_c *EVMDownloaderMock_GetLastFinalizedBlock_Call) Return(_a0 *types.Header, _a1 error) *EVMDownloaderMock_GetLastFinalizedBlock_Call

+ func (_c *EVMDownloaderMock_GetLastFinalizedBlock_Call) Run(run func(ctx context.Context)) *EVMDownloaderMock_GetLastFinalizedBlock_Call

+ func (_c *EVMDownloaderMock_GetLastFinalizedBlock_Call) RunAndReturn(run func(context.Context) (*types.Header, error)) *EVMDownloaderMock_GetLastFinalizedBlock_Call

type ReorgDetector

+ GetFinalizedBlockType func() etherman.BlockNumberFinality

+ String func() string

type ReorgDetectorMock

+ func (_m *ReorgDetectorMock) GetFinalizedBlockType() etherman.BlockNumberFinality

+ func (_m *ReorgDetectorMock) String() string

type ReorgDetectorMock_Expecter

+ func (_e *ReorgDetectorMock_Expecter) GetFinalizedBlockType() *ReorgDetectorMock_GetFinalizedBlockType_Call

+ func (_e *ReorgDetectorMock_Expecter) String() *ReorgDetectorMock_String_Call

+ type ReorgDetectorMock_GetFinalizedBlockType_Call struct

+ func (_c *ReorgDetectorMock_GetFinalizedBlockType_Call) Return(_a0 etherman.BlockNumberFinality) *ReorgDetectorMock_GetFinalizedBlockType_Call

+ func (_c *ReorgDetectorMock_GetFinalizedBlockType_Call) Run(run func()) *ReorgDetectorMock_GetFinalizedBlockType_Call

+ func (_c *ReorgDetectorMock_GetFinalizedBlockType_Call) RunAndReturn(run func() etherman.BlockNumberFinality) *ReorgDetectorMock_GetFinalizedBlockType_Call

+ type ReorgDetectorMock_String_Call struct

+ func (_c *ReorgDetectorMock_String_Call) Return(_a0 string) *ReorgDetectorMock_String_Call

+ func (_c *ReorgDetectorMock_String_Call) Run(run func()) *ReorgDetectorMock_String_Call

+ func (_c *ReorgDetectorMock_String_Call) RunAndReturn(run func() string) *ReorgDetectorMock_String_Call

Jan 21, 2025

Changes in this version

+ const DefaultWaitPeriodBlockNotFound

+ var ErrInconsistentState = errors.New("state is inconsistent, try again later once the state is consolidated")

+ func UnhaltIfAffectedRows(halted *bool, haltedReason *string, mu *sync.RWMutex, rowsAffected int64)

+ type Block struct

+ Events []interface{}

+ Num uint64

+ type EVMBlock struct

+ Events []interface{}

+ type EVMBlockHeader struct

+ Hash common.Hash

+ Num uint64

+ ParentHash common.Hash

+ Timestamp uint64

+ type EVMDownloader struct

+ func NewEVMDownloader(syncerID string, ethClient EthClienter, syncBlockChunkSize uint64, ...) (*EVMDownloader, error)

+ func (d *EVMDownloader) Download(ctx context.Context, fromBlock uint64, downloadedCh chan EVMBlock)

+ type EVMDownloaderImplementation struct

+ func NewEVMDownloaderImplementation(syncerID string, ethClient EthClienter, blockFinality *big.Int, ...) *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 interface

+ GetBlockHeader func(ctx context.Context, blockNum uint64) (EVMBlockHeader, bool)

+ GetEventsByBlockRange func(ctx context.Context, fromBlock, toBlock uint64) []EVMBlock

+ GetLogs func(ctx context.Context, fromBlock, toBlock uint64) []types.Log

+ WaitForNewBlocks func(ctx context.Context, lastBlockSeen uint64) (newLastBlock uint64)

+ type EVMDownloaderMock struct

+ func NewEVMDownloaderMock(t interface{ ... }) *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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ func NewEVMDriver(reorgDetector ReorgDetector, processor processorInterface, ...) (*EVMDriver, error)

+ func (d *EVMDriver) Sync(ctx context.Context)

+ type EthClienter interface

+ type L2Mock struct

+ func NewL2Mock(t interface{ ... }) *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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 map[common.Hash]func(b *EVMBlock, l types.Log) error

+ type ProcessorMock struct

+ func NewProcessorMock(t interface{ ... }) *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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 interface

+ AddBlockToTrack func(ctx context.Context, id string, blockNum uint64, blockHash common.Hash) error

+ Subscribe func(id string) (*reorgdetector.Subscription, error)

+ type ReorgDetectorMock struct

+ func NewReorgDetectorMock(t interface{ ... }) *ReorgDetectorMock

+ func (_m *ReorgDetectorMock) AddBlockToTrack(ctx context.Context, id string, blockNum uint64, blockHash common.Hash) error

+ func (_m *ReorgDetectorMock) EXPECT() *ReorgDetectorMock_Expecter

+ func (_m *ReorgDetectorMock) Subscribe(id string) (*reorgdetector.Subscription, error)

+ type ReorgDetectorMock_AddBlockToTrack_Call struct

+ 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 struct

+ func (_e *ReorgDetectorMock_Expecter) AddBlockToTrack(ctx interface{}, id interface{}, blockNum interface{}, blockHash interface{}) *ReorgDetectorMock_AddBlockToTrack_Call

+ func (_e *ReorgDetectorMock_Expecter) Subscribe(id interface{}) *ReorgDetectorMock_Subscribe_Call

+ type ReorgDetectorMock_Subscribe_Call struct

+ 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 struct

+ MaxRetryAttemptsAfterError int

+ RetryAfterErrorPeriod time.Duration

+ func (h *RetryHandler) Handle(funcName string, attempts int)