Documentation
¶
Index ¶
- type DownloaderInterface
- type DownloaderInterface_ChainID_Call
- func (_c *DownloaderInterface_ChainID_Call) Return(_a0 uint64, _a1 error) *DownloaderInterface_ChainID_Call
- func (_c *DownloaderInterface_ChainID_Call) Run(run func(ctx context.Context)) *DownloaderInterface_ChainID_Call
- func (_c *DownloaderInterface_ChainID_Call) RunAndReturn(run func(context.Context) (uint64, error)) *DownloaderInterface_ChainID_Call
- type DownloaderInterface_DownloadNextBlocks_Call
- func (_c *DownloaderInterface_DownloadNextBlocks_Call) Return(_a0 *types.DownloadResult, _a1 error) *DownloaderInterface_DownloadNextBlocks_Call
- func (_c *DownloaderInterface_DownloadNextBlocks_Call) Run(run func(ctx context.Context, fromBlockHeader *aggkittypes.BlockHeader, ...)) *DownloaderInterface_DownloadNextBlocks_Call
- func (_c *DownloaderInterface_DownloadNextBlocks_Call) RunAndReturn(...) *DownloaderInterface_DownloadNextBlocks_Call
- type DownloaderInterface_Expecter
- type MultidownloaderInterface
- func (_m *MultidownloaderInterface) ChainID(ctx context.Context) (uint64, error)
- func (_m *MultidownloaderInterface) CheckValidBlock(ctx context.Context, blockNumber uint64, blockHash common.Hash) (bool, uint64, error)
- func (_m *MultidownloaderInterface) EXPECT() *MultidownloaderInterface_Expecter
- func (_m *MultidownloaderInterface) Finality() aggkittypes.BlockNumberFinality
- func (_m *MultidownloaderInterface) GetReorgedDataByReorgID(ctx context.Context, reorgID uint64) (*multidownloadertypes.ReorgData, error)
- func (_m *MultidownloaderInterface) HeaderByNumber(ctx context.Context, number *aggkittypes.BlockNumberFinality) (*aggkittypes.BlockHeader, error)
- func (_m *MultidownloaderInterface) IsAvailable(query multidownloadertypes.LogQuery) bool
- func (_m *MultidownloaderInterface) IsPartiallyAvailable(query multidownloadertypes.LogQuery) (bool, *multidownloadertypes.LogQuery)
- func (_m *MultidownloaderInterface) LogQuery(ctx context.Context, query multidownloadertypes.LogQuery) (multidownloadertypes.LogQueryResponse, error)
- func (_m *MultidownloaderInterface) StorageHeaderByNumber(ctx context.Context, number *aggkittypes.BlockNumberFinality) (*aggkittypes.BlockHeader, multidownloadertypes.FinalizedType, error)
- type MultidownloaderInterface_ChainID_Call
- func (_c *MultidownloaderInterface_ChainID_Call) Return(_a0 uint64, _a1 error) *MultidownloaderInterface_ChainID_Call
- func (_c *MultidownloaderInterface_ChainID_Call) Run(run func(ctx context.Context)) *MultidownloaderInterface_ChainID_Call
- func (_c *MultidownloaderInterface_ChainID_Call) RunAndReturn(run func(context.Context) (uint64, error)) *MultidownloaderInterface_ChainID_Call
- type MultidownloaderInterface_CheckValidBlock_Call
- func (_c *MultidownloaderInterface_CheckValidBlock_Call) Return(_a0 bool, _a1 uint64, _a2 error) *MultidownloaderInterface_CheckValidBlock_Call
- func (_c *MultidownloaderInterface_CheckValidBlock_Call) Run(run func(ctx context.Context, blockNumber uint64, blockHash common.Hash)) *MultidownloaderInterface_CheckValidBlock_Call
- func (_c *MultidownloaderInterface_CheckValidBlock_Call) RunAndReturn(run func(context.Context, uint64, common.Hash) (bool, uint64, error)) *MultidownloaderInterface_CheckValidBlock_Call
- type MultidownloaderInterface_Expecter
- func (_e *MultidownloaderInterface_Expecter) ChainID(ctx interface{}) *MultidownloaderInterface_ChainID_Call
- func (_e *MultidownloaderInterface_Expecter) CheckValidBlock(ctx interface{}, blockNumber interface{}, blockHash interface{}) *MultidownloaderInterface_CheckValidBlock_Call
- func (_e *MultidownloaderInterface_Expecter) Finality() *MultidownloaderInterface_Finality_Call
- func (_e *MultidownloaderInterface_Expecter) GetReorgedDataByReorgID(ctx interface{}, reorgID interface{}) *MultidownloaderInterface_GetReorgedDataByReorgID_Call
- func (_e *MultidownloaderInterface_Expecter) HeaderByNumber(ctx interface{}, number interface{}) *MultidownloaderInterface_HeaderByNumber_Call
- func (_e *MultidownloaderInterface_Expecter) IsAvailable(query interface{}) *MultidownloaderInterface_IsAvailable_Call
- func (_e *MultidownloaderInterface_Expecter) IsPartiallyAvailable(query interface{}) *MultidownloaderInterface_IsPartiallyAvailable_Call
- func (_e *MultidownloaderInterface_Expecter) LogQuery(ctx interface{}, query interface{}) *MultidownloaderInterface_LogQuery_Call
- func (_e *MultidownloaderInterface_Expecter) StorageHeaderByNumber(ctx interface{}, number interface{}) *MultidownloaderInterface_StorageHeaderByNumber_Call
- type MultidownloaderInterface_Finality_Call
- func (_c *MultidownloaderInterface_Finality_Call) Return(_a0 aggkittypes.BlockNumberFinality) *MultidownloaderInterface_Finality_Call
- func (_c *MultidownloaderInterface_Finality_Call) Run(run func()) *MultidownloaderInterface_Finality_Call
- func (_c *MultidownloaderInterface_Finality_Call) RunAndReturn(run func() aggkittypes.BlockNumberFinality) *MultidownloaderInterface_Finality_Call
- type MultidownloaderInterface_GetReorgedDataByReorgID_Call
- func (_c *MultidownloaderInterface_GetReorgedDataByReorgID_Call) Return(_a0 *multidownloadertypes.ReorgData, _a1 error) *MultidownloaderInterface_GetReorgedDataByReorgID_Call
- func (_c *MultidownloaderInterface_GetReorgedDataByReorgID_Call) Run(run func(ctx context.Context, reorgID uint64)) *MultidownloaderInterface_GetReorgedDataByReorgID_Call
- func (_c *MultidownloaderInterface_GetReorgedDataByReorgID_Call) RunAndReturn(run func(context.Context, uint64) (*multidownloadertypes.ReorgData, error)) *MultidownloaderInterface_GetReorgedDataByReorgID_Call
- type MultidownloaderInterface_HeaderByNumber_Call
- func (_c *MultidownloaderInterface_HeaderByNumber_Call) Return(_a0 *aggkittypes.BlockHeader, _a1 error) *MultidownloaderInterface_HeaderByNumber_Call
- func (_c *MultidownloaderInterface_HeaderByNumber_Call) Run(run func(ctx context.Context, number *aggkittypes.BlockNumberFinality)) *MultidownloaderInterface_HeaderByNumber_Call
- func (_c *MultidownloaderInterface_HeaderByNumber_Call) RunAndReturn(...) *MultidownloaderInterface_HeaderByNumber_Call
- type MultidownloaderInterface_IsAvailable_Call
- func (_c *MultidownloaderInterface_IsAvailable_Call) Return(_a0 bool) *MultidownloaderInterface_IsAvailable_Call
- func (_c *MultidownloaderInterface_IsAvailable_Call) Run(run func(query multidownloadertypes.LogQuery)) *MultidownloaderInterface_IsAvailable_Call
- func (_c *MultidownloaderInterface_IsAvailable_Call) RunAndReturn(run func(multidownloadertypes.LogQuery) bool) *MultidownloaderInterface_IsAvailable_Call
- type MultidownloaderInterface_IsPartiallyAvailable_Call
- func (_c *MultidownloaderInterface_IsPartiallyAvailable_Call) Return(_a0 bool, _a1 *multidownloadertypes.LogQuery) *MultidownloaderInterface_IsPartiallyAvailable_Call
- func (_c *MultidownloaderInterface_IsPartiallyAvailable_Call) Run(run func(query multidownloadertypes.LogQuery)) *MultidownloaderInterface_IsPartiallyAvailable_Call
- func (_c *MultidownloaderInterface_IsPartiallyAvailable_Call) RunAndReturn(run func(multidownloadertypes.LogQuery) (bool, *multidownloadertypes.LogQuery)) *MultidownloaderInterface_IsPartiallyAvailable_Call
- type MultidownloaderInterface_LogQuery_Call
- func (_c *MultidownloaderInterface_LogQuery_Call) Return(_a0 multidownloadertypes.LogQueryResponse, _a1 error) *MultidownloaderInterface_LogQuery_Call
- func (_c *MultidownloaderInterface_LogQuery_Call) Run(run func(ctx context.Context, query multidownloadertypes.LogQuery)) *MultidownloaderInterface_LogQuery_Call
- func (_c *MultidownloaderInterface_LogQuery_Call) RunAndReturn(...) *MultidownloaderInterface_LogQuery_Call
- type MultidownloaderInterface_StorageHeaderByNumber_Call
- func (_c *MultidownloaderInterface_StorageHeaderByNumber_Call) Return(_a0 *aggkittypes.BlockHeader, _a1 multidownloadertypes.FinalizedType, ...) *MultidownloaderInterface_StorageHeaderByNumber_Call
- func (_c *MultidownloaderInterface_StorageHeaderByNumber_Call) Run(run func(ctx context.Context, number *aggkittypes.BlockNumberFinality)) *MultidownloaderInterface_StorageHeaderByNumber_Call
- func (_c *MultidownloaderInterface_StorageHeaderByNumber_Call) RunAndReturn(...) *MultidownloaderInterface_StorageHeaderByNumber_Call
- type ProcessorInterface
- func (_m *ProcessorInterface) EXPECT() *ProcessorInterface_Expecter
- func (_m *ProcessorInterface) GetLastProcessedBlockHeader(ctx context.Context) (*types.BlockHeader, error)
- func (_m *ProcessorInterface) ProcessBlocks(ctx context.Context, blocks *synctypes.DownloadResult) error
- func (_m *ProcessorInterface) Reorg(ctx context.Context, firstReorgedBlock uint64) error
- type ProcessorInterface_Expecter
- func (_e *ProcessorInterface_Expecter) GetLastProcessedBlockHeader(ctx interface{}) *ProcessorInterface_GetLastProcessedBlockHeader_Call
- func (_e *ProcessorInterface_Expecter) ProcessBlocks(ctx interface{}, blocks interface{}) *ProcessorInterface_ProcessBlocks_Call
- func (_e *ProcessorInterface_Expecter) Reorg(ctx interface{}, firstReorgedBlock interface{}) *ProcessorInterface_Reorg_Call
- type ProcessorInterface_GetLastProcessedBlockHeader_Call
- func (_c *ProcessorInterface_GetLastProcessedBlockHeader_Call) Return(_a0 *types.BlockHeader, _a1 error) *ProcessorInterface_GetLastProcessedBlockHeader_Call
- func (_c *ProcessorInterface_GetLastProcessedBlockHeader_Call) Run(run func(ctx context.Context)) *ProcessorInterface_GetLastProcessedBlockHeader_Call
- func (_c *ProcessorInterface_GetLastProcessedBlockHeader_Call) RunAndReturn(run func(context.Context) (*types.BlockHeader, error)) *ProcessorInterface_GetLastProcessedBlockHeader_Call
- type ProcessorInterface_ProcessBlocks_Call
- func (_c *ProcessorInterface_ProcessBlocks_Call) Return(_a0 error) *ProcessorInterface_ProcessBlocks_Call
- func (_c *ProcessorInterface_ProcessBlocks_Call) Run(run func(ctx context.Context, blocks *synctypes.DownloadResult)) *ProcessorInterface_ProcessBlocks_Call
- func (_c *ProcessorInterface_ProcessBlocks_Call) RunAndReturn(run func(context.Context, *synctypes.DownloadResult) error) *ProcessorInterface_ProcessBlocks_Call
- type ProcessorInterface_Reorg_Call
- func (_c *ProcessorInterface_Reorg_Call) Return(_a0 error) *ProcessorInterface_Reorg_Call
- func (_c *ProcessorInterface_Reorg_Call) Run(run func(ctx context.Context, firstReorgedBlock uint64)) *ProcessorInterface_Reorg_Call
- func (_c *ProcessorInterface_Reorg_Call) RunAndReturn(run func(context.Context, uint64) error) *ProcessorInterface_Reorg_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DownloaderInterface ¶
DownloaderInterface is an autogenerated mock type for the DownloaderInterface type
func NewDownloaderInterface ¶
func NewDownloaderInterface(t interface {
mock.TestingT
Cleanup(func())
}) *DownloaderInterface
NewDownloaderInterface creates a new instance of DownloaderInterface. 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 (*DownloaderInterface) ChainID ¶
func (_m *DownloaderInterface) ChainID(ctx context.Context) (uint64, error)
ChainID provides a mock function with given fields: ctx
func (*DownloaderInterface) DownloadNextBlocks ¶
func (_m *DownloaderInterface) DownloadNextBlocks(ctx context.Context, fromBlockHeader *aggkittypes.BlockHeader, maxBlocks uint64, syncerConfig aggkittypes.SyncerConfig) (*types.DownloadResult, error)
DownloadNextBlocks provides a mock function with given fields: ctx, fromBlockHeader, maxBlocks, syncerConfig
func (*DownloaderInterface) EXPECT ¶
func (_m *DownloaderInterface) EXPECT() *DownloaderInterface_Expecter
type DownloaderInterface_ChainID_Call ¶
DownloaderInterface_ChainID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ChainID'
func (*DownloaderInterface_ChainID_Call) Return ¶
func (_c *DownloaderInterface_ChainID_Call) Return(_a0 uint64, _a1 error) *DownloaderInterface_ChainID_Call
func (*DownloaderInterface_ChainID_Call) Run ¶
func (_c *DownloaderInterface_ChainID_Call) Run(run func(ctx context.Context)) *DownloaderInterface_ChainID_Call
func (*DownloaderInterface_ChainID_Call) RunAndReturn ¶
func (_c *DownloaderInterface_ChainID_Call) RunAndReturn(run func(context.Context) (uint64, error)) *DownloaderInterface_ChainID_Call
type DownloaderInterface_DownloadNextBlocks_Call ¶
DownloaderInterface_DownloadNextBlocks_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DownloadNextBlocks'
func (*DownloaderInterface_DownloadNextBlocks_Call) Return ¶
func (_c *DownloaderInterface_DownloadNextBlocks_Call) Return(_a0 *types.DownloadResult, _a1 error) *DownloaderInterface_DownloadNextBlocks_Call
func (*DownloaderInterface_DownloadNextBlocks_Call) Run ¶
func (_c *DownloaderInterface_DownloadNextBlocks_Call) Run(run func(ctx context.Context, fromBlockHeader *aggkittypes.BlockHeader, maxBlocks uint64, syncerConfig aggkittypes.SyncerConfig)) *DownloaderInterface_DownloadNextBlocks_Call
func (*DownloaderInterface_DownloadNextBlocks_Call) RunAndReturn ¶
func (_c *DownloaderInterface_DownloadNextBlocks_Call) RunAndReturn(run func(context.Context, *aggkittypes.BlockHeader, uint64, aggkittypes.SyncerConfig) (*types.DownloadResult, error)) *DownloaderInterface_DownloadNextBlocks_Call
type DownloaderInterface_Expecter ¶
type DownloaderInterface_Expecter struct {
// contains filtered or unexported fields
}
func (*DownloaderInterface_Expecter) ChainID ¶
func (_e *DownloaderInterface_Expecter) ChainID(ctx interface{}) *DownloaderInterface_ChainID_Call
ChainID is a helper method to define mock.On call
- ctx context.Context
func (*DownloaderInterface_Expecter) DownloadNextBlocks ¶
func (_e *DownloaderInterface_Expecter) DownloadNextBlocks(ctx interface{}, fromBlockHeader interface{}, maxBlocks interface{}, syncerConfig interface{}) *DownloaderInterface_DownloadNextBlocks_Call
DownloadNextBlocks is a helper method to define mock.On call
- ctx context.Context
- fromBlockHeader *aggkittypes.BlockHeader
- maxBlocks uint64
- syncerConfig aggkittypes.SyncerConfig
type MultidownloaderInterface ¶
MultidownloaderInterface is an autogenerated mock type for the MultidownloaderInterface type
func NewMultidownloaderInterface ¶
func NewMultidownloaderInterface(t interface {
mock.TestingT
Cleanup(func())
}) *MultidownloaderInterface
NewMultidownloaderInterface creates a new instance of MultidownloaderInterface. 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 (*MultidownloaderInterface) ChainID ¶
func (_m *MultidownloaderInterface) ChainID(ctx context.Context) (uint64, error)
ChainID provides a mock function with given fields: ctx
func (*MultidownloaderInterface) CheckValidBlock ¶
func (_m *MultidownloaderInterface) CheckValidBlock(ctx context.Context, blockNumber uint64, blockHash common.Hash) (bool, uint64, error)
CheckValidBlock provides a mock function with given fields: ctx, blockNumber, blockHash
func (*MultidownloaderInterface) EXPECT ¶
func (_m *MultidownloaderInterface) EXPECT() *MultidownloaderInterface_Expecter
func (*MultidownloaderInterface) Finality ¶
func (_m *MultidownloaderInterface) Finality() aggkittypes.BlockNumberFinality
Finality provides a mock function with no fields
func (*MultidownloaderInterface) GetReorgedDataByReorgID ¶
func (_m *MultidownloaderInterface) GetReorgedDataByReorgID(ctx context.Context, reorgID uint64) (*multidownloadertypes.ReorgData, error)
GetReorgedDataByReorgID provides a mock function with given fields: ctx, reorgID
func (*MultidownloaderInterface) HeaderByNumber ¶
func (_m *MultidownloaderInterface) HeaderByNumber(ctx context.Context, number *aggkittypes.BlockNumberFinality) (*aggkittypes.BlockHeader, error)
HeaderByNumber provides a mock function with given fields: ctx, number
func (*MultidownloaderInterface) IsAvailable ¶
func (_m *MultidownloaderInterface) IsAvailable(query multidownloadertypes.LogQuery) bool
IsAvailable provides a mock function with given fields: query
func (*MultidownloaderInterface) IsPartiallyAvailable ¶
func (_m *MultidownloaderInterface) IsPartiallyAvailable(query multidownloadertypes.LogQuery) (bool, *multidownloadertypes.LogQuery)
IsPartiallyAvailable provides a mock function with given fields: query
func (*MultidownloaderInterface) LogQuery ¶
func (_m *MultidownloaderInterface) LogQuery(ctx context.Context, query multidownloadertypes.LogQuery) (multidownloadertypes.LogQueryResponse, error)
LogQuery provides a mock function with given fields: ctx, query
func (*MultidownloaderInterface) StorageHeaderByNumber ¶
func (_m *MultidownloaderInterface) StorageHeaderByNumber(ctx context.Context, number *aggkittypes.BlockNumberFinality) (*aggkittypes.BlockHeader, multidownloadertypes.FinalizedType, error)
StorageHeaderByNumber provides a mock function with given fields: ctx, number
type MultidownloaderInterface_ChainID_Call ¶
MultidownloaderInterface_ChainID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ChainID'
func (*MultidownloaderInterface_ChainID_Call) Return ¶
func (_c *MultidownloaderInterface_ChainID_Call) Return(_a0 uint64, _a1 error) *MultidownloaderInterface_ChainID_Call
func (*MultidownloaderInterface_ChainID_Call) Run ¶
func (_c *MultidownloaderInterface_ChainID_Call) Run(run func(ctx context.Context)) *MultidownloaderInterface_ChainID_Call
func (*MultidownloaderInterface_ChainID_Call) RunAndReturn ¶
func (_c *MultidownloaderInterface_ChainID_Call) RunAndReturn(run func(context.Context) (uint64, error)) *MultidownloaderInterface_ChainID_Call
type MultidownloaderInterface_CheckValidBlock_Call ¶
MultidownloaderInterface_CheckValidBlock_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CheckValidBlock'
func (*MultidownloaderInterface_CheckValidBlock_Call) Return ¶
func (_c *MultidownloaderInterface_CheckValidBlock_Call) Return(_a0 bool, _a1 uint64, _a2 error) *MultidownloaderInterface_CheckValidBlock_Call
func (*MultidownloaderInterface_CheckValidBlock_Call) Run ¶
func (_c *MultidownloaderInterface_CheckValidBlock_Call) Run(run func(ctx context.Context, blockNumber uint64, blockHash common.Hash)) *MultidownloaderInterface_CheckValidBlock_Call
func (*MultidownloaderInterface_CheckValidBlock_Call) RunAndReturn ¶
func (_c *MultidownloaderInterface_CheckValidBlock_Call) RunAndReturn(run func(context.Context, uint64, common.Hash) (bool, uint64, error)) *MultidownloaderInterface_CheckValidBlock_Call
type MultidownloaderInterface_Expecter ¶
type MultidownloaderInterface_Expecter struct {
// contains filtered or unexported fields
}
func (*MultidownloaderInterface_Expecter) ChainID ¶
func (_e *MultidownloaderInterface_Expecter) ChainID(ctx interface{}) *MultidownloaderInterface_ChainID_Call
ChainID is a helper method to define mock.On call
- ctx context.Context
func (*MultidownloaderInterface_Expecter) CheckValidBlock ¶
func (_e *MultidownloaderInterface_Expecter) CheckValidBlock(ctx interface{}, blockNumber interface{}, blockHash interface{}) *MultidownloaderInterface_CheckValidBlock_Call
CheckValidBlock is a helper method to define mock.On call
- ctx context.Context
- blockNumber uint64
- blockHash common.Hash
func (*MultidownloaderInterface_Expecter) Finality ¶
func (_e *MultidownloaderInterface_Expecter) Finality() *MultidownloaderInterface_Finality_Call
Finality is a helper method to define mock.On call
func (*MultidownloaderInterface_Expecter) GetReorgedDataByReorgID ¶
func (_e *MultidownloaderInterface_Expecter) GetReorgedDataByReorgID(ctx interface{}, reorgID interface{}) *MultidownloaderInterface_GetReorgedDataByReorgID_Call
GetReorgedDataByReorgID is a helper method to define mock.On call
- ctx context.Context
- reorgID uint64
func (*MultidownloaderInterface_Expecter) HeaderByNumber ¶
func (_e *MultidownloaderInterface_Expecter) HeaderByNumber(ctx interface{}, number interface{}) *MultidownloaderInterface_HeaderByNumber_Call
HeaderByNumber is a helper method to define mock.On call
- ctx context.Context
- number *aggkittypes.BlockNumberFinality
func (*MultidownloaderInterface_Expecter) IsAvailable ¶
func (_e *MultidownloaderInterface_Expecter) IsAvailable(query interface{}) *MultidownloaderInterface_IsAvailable_Call
IsAvailable is a helper method to define mock.On call
- query multidownloadertypes.LogQuery
func (*MultidownloaderInterface_Expecter) IsPartiallyAvailable ¶
func (_e *MultidownloaderInterface_Expecter) IsPartiallyAvailable(query interface{}) *MultidownloaderInterface_IsPartiallyAvailable_Call
IsPartiallyAvailable is a helper method to define mock.On call
- query multidownloadertypes.LogQuery
func (*MultidownloaderInterface_Expecter) LogQuery ¶
func (_e *MultidownloaderInterface_Expecter) LogQuery(ctx interface{}, query interface{}) *MultidownloaderInterface_LogQuery_Call
LogQuery is a helper method to define mock.On call
- ctx context.Context
- query multidownloadertypes.LogQuery
func (*MultidownloaderInterface_Expecter) StorageHeaderByNumber ¶
func (_e *MultidownloaderInterface_Expecter) StorageHeaderByNumber(ctx interface{}, number interface{}) *MultidownloaderInterface_StorageHeaderByNumber_Call
StorageHeaderByNumber is a helper method to define mock.On call
- ctx context.Context
- number *aggkittypes.BlockNumberFinality
type MultidownloaderInterface_Finality_Call ¶
MultidownloaderInterface_Finality_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Finality'
func (*MultidownloaderInterface_Finality_Call) Return ¶
func (_c *MultidownloaderInterface_Finality_Call) Return(_a0 aggkittypes.BlockNumberFinality) *MultidownloaderInterface_Finality_Call
func (*MultidownloaderInterface_Finality_Call) Run ¶
func (_c *MultidownloaderInterface_Finality_Call) Run(run func()) *MultidownloaderInterface_Finality_Call
func (*MultidownloaderInterface_Finality_Call) RunAndReturn ¶
func (_c *MultidownloaderInterface_Finality_Call) RunAndReturn(run func() aggkittypes.BlockNumberFinality) *MultidownloaderInterface_Finality_Call
type MultidownloaderInterface_GetReorgedDataByReorgID_Call ¶
MultidownloaderInterface_GetReorgedDataByReorgID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetReorgedDataByReorgID'
func (*MultidownloaderInterface_GetReorgedDataByReorgID_Call) Run ¶
func (_c *MultidownloaderInterface_GetReorgedDataByReorgID_Call) Run(run func(ctx context.Context, reorgID uint64)) *MultidownloaderInterface_GetReorgedDataByReorgID_Call
func (*MultidownloaderInterface_GetReorgedDataByReorgID_Call) RunAndReturn ¶
func (_c *MultidownloaderInterface_GetReorgedDataByReorgID_Call) RunAndReturn(run func(context.Context, uint64) (*multidownloadertypes.ReorgData, error)) *MultidownloaderInterface_GetReorgedDataByReorgID_Call
type MultidownloaderInterface_HeaderByNumber_Call ¶
MultidownloaderInterface_HeaderByNumber_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HeaderByNumber'
func (*MultidownloaderInterface_HeaderByNumber_Call) Return ¶
func (_c *MultidownloaderInterface_HeaderByNumber_Call) Return(_a0 *aggkittypes.BlockHeader, _a1 error) *MultidownloaderInterface_HeaderByNumber_Call
func (*MultidownloaderInterface_HeaderByNumber_Call) Run ¶
func (_c *MultidownloaderInterface_HeaderByNumber_Call) Run(run func(ctx context.Context, number *aggkittypes.BlockNumberFinality)) *MultidownloaderInterface_HeaderByNumber_Call
func (*MultidownloaderInterface_HeaderByNumber_Call) RunAndReturn ¶
func (_c *MultidownloaderInterface_HeaderByNumber_Call) RunAndReturn(run func(context.Context, *aggkittypes.BlockNumberFinality) (*aggkittypes.BlockHeader, error)) *MultidownloaderInterface_HeaderByNumber_Call
type MultidownloaderInterface_IsAvailable_Call ¶
MultidownloaderInterface_IsAvailable_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsAvailable'
func (*MultidownloaderInterface_IsAvailable_Call) Return ¶
func (_c *MultidownloaderInterface_IsAvailable_Call) Return(_a0 bool) *MultidownloaderInterface_IsAvailable_Call
func (*MultidownloaderInterface_IsAvailable_Call) Run ¶
func (_c *MultidownloaderInterface_IsAvailable_Call) Run(run func(query multidownloadertypes.LogQuery)) *MultidownloaderInterface_IsAvailable_Call
func (*MultidownloaderInterface_IsAvailable_Call) RunAndReturn ¶
func (_c *MultidownloaderInterface_IsAvailable_Call) RunAndReturn(run func(multidownloadertypes.LogQuery) bool) *MultidownloaderInterface_IsAvailable_Call
type MultidownloaderInterface_IsPartiallyAvailable_Call ¶
MultidownloaderInterface_IsPartiallyAvailable_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsPartiallyAvailable'
func (*MultidownloaderInterface_IsPartiallyAvailable_Call) Return ¶
func (_c *MultidownloaderInterface_IsPartiallyAvailable_Call) Return(_a0 bool, _a1 *multidownloadertypes.LogQuery) *MultidownloaderInterface_IsPartiallyAvailable_Call
func (*MultidownloaderInterface_IsPartiallyAvailable_Call) Run ¶
func (_c *MultidownloaderInterface_IsPartiallyAvailable_Call) Run(run func(query multidownloadertypes.LogQuery)) *MultidownloaderInterface_IsPartiallyAvailable_Call
func (*MultidownloaderInterface_IsPartiallyAvailable_Call) RunAndReturn ¶
func (_c *MultidownloaderInterface_IsPartiallyAvailable_Call) RunAndReturn(run func(multidownloadertypes.LogQuery) (bool, *multidownloadertypes.LogQuery)) *MultidownloaderInterface_IsPartiallyAvailable_Call
type MultidownloaderInterface_LogQuery_Call ¶
MultidownloaderInterface_LogQuery_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LogQuery'
func (*MultidownloaderInterface_LogQuery_Call) Return ¶
func (_c *MultidownloaderInterface_LogQuery_Call) Return(_a0 multidownloadertypes.LogQueryResponse, _a1 error) *MultidownloaderInterface_LogQuery_Call
func (*MultidownloaderInterface_LogQuery_Call) Run ¶
func (_c *MultidownloaderInterface_LogQuery_Call) Run(run func(ctx context.Context, query multidownloadertypes.LogQuery)) *MultidownloaderInterface_LogQuery_Call
func (*MultidownloaderInterface_LogQuery_Call) RunAndReturn ¶
func (_c *MultidownloaderInterface_LogQuery_Call) RunAndReturn(run func(context.Context, multidownloadertypes.LogQuery) (multidownloadertypes.LogQueryResponse, error)) *MultidownloaderInterface_LogQuery_Call
type MultidownloaderInterface_StorageHeaderByNumber_Call ¶
MultidownloaderInterface_StorageHeaderByNumber_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StorageHeaderByNumber'
func (*MultidownloaderInterface_StorageHeaderByNumber_Call) Return ¶
func (_c *MultidownloaderInterface_StorageHeaderByNumber_Call) Return(_a0 *aggkittypes.BlockHeader, _a1 multidownloadertypes.FinalizedType, _a2 error) *MultidownloaderInterface_StorageHeaderByNumber_Call
func (*MultidownloaderInterface_StorageHeaderByNumber_Call) Run ¶
func (_c *MultidownloaderInterface_StorageHeaderByNumber_Call) Run(run func(ctx context.Context, number *aggkittypes.BlockNumberFinality)) *MultidownloaderInterface_StorageHeaderByNumber_Call
func (*MultidownloaderInterface_StorageHeaderByNumber_Call) RunAndReturn ¶
func (_c *MultidownloaderInterface_StorageHeaderByNumber_Call) RunAndReturn(run func(context.Context, *aggkittypes.BlockNumberFinality) (*aggkittypes.BlockHeader, multidownloadertypes.FinalizedType, error)) *MultidownloaderInterface_StorageHeaderByNumber_Call
type ProcessorInterface ¶
ProcessorInterface is an autogenerated mock type for the ProcessorInterface type
func NewProcessorInterface ¶
func NewProcessorInterface(t interface {
mock.TestingT
Cleanup(func())
}) *ProcessorInterface
NewProcessorInterface creates a new instance of ProcessorInterface. 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 (*ProcessorInterface) EXPECT ¶
func (_m *ProcessorInterface) EXPECT() *ProcessorInterface_Expecter
func (*ProcessorInterface) GetLastProcessedBlockHeader ¶
func (_m *ProcessorInterface) GetLastProcessedBlockHeader(ctx context.Context) (*types.BlockHeader, error)
GetLastProcessedBlockHeader provides a mock function with given fields: ctx
func (*ProcessorInterface) ProcessBlocks ¶
func (_m *ProcessorInterface) ProcessBlocks(ctx context.Context, blocks *synctypes.DownloadResult) error
ProcessBlocks provides a mock function with given fields: ctx, blocks
type ProcessorInterface_Expecter ¶
type ProcessorInterface_Expecter struct {
// contains filtered or unexported fields
}
func (*ProcessorInterface_Expecter) GetLastProcessedBlockHeader ¶
func (_e *ProcessorInterface_Expecter) GetLastProcessedBlockHeader(ctx interface{}) *ProcessorInterface_GetLastProcessedBlockHeader_Call
GetLastProcessedBlockHeader is a helper method to define mock.On call
- ctx context.Context
func (*ProcessorInterface_Expecter) ProcessBlocks ¶
func (_e *ProcessorInterface_Expecter) ProcessBlocks(ctx interface{}, blocks interface{}) *ProcessorInterface_ProcessBlocks_Call
ProcessBlocks is a helper method to define mock.On call
- ctx context.Context
- blocks *synctypes.DownloadResult
func (*ProcessorInterface_Expecter) Reorg ¶
func (_e *ProcessorInterface_Expecter) Reorg(ctx interface{}, firstReorgedBlock interface{}) *ProcessorInterface_Reorg_Call
Reorg is a helper method to define mock.On call
- ctx context.Context
- firstReorgedBlock uint64
type ProcessorInterface_GetLastProcessedBlockHeader_Call ¶
ProcessorInterface_GetLastProcessedBlockHeader_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLastProcessedBlockHeader'
func (*ProcessorInterface_GetLastProcessedBlockHeader_Call) Return ¶
func (_c *ProcessorInterface_GetLastProcessedBlockHeader_Call) Return(_a0 *types.BlockHeader, _a1 error) *ProcessorInterface_GetLastProcessedBlockHeader_Call
func (*ProcessorInterface_GetLastProcessedBlockHeader_Call) Run ¶
func (_c *ProcessorInterface_GetLastProcessedBlockHeader_Call) Run(run func(ctx context.Context)) *ProcessorInterface_GetLastProcessedBlockHeader_Call
func (*ProcessorInterface_GetLastProcessedBlockHeader_Call) RunAndReturn ¶
func (_c *ProcessorInterface_GetLastProcessedBlockHeader_Call) RunAndReturn(run func(context.Context) (*types.BlockHeader, error)) *ProcessorInterface_GetLastProcessedBlockHeader_Call
type ProcessorInterface_ProcessBlocks_Call ¶
ProcessorInterface_ProcessBlocks_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ProcessBlocks'
func (*ProcessorInterface_ProcessBlocks_Call) Return ¶
func (_c *ProcessorInterface_ProcessBlocks_Call) Return(_a0 error) *ProcessorInterface_ProcessBlocks_Call
func (*ProcessorInterface_ProcessBlocks_Call) Run ¶
func (_c *ProcessorInterface_ProcessBlocks_Call) Run(run func(ctx context.Context, blocks *synctypes.DownloadResult)) *ProcessorInterface_ProcessBlocks_Call
func (*ProcessorInterface_ProcessBlocks_Call) RunAndReturn ¶
func (_c *ProcessorInterface_ProcessBlocks_Call) RunAndReturn(run func(context.Context, *synctypes.DownloadResult) error) *ProcessorInterface_ProcessBlocks_Call
type ProcessorInterface_Reorg_Call ¶
ProcessorInterface_Reorg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Reorg'
func (*ProcessorInterface_Reorg_Call) Return ¶
func (_c *ProcessorInterface_Reorg_Call) Return(_a0 error) *ProcessorInterface_Reorg_Call
func (*ProcessorInterface_Reorg_Call) Run ¶
func (_c *ProcessorInterface_Reorg_Call) Run(run func(ctx context.Context, firstReorgedBlock uint64)) *ProcessorInterface_Reorg_Call
func (*ProcessorInterface_Reorg_Call) RunAndReturn ¶
func (_c *ProcessorInterface_Reorg_Call) RunAndReturn(run func(context.Context, uint64) error) *ProcessorInterface_Reorg_Call