mocks

package
v0.10.0-rc1 Latest Latest
Warning

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

 Go to latest Published: Apr 20, 2026 License: Apache-2.0, MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ReorgPorter 

type ReorgPorter struct {
	mock.Mock
}

ReorgPorter is an autogenerated mock type for the ReorgPorter type

func NewReorgPorter 

func NewReorgPorter(t interface {
	mock.TestingT
	Cleanup(func())
}) *ReorgPorter

NewReorgPorter creates a new instance of ReorgPorter. 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 (*ReorgPorter) EXPECT 

func (_m *ReorgPorter) EXPECT() *ReorgPorter_Expecter

func (*ReorgPorter) GetBlockNumberInRPC 

func (_m *ReorgPorter) GetBlockNumberInRPC(ctx context.Context, blockFinality types.BlockNumberFinality) (uint64, error)

GetBlockNumberInRPC provides a mock function with given fields: ctx, blockFinality

func (*ReorgPorter) GetBlockStorageAndRPC 

func (_m *ReorgPorter) GetBlockStorageAndRPC(ctx context.Context, tx dbtypes.Querier, blockNumber uint64) (*multidownloadertypes.CompareBlockHeaders, error)

GetBlockStorageAndRPC provides a mock function with given fields: ctx, tx, blockNumber

func (*ReorgPorter) GetLastBlockNumberInStorage 

func (_m *ReorgPorter) GetLastBlockNumberInStorage(tx dbtypes.Querier) (uint64, error)

GetLastBlockNumberInStorage provides a mock function with given fields: tx

func (*ReorgPorter) MoveReorgedBlocks 

func (_m *ReorgPorter) MoveReorgedBlocks(tx dbtypes.Querier, reorgData multidownloadertypes.ReorgData) (uint64, error)

MoveReorgedBlocks provides a mock function with given fields: tx, reorgData

func (*ReorgPorter) NewTx 

func (_m *ReorgPorter) NewTx(ctx context.Context) (dbtypes.Txer, error)

NewTx provides a mock function with given fields: ctx

func (*ReorgPorter) TimeNowUnix 

func (_m *ReorgPorter) TimeNowUnix() uint64

TimeNowUnix provides a mock function with no fields

type ReorgPorter_Expecter 

type ReorgPorter_Expecter struct {
	// contains filtered or unexported fields
}

func (*ReorgPorter_Expecter) GetBlockNumberInRPC 

func (_e *ReorgPorter_Expecter) GetBlockNumberInRPC(ctx interface{}, blockFinality interface{}) *ReorgPorter_GetBlockNumberInRPC_Call

GetBlockNumberInRPC is a helper method to define mock.On call

  • ctx context.Context
  • blockFinality types.BlockNumberFinality

func (*ReorgPorter_Expecter) GetBlockStorageAndRPC 

func (_e *ReorgPorter_Expecter) GetBlockStorageAndRPC(ctx interface{}, tx interface{}, blockNumber interface{}) *ReorgPorter_GetBlockStorageAndRPC_Call

GetBlockStorageAndRPC is a helper method to define mock.On call

  • ctx context.Context
  • tx dbtypes.Querier
  • blockNumber uint64

func (*ReorgPorter_Expecter) GetLastBlockNumberInStorage 

func (_e *ReorgPorter_Expecter) GetLastBlockNumberInStorage(tx interface{}) *ReorgPorter_GetLastBlockNumberInStorage_Call

GetLastBlockNumberInStorage is a helper method to define mock.On call

  • tx dbtypes.Querier

func (*ReorgPorter_Expecter) MoveReorgedBlocks 

func (_e *ReorgPorter_Expecter) MoveReorgedBlocks(tx interface{}, reorgData interface{}) *ReorgPorter_MoveReorgedBlocks_Call

MoveReorgedBlocks is a helper method to define mock.On call

  • tx dbtypes.Querier
  • reorgData multidownloadertypes.ReorgData

func (*ReorgPorter_Expecter) NewTx 

func (_e *ReorgPorter_Expecter) NewTx(ctx interface{}) *ReorgPorter_NewTx_Call

NewTx is a helper method to define mock.On call

  • ctx context.Context

func (*ReorgPorter_Expecter) TimeNowUnix 

func (_e *ReorgPorter_Expecter) TimeNowUnix() *ReorgPorter_TimeNowUnix_Call

TimeNowUnix is a helper method to define mock.On call

type ReorgPorter_GetBlockNumberInRPC_Call 

type ReorgPorter_GetBlockNumberInRPC_Call struct {
	*mock.Call
}

ReorgPorter_GetBlockNumberInRPC_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetBlockNumberInRPC'

func (*ReorgPorter_GetBlockNumberInRPC_Call) Return 

func (_c *ReorgPorter_GetBlockNumberInRPC_Call) Return(_a0 uint64, _a1 error) *ReorgPorter_GetBlockNumberInRPC_Call

func (*ReorgPorter_GetBlockNumberInRPC_Call) Run 

func (_c *ReorgPorter_GetBlockNumberInRPC_Call) Run(run func(ctx context.Context, blockFinality types.BlockNumberFinality)) *ReorgPorter_GetBlockNumberInRPC_Call

func (*ReorgPorter_GetBlockNumberInRPC_Call) RunAndReturn 

func (_c *ReorgPorter_GetBlockNumberInRPC_Call) RunAndReturn(run func(context.Context, types.BlockNumberFinality) (uint64, error)) *ReorgPorter_GetBlockNumberInRPC_Call

type ReorgPorter_GetBlockStorageAndRPC_Call 

type ReorgPorter_GetBlockStorageAndRPC_Call struct {
	*mock.Call
}

ReorgPorter_GetBlockStorageAndRPC_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetBlockStorageAndRPC'

func (*ReorgPorter_GetBlockStorageAndRPC_Call) Return 

func (_c *ReorgPorter_GetBlockStorageAndRPC_Call) Return(_a0 *multidownloadertypes.CompareBlockHeaders, _a1 error) *ReorgPorter_GetBlockStorageAndRPC_Call

func (*ReorgPorter_GetBlockStorageAndRPC_Call) Run 

func (_c *ReorgPorter_GetBlockStorageAndRPC_Call) Run(run func(ctx context.Context, tx dbtypes.Querier, blockNumber uint64)) *ReorgPorter_GetBlockStorageAndRPC_Call

func (*ReorgPorter_GetBlockStorageAndRPC_Call) RunAndReturn 

func (_c *ReorgPorter_GetBlockStorageAndRPC_Call) RunAndReturn(run func(context.Context, dbtypes.Querier, uint64) (*multidownloadertypes.CompareBlockHeaders, error)) *ReorgPorter_GetBlockStorageAndRPC_Call

type ReorgPorter_GetLastBlockNumberInStorage_Call 

type ReorgPorter_GetLastBlockNumberInStorage_Call struct {
	*mock.Call
}

ReorgPorter_GetLastBlockNumberInStorage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLastBlockNumberInStorage'

func (*ReorgPorter_GetLastBlockNumberInStorage_Call) Return 

func (_c *ReorgPorter_GetLastBlockNumberInStorage_Call) Return(_a0 uint64, _a1 error) *ReorgPorter_GetLastBlockNumberInStorage_Call

func (*ReorgPorter_GetLastBlockNumberInStorage_Call) Run 

func (_c *ReorgPorter_GetLastBlockNumberInStorage_Call) Run(run func(tx dbtypes.Querier)) *ReorgPorter_GetLastBlockNumberInStorage_Call

func (*ReorgPorter_GetLastBlockNumberInStorage_Call) RunAndReturn 

func (_c *ReorgPorter_GetLastBlockNumberInStorage_Call) RunAndReturn(run func(dbtypes.Querier) (uint64, error)) *ReorgPorter_GetLastBlockNumberInStorage_Call

type ReorgPorter_MoveReorgedBlocks_Call 

type ReorgPorter_MoveReorgedBlocks_Call struct {
	*mock.Call
}

ReorgPorter_MoveReorgedBlocks_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MoveReorgedBlocks'

func (*ReorgPorter_MoveReorgedBlocks_Call) Return 

func (_c *ReorgPorter_MoveReorgedBlocks_Call) Return(_a0 uint64, _a1 error) *ReorgPorter_MoveReorgedBlocks_Call

func (*ReorgPorter_MoveReorgedBlocks_Call) Run 

func (_c *ReorgPorter_MoveReorgedBlocks_Call) Run(run func(tx dbtypes.Querier, reorgData multidownloadertypes.ReorgData)) *ReorgPorter_MoveReorgedBlocks_Call

func (*ReorgPorter_MoveReorgedBlocks_Call) RunAndReturn 

func (_c *ReorgPorter_MoveReorgedBlocks_Call) RunAndReturn(run func(dbtypes.Querier, multidownloadertypes.ReorgData) (uint64, error)) *ReorgPorter_MoveReorgedBlocks_Call

type ReorgPorter_NewTx_Call 

type ReorgPorter_NewTx_Call struct {
	*mock.Call
}

ReorgPorter_NewTx_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewTx'

func (*ReorgPorter_NewTx_Call) Return 

func (_c *ReorgPorter_NewTx_Call) Return(_a0 dbtypes.Txer, _a1 error) *ReorgPorter_NewTx_Call

func (*ReorgPorter_NewTx_Call) Run 

func (_c *ReorgPorter_NewTx_Call) Run(run func(ctx context.Context)) *ReorgPorter_NewTx_Call

func (*ReorgPorter_NewTx_Call) RunAndReturn 

func (_c *ReorgPorter_NewTx_Call) RunAndReturn(run func(context.Context) (dbtypes.Txer, error)) *ReorgPorter_NewTx_Call

type ReorgPorter_TimeNowUnix_Call 

type ReorgPorter_TimeNowUnix_Call struct {
	*mock.Call
}

ReorgPorter_TimeNowUnix_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TimeNowUnix'

func (*ReorgPorter_TimeNowUnix_Call) Return 

func (_c *ReorgPorter_TimeNowUnix_Call) Return(_a0 uint64) *ReorgPorter_TimeNowUnix_Call

func (*ReorgPorter_TimeNowUnix_Call) Run 

func (_c *ReorgPorter_TimeNowUnix_Call) Run(run func()) *ReorgPorter_TimeNowUnix_Call

func (*ReorgPorter_TimeNowUnix_Call) RunAndReturn 

func (_c *ReorgPorter_TimeNowUnix_Call) RunAndReturn(run func() uint64) *ReorgPorter_TimeNowUnix_Call

type ReorgProcessor 

type ReorgProcessor struct {
	mock.Mock
}

ReorgProcessor is an autogenerated mock type for the ReorgProcessor type

func NewReorgProcessor 

func NewReorgProcessor(t interface {
	mock.TestingT
	Cleanup(func())
}) *ReorgProcessor

NewReorgProcessor creates a new instance of ReorgProcessor. 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 (*ReorgProcessor) EXPECT 

func (_m *ReorgProcessor) EXPECT() *ReorgProcessor_Expecter

func (*ReorgProcessor) ProcessReorg 

func (_m *ReorgProcessor) ProcessReorg(ctx context.Context, detectedReorgError types.DetectedReorgError, finalizedBlockTag aggkittypes.BlockNumberFinality) error

ProcessReorg provides a mock function with given fields: ctx, detectedReorgError, finalizedBlockTag

type ReorgProcessor_Expecter 

type ReorgProcessor_Expecter struct {
	// contains filtered or unexported fields
}

func (*ReorgProcessor_Expecter) ProcessReorg 

func (_e *ReorgProcessor_Expecter) ProcessReorg(ctx interface{}, detectedReorgError interface{}, finalizedBlockTag interface{}) *ReorgProcessor_ProcessReorg_Call

ProcessReorg is a helper method to define mock.On call

  • ctx context.Context
  • detectedReorgError types.DetectedReorgError
  • finalizedBlockTag aggkittypes.BlockNumberFinality

type ReorgProcessor_ProcessReorg_Call 

type ReorgProcessor_ProcessReorg_Call struct {
	*mock.Call
}

ReorgProcessor_ProcessReorg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ProcessReorg'

func (*ReorgProcessor_ProcessReorg_Call) Return 

func (_c *ReorgProcessor_ProcessReorg_Call) Return(_a0 error) *ReorgProcessor_ProcessReorg_Call

func (*ReorgProcessor_ProcessReorg_Call) Run 

func (_c *ReorgProcessor_ProcessReorg_Call) Run(run func(ctx context.Context, detectedReorgError types.DetectedReorgError, finalizedBlockTag aggkittypes.BlockNumberFinality)) *ReorgProcessor_ProcessReorg_Call

func (*ReorgProcessor_ProcessReorg_Call) RunAndReturn 

func (_c *ReorgProcessor_ProcessReorg_Call) RunAndReturn(run func(context.Context, types.DetectedReorgError, aggkittypes.BlockNumberFinality) error) *ReorgProcessor_ProcessReorg_Call

type Storager 

type Storager struct {
	mock.Mock
}

Storager is an autogenerated mock type for the Storager type

func NewStorager 

func NewStorager(t interface {
	mock.TestingT
	Cleanup(func())
}) *Storager

NewStorager creates a new instance of Storager. 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 (*Storager) EXPECT 

func (_m *Storager) EXPECT() *Storager_Expecter

func (*Storager) GetBlockHeaderByNumber 

func (_m *Storager) GetBlockHeaderByNumber(tx types.Querier, blockNumber uint64) (*aggkittypes.BlockHeader, multidownloadertypes.FinalizedType, error)

GetBlockHeaderByNumber provides a mock function with given fields: tx, blockNumber

func (*Storager) GetBlockHeadersNotFinalized 

func (_m *Storager) GetBlockHeadersNotFinalized(tx types.Querier, maxBlock *uint64) (aggkittypes.ListBlockHeaders, error)

GetBlockHeadersNotFinalized provides a mock function with given fields: tx, maxBlock

func (*Storager) GetBlockReorgedReorgID 

func (_m *Storager) GetBlockReorgedReorgID(tx types.Querier, blockNumber uint64, blockHash common.Hash) (uint64, bool, error)

GetBlockReorgedReorgID provides a mock function with given fields: tx, blockNumber, blockHash

func (*Storager) GetEthLogs 

func (_m *Storager) GetEthLogs(tx types.Querier, query multidownloadertypes.LogQuery) ([]coretypes.Log, error)

GetEthLogs provides a mock function with given fields: tx, query

func (*Storager) GetHighestBlockNumber 

func (_m *Storager) GetHighestBlockNumber(tx types.Querier) (uint64, error)

GetHighestBlockNumber provides a mock function with given fields: tx

func (*Storager) GetRangeBlockHeader 

func (_m *Storager) GetRangeBlockHeader(tx types.Querier, isFinal multidownloadertypes.FinalizedType) (*aggkittypes.BlockHeader, *aggkittypes.BlockHeader, error)

GetRangeBlockHeader provides a mock function with given fields: tx, isFinal

func (*Storager) GetReorgedDataByReorgID 

func (_m *Storager) GetReorgedDataByReorgID(tx types.Querier, reorgID uint64) (*multidownloadertypes.ReorgData, error)

GetReorgedDataByReorgID provides a mock function with given fields: tx, reorgID

func (*Storager) GetSyncedBlockRangePerContract 

func (_m *Storager) GetSyncedBlockRangePerContract(tx types.Querier) (multidownloadertypes.SetSyncSegment, error)

GetSyncedBlockRangePerContract provides a mock function with given fields: tx

func (*Storager) GetValue 

func (_m *Storager) GetValue(tx types.Querier, owner string, key string) (string, error)

GetValue provides a mock function with given fields: tx, owner, key

func (*Storager) InsertReorgAndMoveReorgedBlocksAndLogs 

func (_m *Storager) InsertReorgAndMoveReorgedBlocksAndLogs(tx types.Querier, reorgData multidownloadertypes.ReorgData) (uint64, error)

InsertReorgAndMoveReorgedBlocksAndLogs provides a mock function with given fields: tx, reorgData

func (*Storager) InsertValue 

func (_m *Storager) InsertValue(tx types.Querier, owner string, key string, value string) error

InsertValue provides a mock function with given fields: tx, owner, key, value

func (*Storager) LogQuery 

func (_m *Storager) LogQuery(tx types.Querier, query multidownloadertypes.LogQuery) (multidownloadertypes.LogQueryResponse, error)

LogQuery provides a mock function with given fields: tx, query

func (*Storager) NewTx 

func (_m *Storager) NewTx(ctx context.Context) (types.Txer, error)

NewTx provides a mock function with given fields: ctx

func (*Storager) SaveEthLogsWithHeaders 

func (_m *Storager) SaveEthLogsWithHeaders(tx types.Querier, blockHeaders aggkittypes.ListBlockHeaders, logs []coretypes.Log, isFinal bool) error

SaveEthLogsWithHeaders provides a mock function with given fields: tx, blockHeaders, logs, isFinal

func (*Storager) UpdateBlockToFinalized 

func (_m *Storager) UpdateBlockToFinalized(tx types.Querier, blockNumbers []uint64) error

UpdateBlockToFinalized provides a mock function with given fields: tx, blockNumbers

func (*Storager) UpdateSyncedStatus 

func (_m *Storager) UpdateSyncedStatus(tx types.Querier, segments []multidownloadertypes.SyncSegment) error

UpdateSyncedStatus provides a mock function with given fields: tx, segments

func (*Storager) UpdateValue 

func (_m *Storager) UpdateValue(tx types.Querier, owner string, key string, value string) error

UpdateValue provides a mock function with given fields: tx, owner, key, value

func (*Storager) UpsertSyncerConfigs 

func (_m *Storager) UpsertSyncerConfigs(tx types.Querier, configs []multidownloadertypes.ContractConfig) error

UpsertSyncerConfigs provides a mock function with given fields: tx, configs

type StoragerForReorg 

type StoragerForReorg struct {
	mock.Mock
}

StoragerForReorg is an autogenerated mock type for the StoragerForReorg type

func NewStoragerForReorg 

func NewStoragerForReorg(t interface {
	mock.TestingT
	Cleanup(func())
}) *StoragerForReorg

NewStoragerForReorg creates a new instance of StoragerForReorg. 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 (*StoragerForReorg) EXPECT 

func (_m *StoragerForReorg) EXPECT() *StoragerForReorg_Expecter

func (*StoragerForReorg) GetBlockHeaderByNumber 

func (_m *StoragerForReorg) GetBlockHeaderByNumber(tx types.Querier, blockNumber uint64) (*aggkittypes.BlockHeader, multidownloadertypes.FinalizedType, error)

GetBlockHeaderByNumber provides a mock function with given fields: tx, blockNumber

func (*StoragerForReorg) InsertReorgAndMoveReorgedBlocksAndLogs 

func (_m *StoragerForReorg) InsertReorgAndMoveReorgedBlocksAndLogs(tx types.Querier, reorgData multidownloadertypes.ReorgData) (uint64, error)

InsertReorgAndMoveReorgedBlocksAndLogs provides a mock function with given fields: tx, reorgData

type StoragerForReorg_Expecter 

type StoragerForReorg_Expecter struct {
	// contains filtered or unexported fields
}

func (*StoragerForReorg_Expecter) GetBlockHeaderByNumber 

func (_e *StoragerForReorg_Expecter) GetBlockHeaderByNumber(tx interface{}, blockNumber interface{}) *StoragerForReorg_GetBlockHeaderByNumber_Call

GetBlockHeaderByNumber is a helper method to define mock.On call

  • tx types.Querier
  • blockNumber uint64

func (*StoragerForReorg_Expecter) InsertReorgAndMoveReorgedBlocksAndLogs 

func (_e *StoragerForReorg_Expecter) InsertReorgAndMoveReorgedBlocksAndLogs(tx interface{}, reorgData interface{}) *StoragerForReorg_InsertReorgAndMoveReorgedBlocksAndLogs_Call

InsertReorgAndMoveReorgedBlocksAndLogs is a helper method to define mock.On call

  • tx types.Querier
  • reorgData multidownloadertypes.ReorgData

type StoragerForReorg_GetBlockHeaderByNumber_Call 

type StoragerForReorg_GetBlockHeaderByNumber_Call struct {
	*mock.Call
}

StoragerForReorg_GetBlockHeaderByNumber_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetBlockHeaderByNumber'

func (*StoragerForReorg_GetBlockHeaderByNumber_Call) Return 

func (_c *StoragerForReorg_GetBlockHeaderByNumber_Call) Return(_a0 *aggkittypes.BlockHeader, _a1 multidownloadertypes.FinalizedType, _a2 error) *StoragerForReorg_GetBlockHeaderByNumber_Call

func (*StoragerForReorg_GetBlockHeaderByNumber_Call) Run 

func (_c *StoragerForReorg_GetBlockHeaderByNumber_Call) Run(run func(tx types.Querier, blockNumber uint64)) *StoragerForReorg_GetBlockHeaderByNumber_Call

func (*StoragerForReorg_GetBlockHeaderByNumber_Call) RunAndReturn 

func (_c *StoragerForReorg_GetBlockHeaderByNumber_Call) RunAndReturn(run func(types.Querier, uint64) (*aggkittypes.BlockHeader, multidownloadertypes.FinalizedType, error)) *StoragerForReorg_GetBlockHeaderByNumber_Call

type StoragerForReorg_InsertReorgAndMoveReorgedBlocksAndLogs_Call 

type StoragerForReorg_InsertReorgAndMoveReorgedBlocksAndLogs_Call struct {
	*mock.Call
}

StoragerForReorg_InsertReorgAndMoveReorgedBlocksAndLogs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InsertReorgAndMoveReorgedBlocksAndLogs'

func (*StoragerForReorg_InsertReorgAndMoveReorgedBlocksAndLogs_Call) Return 

func (_c *StoragerForReorg_InsertReorgAndMoveReorgedBlocksAndLogs_Call) Return(_a0 uint64, _a1 error) *StoragerForReorg_InsertReorgAndMoveReorgedBlocksAndLogs_Call

func (*StoragerForReorg_InsertReorgAndMoveReorgedBlocksAndLogs_Call) Run 

func (_c *StoragerForReorg_InsertReorgAndMoveReorgedBlocksAndLogs_Call) Run(run func(tx types.Querier, reorgData multidownloadertypes.ReorgData)) *StoragerForReorg_InsertReorgAndMoveReorgedBlocksAndLogs_Call

func (*StoragerForReorg_InsertReorgAndMoveReorgedBlocksAndLogs_Call) RunAndReturn 

func (_c *StoragerForReorg_InsertReorgAndMoveReorgedBlocksAndLogs_Call) RunAndReturn(run func(types.Querier, multidownloadertypes.ReorgData) (uint64, error)) *StoragerForReorg_InsertReorgAndMoveReorgedBlocksAndLogs_Call

type Storager_Expecter 

type Storager_Expecter struct {
	// contains filtered or unexported fields
}

func (*Storager_Expecter) GetBlockHeaderByNumber 

func (_e *Storager_Expecter) GetBlockHeaderByNumber(tx interface{}, blockNumber interface{}) *Storager_GetBlockHeaderByNumber_Call

GetBlockHeaderByNumber is a helper method to define mock.On call

  • tx types.Querier
  • blockNumber uint64

func (*Storager_Expecter) GetBlockHeadersNotFinalized 

func (_e *Storager_Expecter) GetBlockHeadersNotFinalized(tx interface{}, maxBlock interface{}) *Storager_GetBlockHeadersNotFinalized_Call

GetBlockHeadersNotFinalized is a helper method to define mock.On call

  • tx types.Querier
  • maxBlock *uint64

func (*Storager_Expecter) GetBlockReorgedReorgID 

func (_e *Storager_Expecter) GetBlockReorgedReorgID(tx interface{}, blockNumber interface{}, blockHash interface{}) *Storager_GetBlockReorgedReorgID_Call

GetBlockReorgedReorgID is a helper method to define mock.On call

  • tx types.Querier
  • blockNumber uint64
  • blockHash common.Hash

func (*Storager_Expecter) GetEthLogs 

func (_e *Storager_Expecter) GetEthLogs(tx interface{}, query interface{}) *Storager_GetEthLogs_Call

GetEthLogs is a helper method to define mock.On call

  • tx types.Querier
  • query multidownloadertypes.LogQuery

func (*Storager_Expecter) GetHighestBlockNumber 

func (_e *Storager_Expecter) GetHighestBlockNumber(tx interface{}) *Storager_GetHighestBlockNumber_Call

GetHighestBlockNumber is a helper method to define mock.On call

  • tx types.Querier

func (*Storager_Expecter) GetRangeBlockHeader 

func (_e *Storager_Expecter) GetRangeBlockHeader(tx interface{}, isFinal interface{}) *Storager_GetRangeBlockHeader_Call

GetRangeBlockHeader is a helper method to define mock.On call

  • tx types.Querier
  • isFinal multidownloadertypes.FinalizedType

func (*Storager_Expecter) GetReorgedDataByReorgID 

func (_e *Storager_Expecter) GetReorgedDataByReorgID(tx interface{}, reorgID interface{}) *Storager_GetReorgedDataByReorgID_Call

GetReorgedDataByReorgID is a helper method to define mock.On call

  • tx types.Querier
  • reorgID uint64

func (*Storager_Expecter) GetSyncedBlockRangePerContract 

func (_e *Storager_Expecter) GetSyncedBlockRangePerContract(tx interface{}) *Storager_GetSyncedBlockRangePerContract_Call

GetSyncedBlockRangePerContract is a helper method to define mock.On call

  • tx types.Querier

func (*Storager_Expecter) GetValue 

func (_e *Storager_Expecter) GetValue(tx interface{}, owner interface{}, key interface{}) *Storager_GetValue_Call

GetValue is a helper method to define mock.On call

  • tx types.Querier
  • owner string
  • key string

func (*Storager_Expecter) InsertReorgAndMoveReorgedBlocksAndLogs 

func (_e *Storager_Expecter) InsertReorgAndMoveReorgedBlocksAndLogs(tx interface{}, reorgData interface{}) *Storager_InsertReorgAndMoveReorgedBlocksAndLogs_Call

InsertReorgAndMoveReorgedBlocksAndLogs is a helper method to define mock.On call

  • tx types.Querier
  • reorgData multidownloadertypes.ReorgData

func (*Storager_Expecter) InsertValue 

func (_e *Storager_Expecter) InsertValue(tx interface{}, owner interface{}, key interface{}, value interface{}) *Storager_InsertValue_Call

InsertValue is a helper method to define mock.On call

  • tx types.Querier
  • owner string
  • key string
  • value string

func (*Storager_Expecter) LogQuery 

func (_e *Storager_Expecter) LogQuery(tx interface{}, query interface{}) *Storager_LogQuery_Call

LogQuery is a helper method to define mock.On call

  • tx types.Querier
  • query multidownloadertypes.LogQuery

func (*Storager_Expecter) NewTx 

func (_e *Storager_Expecter) NewTx(ctx interface{}) *Storager_NewTx_Call

NewTx is a helper method to define mock.On call

  • ctx context.Context

func (*Storager_Expecter) SaveEthLogsWithHeaders 

func (_e *Storager_Expecter) SaveEthLogsWithHeaders(tx interface{}, blockHeaders interface{}, logs interface{}, isFinal interface{}) *Storager_SaveEthLogsWithHeaders_Call

SaveEthLogsWithHeaders is a helper method to define mock.On call

  • tx types.Querier
  • blockHeaders aggkittypes.ListBlockHeaders
  • logs []coretypes.Log
  • isFinal bool

func (*Storager_Expecter) UpdateBlockToFinalized 

func (_e *Storager_Expecter) UpdateBlockToFinalized(tx interface{}, blockNumbers interface{}) *Storager_UpdateBlockToFinalized_Call

UpdateBlockToFinalized is a helper method to define mock.On call

  • tx types.Querier
  • blockNumbers []uint64

func (*Storager_Expecter) UpdateSyncedStatus 

func (_e *Storager_Expecter) UpdateSyncedStatus(tx interface{}, segments interface{}) *Storager_UpdateSyncedStatus_Call

UpdateSyncedStatus is a helper method to define mock.On call

  • tx types.Querier
  • segments []multidownloadertypes.SyncSegment

func (*Storager_Expecter) UpdateValue 

func (_e *Storager_Expecter) UpdateValue(tx interface{}, owner interface{}, key interface{}, value interface{}) *Storager_UpdateValue_Call

UpdateValue is a helper method to define mock.On call

  • tx types.Querier
  • owner string
  • key string
  • value string

func (*Storager_Expecter) UpsertSyncerConfigs 

func (_e *Storager_Expecter) UpsertSyncerConfigs(tx interface{}, configs interface{}) *Storager_UpsertSyncerConfigs_Call

UpsertSyncerConfigs is a helper method to define mock.On call

  • tx types.Querier
  • configs []multidownloadertypes.ContractConfig

type Storager_GetBlockHeaderByNumber_Call 

type Storager_GetBlockHeaderByNumber_Call struct {
	*mock.Call
}

Storager_GetBlockHeaderByNumber_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetBlockHeaderByNumber'

func (*Storager_GetBlockHeaderByNumber_Call) Return 

func (_c *Storager_GetBlockHeaderByNumber_Call) Return(_a0 *aggkittypes.BlockHeader, _a1 multidownloadertypes.FinalizedType, _a2 error) *Storager_GetBlockHeaderByNumber_Call

func (*Storager_GetBlockHeaderByNumber_Call) Run 

func (_c *Storager_GetBlockHeaderByNumber_Call) Run(run func(tx types.Querier, blockNumber uint64)) *Storager_GetBlockHeaderByNumber_Call

func (*Storager_GetBlockHeaderByNumber_Call) RunAndReturn 

func (_c *Storager_GetBlockHeaderByNumber_Call) RunAndReturn(run func(types.Querier, uint64) (*aggkittypes.BlockHeader, multidownloadertypes.FinalizedType, error)) *Storager_GetBlockHeaderByNumber_Call

type Storager_GetBlockHeadersNotFinalized_Call 

type Storager_GetBlockHeadersNotFinalized_Call struct {
	*mock.Call
}

Storager_GetBlockHeadersNotFinalized_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetBlockHeadersNotFinalized'

func (*Storager_GetBlockHeadersNotFinalized_Call) Return 

func (_c *Storager_GetBlockHeadersNotFinalized_Call) Return(_a0 aggkittypes.ListBlockHeaders, _a1 error) *Storager_GetBlockHeadersNotFinalized_Call

func (*Storager_GetBlockHeadersNotFinalized_Call) Run 

func (_c *Storager_GetBlockHeadersNotFinalized_Call) Run(run func(tx types.Querier, maxBlock *uint64)) *Storager_GetBlockHeadersNotFinalized_Call

func (*Storager_GetBlockHeadersNotFinalized_Call) RunAndReturn 

func (_c *Storager_GetBlockHeadersNotFinalized_Call) RunAndReturn(run func(types.Querier, *uint64) (aggkittypes.ListBlockHeaders, error)) *Storager_GetBlockHeadersNotFinalized_Call

type Storager_GetBlockReorgedReorgID_Call 

type Storager_GetBlockReorgedReorgID_Call struct {
	*mock.Call
}

Storager_GetBlockReorgedReorgID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetBlockReorgedReorgID'

func (*Storager_GetBlockReorgedReorgID_Call) Return 

func (_c *Storager_GetBlockReorgedReorgID_Call) Return(_a0 uint64, _a1 bool, _a2 error) *Storager_GetBlockReorgedReorgID_Call

func (*Storager_GetBlockReorgedReorgID_Call) Run 

func (_c *Storager_GetBlockReorgedReorgID_Call) Run(run func(tx types.Querier, blockNumber uint64, blockHash common.Hash)) *Storager_GetBlockReorgedReorgID_Call

func (*Storager_GetBlockReorgedReorgID_Call) RunAndReturn 

func (_c *Storager_GetBlockReorgedReorgID_Call) RunAndReturn(run func(types.Querier, uint64, common.Hash) (uint64, bool, error)) *Storager_GetBlockReorgedReorgID_Call

type Storager_GetEthLogs_Call 

type Storager_GetEthLogs_Call struct {
	*mock.Call
}

Storager_GetEthLogs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetEthLogs'

func (*Storager_GetEthLogs_Call) Return 

func (_c *Storager_GetEthLogs_Call) Return(_a0 []coretypes.Log, _a1 error) *Storager_GetEthLogs_Call

func (*Storager_GetEthLogs_Call) Run 

func (_c *Storager_GetEthLogs_Call) Run(run func(tx types.Querier, query multidownloadertypes.LogQuery)) *Storager_GetEthLogs_Call

func (*Storager_GetEthLogs_Call) RunAndReturn 

func (_c *Storager_GetEthLogs_Call) RunAndReturn(run func(types.Querier, multidownloadertypes.LogQuery) ([]coretypes.Log, error)) *Storager_GetEthLogs_Call

type Storager_GetHighestBlockNumber_Call 

type Storager_GetHighestBlockNumber_Call struct {
	*mock.Call
}

Storager_GetHighestBlockNumber_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetHighestBlockNumber'

func (*Storager_GetHighestBlockNumber_Call) Return 

func (_c *Storager_GetHighestBlockNumber_Call) Return(_a0 uint64, _a1 error) *Storager_GetHighestBlockNumber_Call

func (*Storager_GetHighestBlockNumber_Call) Run 

func (_c *Storager_GetHighestBlockNumber_Call) Run(run func(tx types.Querier)) *Storager_GetHighestBlockNumber_Call

func (*Storager_GetHighestBlockNumber_Call) RunAndReturn 

func (_c *Storager_GetHighestBlockNumber_Call) RunAndReturn(run func(types.Querier) (uint64, error)) *Storager_GetHighestBlockNumber_Call

type Storager_GetRangeBlockHeader_Call 

type Storager_GetRangeBlockHeader_Call struct {
	*mock.Call
}

Storager_GetRangeBlockHeader_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetRangeBlockHeader'

func (*Storager_GetRangeBlockHeader_Call) Return 

func (_c *Storager_GetRangeBlockHeader_Call) Return(lowest *aggkittypes.BlockHeader, highest *aggkittypes.BlockHeader, err error) *Storager_GetRangeBlockHeader_Call

func (*Storager_GetRangeBlockHeader_Call) Run 

func (_c *Storager_GetRangeBlockHeader_Call) Run(run func(tx types.Querier, isFinal multidownloadertypes.FinalizedType)) *Storager_GetRangeBlockHeader_Call

func (*Storager_GetRangeBlockHeader_Call) RunAndReturn 

func (_c *Storager_GetRangeBlockHeader_Call) RunAndReturn(run func(types.Querier, multidownloadertypes.FinalizedType) (*aggkittypes.BlockHeader, *aggkittypes.BlockHeader, error)) *Storager_GetRangeBlockHeader_Call

type Storager_GetReorgedDataByReorgID_Call 

type Storager_GetReorgedDataByReorgID_Call struct {
	*mock.Call
}

Storager_GetReorgedDataByReorgID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetReorgedDataByReorgID'

func (*Storager_GetReorgedDataByReorgID_Call) Return 

func (_c *Storager_GetReorgedDataByReorgID_Call) Return(_a0 *multidownloadertypes.ReorgData, _a1 error) *Storager_GetReorgedDataByReorgID_Call

func (*Storager_GetReorgedDataByReorgID_Call) Run 

func (_c *Storager_GetReorgedDataByReorgID_Call) Run(run func(tx types.Querier, reorgID uint64)) *Storager_GetReorgedDataByReorgID_Call

func (*Storager_GetReorgedDataByReorgID_Call) RunAndReturn 

func (_c *Storager_GetReorgedDataByReorgID_Call) RunAndReturn(run func(types.Querier, uint64) (*multidownloadertypes.ReorgData, error)) *Storager_GetReorgedDataByReorgID_Call

type Storager_GetSyncedBlockRangePerContract_Call 

type Storager_GetSyncedBlockRangePerContract_Call struct {
	*mock.Call
}

Storager_GetSyncedBlockRangePerContract_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSyncedBlockRangePerContract'

func (*Storager_GetSyncedBlockRangePerContract_Call) Return 

func (_c *Storager_GetSyncedBlockRangePerContract_Call) Return(_a0 multidownloadertypes.SetSyncSegment, _a1 error) *Storager_GetSyncedBlockRangePerContract_Call

func (*Storager_GetSyncedBlockRangePerContract_Call) Run 

func (_c *Storager_GetSyncedBlockRangePerContract_Call) Run(run func(tx types.Querier)) *Storager_GetSyncedBlockRangePerContract_Call

func (*Storager_GetSyncedBlockRangePerContract_Call) RunAndReturn 

func (_c *Storager_GetSyncedBlockRangePerContract_Call) RunAndReturn(run func(types.Querier) (multidownloadertypes.SetSyncSegment, error)) *Storager_GetSyncedBlockRangePerContract_Call

type Storager_GetValue_Call 

type Storager_GetValue_Call struct {
	*mock.Call
}

Storager_GetValue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetValue'

func (*Storager_GetValue_Call) Return 

func (_c *Storager_GetValue_Call) Return(_a0 string, _a1 error) *Storager_GetValue_Call

func (*Storager_GetValue_Call) Run 

func (_c *Storager_GetValue_Call) Run(run func(tx types.Querier, owner string, key string)) *Storager_GetValue_Call

func (*Storager_GetValue_Call) RunAndReturn 

func (_c *Storager_GetValue_Call) RunAndReturn(run func(types.Querier, string, string) (string, error)) *Storager_GetValue_Call

type Storager_InsertReorgAndMoveReorgedBlocksAndLogs_Call 

type Storager_InsertReorgAndMoveReorgedBlocksAndLogs_Call struct {
	*mock.Call
}

Storager_InsertReorgAndMoveReorgedBlocksAndLogs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InsertReorgAndMoveReorgedBlocksAndLogs'

func (*Storager_InsertReorgAndMoveReorgedBlocksAndLogs_Call) Return 

func (_c *Storager_InsertReorgAndMoveReorgedBlocksAndLogs_Call) Return(_a0 uint64, _a1 error) *Storager_InsertReorgAndMoveReorgedBlocksAndLogs_Call

func (*Storager_InsertReorgAndMoveReorgedBlocksAndLogs_Call) Run 

func (_c *Storager_InsertReorgAndMoveReorgedBlocksAndLogs_Call) Run(run func(tx types.Querier, reorgData multidownloadertypes.ReorgData)) *Storager_InsertReorgAndMoveReorgedBlocksAndLogs_Call

func (*Storager_InsertReorgAndMoveReorgedBlocksAndLogs_Call) RunAndReturn 

func (_c *Storager_InsertReorgAndMoveReorgedBlocksAndLogs_Call) RunAndReturn(run func(types.Querier, multidownloadertypes.ReorgData) (uint64, error)) *Storager_InsertReorgAndMoveReorgedBlocksAndLogs_Call

type Storager_InsertValue_Call 

type Storager_InsertValue_Call struct {
	*mock.Call
}

Storager_InsertValue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InsertValue'

func (*Storager_InsertValue_Call) Return 

func (_c *Storager_InsertValue_Call) Return(_a0 error) *Storager_InsertValue_Call

func (*Storager_InsertValue_Call) Run 

func (_c *Storager_InsertValue_Call) Run(run func(tx types.Querier, owner string, key string, value string)) *Storager_InsertValue_Call

func (*Storager_InsertValue_Call) RunAndReturn 

func (_c *Storager_InsertValue_Call) RunAndReturn(run func(types.Querier, string, string, string) error) *Storager_InsertValue_Call

type Storager_LogQuery_Call 

type Storager_LogQuery_Call struct {
	*mock.Call
}

Storager_LogQuery_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LogQuery'

func (*Storager_LogQuery_Call) Return 

func (_c *Storager_LogQuery_Call) Return(_a0 multidownloadertypes.LogQueryResponse, _a1 error) *Storager_LogQuery_Call

func (*Storager_LogQuery_Call) Run 

func (_c *Storager_LogQuery_Call) Run(run func(tx types.Querier, query multidownloadertypes.LogQuery)) *Storager_LogQuery_Call

func (*Storager_LogQuery_Call) RunAndReturn 

func (_c *Storager_LogQuery_Call) RunAndReturn(run func(types.Querier, multidownloadertypes.LogQuery) (multidownloadertypes.LogQueryResponse, error)) *Storager_LogQuery_Call

type Storager_NewTx_Call 

type Storager_NewTx_Call struct {
	*mock.Call
}

Storager_NewTx_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewTx'

func (*Storager_NewTx_Call) Return 

func (_c *Storager_NewTx_Call) Return(_a0 types.Txer, _a1 error) *Storager_NewTx_Call

func (*Storager_NewTx_Call) Run 

func (_c *Storager_NewTx_Call) Run(run func(ctx context.Context)) *Storager_NewTx_Call

func (*Storager_NewTx_Call) RunAndReturn 

func (_c *Storager_NewTx_Call) RunAndReturn(run func(context.Context) (types.Txer, error)) *Storager_NewTx_Call

type Storager_SaveEthLogsWithHeaders_Call 

type Storager_SaveEthLogsWithHeaders_Call struct {
	*mock.Call
}

Storager_SaveEthLogsWithHeaders_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SaveEthLogsWithHeaders'

func (*Storager_SaveEthLogsWithHeaders_Call) Return 

func (_c *Storager_SaveEthLogsWithHeaders_Call) Return(_a0 error) *Storager_SaveEthLogsWithHeaders_Call

func (*Storager_SaveEthLogsWithHeaders_Call) Run 

func (_c *Storager_SaveEthLogsWithHeaders_Call) Run(run func(tx types.Querier, blockHeaders aggkittypes.ListBlockHeaders, logs []coretypes.Log, isFinal bool)) *Storager_SaveEthLogsWithHeaders_Call

func (*Storager_SaveEthLogsWithHeaders_Call) RunAndReturn 

func (_c *Storager_SaveEthLogsWithHeaders_Call) RunAndReturn(run func(types.Querier, aggkittypes.ListBlockHeaders, []coretypes.Log, bool) error) *Storager_SaveEthLogsWithHeaders_Call

type Storager_UpdateBlockToFinalized_Call 

type Storager_UpdateBlockToFinalized_Call struct {
	*mock.Call
}

Storager_UpdateBlockToFinalized_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateBlockToFinalized'

func (*Storager_UpdateBlockToFinalized_Call) Return 

func (_c *Storager_UpdateBlockToFinalized_Call) Return(_a0 error) *Storager_UpdateBlockToFinalized_Call

func (*Storager_UpdateBlockToFinalized_Call) Run 

func (_c *Storager_UpdateBlockToFinalized_Call) Run(run func(tx types.Querier, blockNumbers []uint64)) *Storager_UpdateBlockToFinalized_Call

func (*Storager_UpdateBlockToFinalized_Call) RunAndReturn 

func (_c *Storager_UpdateBlockToFinalized_Call) RunAndReturn(run func(types.Querier, []uint64) error) *Storager_UpdateBlockToFinalized_Call

type Storager_UpdateSyncedStatus_Call 

type Storager_UpdateSyncedStatus_Call struct {
	*mock.Call
}

Storager_UpdateSyncedStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateSyncedStatus'

func (*Storager_UpdateSyncedStatus_Call) Return 

func (_c *Storager_UpdateSyncedStatus_Call) Return(_a0 error) *Storager_UpdateSyncedStatus_Call

func (*Storager_UpdateSyncedStatus_Call) Run 

func (_c *Storager_UpdateSyncedStatus_Call) Run(run func(tx types.Querier, segments []multidownloadertypes.SyncSegment)) *Storager_UpdateSyncedStatus_Call

func (*Storager_UpdateSyncedStatus_Call) RunAndReturn 

func (_c *Storager_UpdateSyncedStatus_Call) RunAndReturn(run func(types.Querier, []multidownloadertypes.SyncSegment) error) *Storager_UpdateSyncedStatus_Call

type Storager_UpdateValue_Call 

type Storager_UpdateValue_Call struct {
	*mock.Call
}

Storager_UpdateValue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateValue'

func (*Storager_UpdateValue_Call) Return 

func (_c *Storager_UpdateValue_Call) Return(_a0 error) *Storager_UpdateValue_Call

func (*Storager_UpdateValue_Call) Run 

func (_c *Storager_UpdateValue_Call) Run(run func(tx types.Querier, owner string, key string, value string)) *Storager_UpdateValue_Call

func (*Storager_UpdateValue_Call) RunAndReturn 

func (_c *Storager_UpdateValue_Call) RunAndReturn(run func(types.Querier, string, string, string) error) *Storager_UpdateValue_Call

type Storager_UpsertSyncerConfigs_Call 

type Storager_UpsertSyncerConfigs_Call struct {
	*mock.Call
}

Storager_UpsertSyncerConfigs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpsertSyncerConfigs'

func (*Storager_UpsertSyncerConfigs_Call) Return 

func (_c *Storager_UpsertSyncerConfigs_Call) Return(_a0 error) *Storager_UpsertSyncerConfigs_Call

func (*Storager_UpsertSyncerConfigs_Call) Run 

func (_c *Storager_UpsertSyncerConfigs_Call) Run(run func(tx types.Querier, configs []multidownloadertypes.ContractConfig)) *Storager_UpsertSyncerConfigs_Call

func (*Storager_UpsertSyncerConfigs_Call) RunAndReturn 

func (_c *Storager_UpsertSyncerConfigs_Call) RunAndReturn(run func(types.Querier, []multidownloadertypes.ContractConfig) error) *Storager_UpsertSyncerConfigs_Call

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.