sync

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 21, 2025 License: AGPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DefaultWaitPeriodBlockNotFound = time.Millisecond * 100
)

Variables

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

Functions

func UnhaltIfAffectedRows

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

Types

type Block

type Block struct {
	Num    uint64
	Events []interface{}
}

type EVMBlock

type EVMBlock struct {
	EVMBlockHeader
	Events []interface{}
}

type EVMBlockHeader

type EVMBlockHeader struct {
	Num        uint64
	Hash       common.Hash
	ParentHash common.Hash
	Timestamp  uint64
}

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)

func (*EVMDownloader) Download

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

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) GetLogs

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

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

type EVMDownloaderMock struct {
	mock.Mock
}

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 (*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

type EVMDownloaderMock_Download_Call struct {
	*mock.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 (*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

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

type EVMDownloaderMock_GetBlockHeader_Call struct {
	*mock.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 (*EVMDownloaderMock_GetBlockHeader_Call) Run

func (*EVMDownloaderMock_GetBlockHeader_Call) RunAndReturn

type EVMDownloaderMock_GetEventsByBlockRange_Call

type EVMDownloaderMock_GetEventsByBlockRange_Call struct {
	*mock.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 (*EVMDownloaderMock_GetEventsByBlockRange_Call) Run

func (*EVMDownloaderMock_GetEventsByBlockRange_Call) RunAndReturn

type EVMDownloaderMock_GetLogs_Call

type EVMDownloaderMock_GetLogs_Call struct {
	*mock.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 (*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

type EVMDownloaderMock_WaitForNewBlocks_Call

type EVMDownloaderMock_WaitForNewBlocks_Call struct {
	*mock.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 (*EVMDownloaderMock_WaitForNewBlocks_Call) Run

func (*EVMDownloaderMock_WaitForNewBlocks_Call) RunAndReturn

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)

func (*EVMDriver) Sync

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

type EthClienter

type EthClienter interface {
	ethereum.LogFilterer
	ethereum.BlockNumberReader
	ethereum.ChainReader
	bind.ContractBackend
}

type L2Mock

type L2Mock struct {
	mock.Mock
}

L2Mock is an autogenerated mock type for the EthClienter type

func NewL2Mock

func NewL2Mock(t interface {
	mock.TestingT
	Cleanup(func())
}) *L2Mock

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

func (_m *L2Mock) BlockByHash(ctx context.Context, hash common.Hash) (*types.Block, error)

BlockByHash provides a mock function with given fields: ctx, hash

func (*L2Mock) BlockByNumber

func (_m *L2Mock) BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)

BlockByNumber provides a mock function with given fields: ctx, number

func (*L2Mock) BlockNumber

func (_m *L2Mock) BlockNumber(ctx context.Context) (uint64, error)

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

func (_m *L2Mock) EstimateGas(ctx context.Context, call ethereum.CallMsg) (uint64, error)

EstimateGas provides a mock function with given fields: ctx, call

func (*L2Mock) FilterLogs

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

FilterLogs provides a mock function with given fields: ctx, q

func (*L2Mock) HeaderByHash

func (_m *L2Mock) HeaderByHash(ctx context.Context, hash common.Hash) (*types.Header, error)

HeaderByHash provides a mock function with given fields: ctx, hash

func (*L2Mock) HeaderByNumber

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

HeaderByNumber provides a mock function with given fields: ctx, number

func (*L2Mock) PendingCodeAt

func (_m *L2Mock) PendingCodeAt(ctx context.Context, account common.Address) ([]byte, error)

PendingCodeAt provides a mock function with given fields: ctx, account

func (*L2Mock) PendingNonceAt

func (_m *L2Mock) PendingNonceAt(ctx context.Context, account common.Address) (uint64, error)

PendingNonceAt provides a mock function with given fields: ctx, account

func (*L2Mock) SendTransaction

func (_m *L2Mock) SendTransaction(ctx context.Context, tx *types.Transaction) error

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

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

SuggestGasPrice provides a mock function with given fields: ctx

func (*L2Mock) SuggestGasTipCap

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

SuggestGasTipCap provides a mock function with given fields: ctx

func (*L2Mock) TransactionCount

func (_m *L2Mock) TransactionCount(ctx context.Context, blockHash common.Hash) (uint, error)

TransactionCount provides a mock function with given fields: ctx, blockHash

func (*L2Mock) TransactionInBlock

func (_m *L2Mock) TransactionInBlock(ctx context.Context, blockHash common.Hash, index uint) (*types.Transaction, error)

TransactionInBlock provides a mock function with given fields: ctx, blockHash, index

type L2Mock_BlockByHash_Call

type L2Mock_BlockByHash_Call struct {
	*mock.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 (*L2Mock_BlockByHash_Call) Run

func (*L2Mock_BlockByHash_Call) RunAndReturn

type L2Mock_BlockByNumber_Call

type L2Mock_BlockByNumber_Call struct {
	*mock.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 (*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

type L2Mock_BlockNumber_Call

type L2Mock_BlockNumber_Call struct {
	*mock.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 (*L2Mock_BlockNumber_Call) Run

func (*L2Mock_BlockNumber_Call) RunAndReturn

type L2Mock_CallContract_Call

type L2Mock_CallContract_Call struct {
	*mock.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 (*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

type L2Mock_CodeAt_Call

type L2Mock_CodeAt_Call struct {
	*mock.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

type L2Mock_EstimateGas_Call struct {
	*mock.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 (*L2Mock_EstimateGas_Call) Run

func (*L2Mock_EstimateGas_Call) RunAndReturn

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

type L2Mock_FilterLogs_Call struct {
	*mock.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 (*L2Mock_FilterLogs_Call) Run

func (*L2Mock_FilterLogs_Call) RunAndReturn

type L2Mock_HeaderByHash_Call

type L2Mock_HeaderByHash_Call struct {
	*mock.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 (*L2Mock_HeaderByHash_Call) Run

func (*L2Mock_HeaderByHash_Call) RunAndReturn

type L2Mock_HeaderByNumber_Call

type L2Mock_HeaderByNumber_Call struct {
	*mock.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 (*L2Mock_HeaderByNumber_Call) Run

func (*L2Mock_HeaderByNumber_Call) RunAndReturn

type L2Mock_PendingCodeAt_Call

type L2Mock_PendingCodeAt_Call struct {
	*mock.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 (*L2Mock_PendingCodeAt_Call) Run

func (*L2Mock_PendingCodeAt_Call) RunAndReturn

type L2Mock_PendingNonceAt_Call

type L2Mock_PendingNonceAt_Call struct {
	*mock.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 (*L2Mock_PendingNonceAt_Call) Run

func (*L2Mock_PendingNonceAt_Call) RunAndReturn

type L2Mock_SendTransaction_Call

type L2Mock_SendTransaction_Call struct {
	*mock.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 (*L2Mock_SendTransaction_Call) Run

func (*L2Mock_SendTransaction_Call) RunAndReturn

type L2Mock_SubscribeFilterLogs_Call

type L2Mock_SubscribeFilterLogs_Call struct {
	*mock.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 (*L2Mock_SubscribeFilterLogs_Call) Run

func (*L2Mock_SubscribeFilterLogs_Call) RunAndReturn

type L2Mock_SubscribeNewHead_Call

type L2Mock_SubscribeNewHead_Call struct {
	*mock.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 (*L2Mock_SubscribeNewHead_Call) Run

func (*L2Mock_SubscribeNewHead_Call) RunAndReturn

type L2Mock_SuggestGasPrice_Call

type L2Mock_SuggestGasPrice_Call struct {
	*mock.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 (*L2Mock_SuggestGasPrice_Call) Run

func (*L2Mock_SuggestGasPrice_Call) RunAndReturn

type L2Mock_SuggestGasTipCap_Call

type L2Mock_SuggestGasTipCap_Call struct {
	*mock.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 (*L2Mock_SuggestGasTipCap_Call) Run

func (*L2Mock_SuggestGasTipCap_Call) RunAndReturn

type L2Mock_TransactionCount_Call

type L2Mock_TransactionCount_Call struct {
	*mock.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 (*L2Mock_TransactionCount_Call) Run

func (*L2Mock_TransactionCount_Call) RunAndReturn

type L2Mock_TransactionInBlock_Call

type L2Mock_TransactionInBlock_Call struct {
	*mock.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 (*L2Mock_TransactionInBlock_Call) Run

func (*L2Mock_TransactionInBlock_Call) RunAndReturn

type LogAppenderMap

type LogAppenderMap map[common.Hash]func(b *EVMBlock, l types.Log) error

type ProcessorMock

type ProcessorMock struct {
	mock.Mock
}

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

func (*ProcessorMock) Reorg

func (_m *ProcessorMock) Reorg(ctx context.Context, firstReorgedBlock uint64) error

Reorg provides a mock function with given fields: ctx, firstReorgedBlock

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

type ProcessorMock_GetLastProcessedBlock_Call struct {
	*mock.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 (*ProcessorMock_GetLastProcessedBlock_Call) Run

func (*ProcessorMock_GetLastProcessedBlock_Call) RunAndReturn

type ProcessorMock_ProcessBlock_Call

type ProcessorMock_ProcessBlock_Call struct {
	*mock.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 (*ProcessorMock_ProcessBlock_Call) Run

func (*ProcessorMock_ProcessBlock_Call) RunAndReturn

type ProcessorMock_Reorg_Call

type ProcessorMock_Reorg_Call struct {
	*mock.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 (*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

type ReorgDetector

type ReorgDetector interface {
	Subscribe(id string) (*reorgdetector.Subscription, error)
	AddBlockToTrack(ctx context.Context, id string, blockNum uint64, blockHash common.Hash) error
}

type ReorgDetectorMock

type ReorgDetectorMock struct {
	mock.Mock
}

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 (*ReorgDetectorMock) Subscribe

Subscribe provides a mock function with given fields: id

type ReorgDetectorMock_AddBlockToTrack_Call

type ReorgDetectorMock_AddBlockToTrack_Call struct {
	*mock.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 (*ReorgDetectorMock_AddBlockToTrack_Call) Run

func (*ReorgDetectorMock_AddBlockToTrack_Call) RunAndReturn

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

type ReorgDetectorMock_Subscribe_Call struct {
	*mock.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 (*ReorgDetectorMock_Subscribe_Call) Run

func (*ReorgDetectorMock_Subscribe_Call) RunAndReturn

type RetryHandler

type RetryHandler struct {
	RetryAfterErrorPeriod      time.Duration
	MaxRetryAttemptsAfterError int
}

func (*RetryHandler) Handle

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL