Documentation
¶
Index ¶
- type MockIMainStorage
- func (_m *MockIMainStorage) EXPECT() *MockIMainStorage_Expecter
- func (_m *MockIMainStorage) GetAggregations(table string, qf storage.QueryFilter) (storage.QueryResult[interface{}], error)
- func (_m *MockIMainStorage) GetBlockHeadersDescending(chainId *big.Int, from *big.Int, to *big.Int) ([]common.BlockHeader, error)
- func (_m *MockIMainStorage) GetBlocks(qf storage.QueryFilter, fields ...string) (storage.QueryResult[common.Block], error)
- func (_m *MockIMainStorage) GetLogs(qf storage.QueryFilter, fields ...string) (storage.QueryResult[common.Log], error)
- func (_m *MockIMainStorage) GetMaxBlockNumber(chainId *big.Int) (*big.Int, error)
- func (_m *MockIMainStorage) GetTokenBalances(qf storage.BalancesQueryFilter, fields ...string) (storage.QueryResult[common.TokenBalance], error)
- func (_m *MockIMainStorage) GetTokenTransfers(qf storage.TransfersQueryFilter, fields ...string) (storage.QueryResult[common.TokenTransfer], error)
- func (_m *MockIMainStorage) GetTraces(qf storage.QueryFilter, fields ...string) (storage.QueryResult[common.Trace], error)
- func (_m *MockIMainStorage) GetTransactions(qf storage.QueryFilter, fields ...string) (storage.QueryResult[common.Transaction], error)
- func (_m *MockIMainStorage) InsertBlockData(data []common.BlockData) error
- func (_m *MockIMainStorage) ReplaceBlockData(data []common.BlockData) ([]common.BlockData, error)
- type MockIMainStorage_Expecter
- func (_e *MockIMainStorage_Expecter) GetAggregations(table interface{}, qf interface{}) *MockIMainStorage_GetAggregations_Call
- func (_e *MockIMainStorage_Expecter) GetBlockHeadersDescending(chainId interface{}, from interface{}, to interface{}) *MockIMainStorage_GetBlockHeadersDescending_Call
- func (_e *MockIMainStorage_Expecter) GetBlocks(qf interface{}, fields ...interface{}) *MockIMainStorage_GetBlocks_Call
- func (_e *MockIMainStorage_Expecter) GetLogs(qf interface{}, fields ...interface{}) *MockIMainStorage_GetLogs_Call
- func (_e *MockIMainStorage_Expecter) GetMaxBlockNumber(chainId interface{}) *MockIMainStorage_GetMaxBlockNumber_Call
- func (_e *MockIMainStorage_Expecter) GetTokenBalances(qf interface{}, fields ...interface{}) *MockIMainStorage_GetTokenBalances_Call
- func (_e *MockIMainStorage_Expecter) GetTokenTransfers(qf interface{}, fields ...interface{}) *MockIMainStorage_GetTokenTransfers_Call
- func (_e *MockIMainStorage_Expecter) GetTraces(qf interface{}, fields ...interface{}) *MockIMainStorage_GetTraces_Call
- func (_e *MockIMainStorage_Expecter) GetTransactions(qf interface{}, fields ...interface{}) *MockIMainStorage_GetTransactions_Call
- func (_e *MockIMainStorage_Expecter) InsertBlockData(data interface{}) *MockIMainStorage_InsertBlockData_Call
- func (_e *MockIMainStorage_Expecter) ReplaceBlockData(data interface{}) *MockIMainStorage_ReplaceBlockData_Call
- type MockIMainStorage_GetAggregations_Call
- func (_c *MockIMainStorage_GetAggregations_Call) Return(_a0 storage.QueryResult[interface{}], _a1 error) *MockIMainStorage_GetAggregations_Call
- func (_c *MockIMainStorage_GetAggregations_Call) Run(run func(table string, qf storage.QueryFilter)) *MockIMainStorage_GetAggregations_Call
- func (_c *MockIMainStorage_GetAggregations_Call) RunAndReturn(...) *MockIMainStorage_GetAggregations_Call
- type MockIMainStorage_GetBlockHeadersDescending_Call
- func (_c *MockIMainStorage_GetBlockHeadersDescending_Call) Return(blockHeaders []common.BlockHeader, err error) *MockIMainStorage_GetBlockHeadersDescending_Call
- func (_c *MockIMainStorage_GetBlockHeadersDescending_Call) Run(run func(chainId *big.Int, from *big.Int, to *big.Int)) *MockIMainStorage_GetBlockHeadersDescending_Call
- func (_c *MockIMainStorage_GetBlockHeadersDescending_Call) RunAndReturn(run func(*big.Int, *big.Int, *big.Int) ([]common.BlockHeader, error)) *MockIMainStorage_GetBlockHeadersDescending_Call
- type MockIMainStorage_GetBlocks_Call
- func (_c *MockIMainStorage_GetBlocks_Call) Return(blocks storage.QueryResult[common.Block], err error) *MockIMainStorage_GetBlocks_Call
- func (_c *MockIMainStorage_GetBlocks_Call) Run(run func(qf storage.QueryFilter, fields ...string)) *MockIMainStorage_GetBlocks_Call
- func (_c *MockIMainStorage_GetBlocks_Call) RunAndReturn(...) *MockIMainStorage_GetBlocks_Call
- type MockIMainStorage_GetLogs_Call
- func (_c *MockIMainStorage_GetLogs_Call) Return(logs storage.QueryResult[common.Log], err error) *MockIMainStorage_GetLogs_Call
- func (_c *MockIMainStorage_GetLogs_Call) Run(run func(qf storage.QueryFilter, fields ...string)) *MockIMainStorage_GetLogs_Call
- func (_c *MockIMainStorage_GetLogs_Call) RunAndReturn(...) *MockIMainStorage_GetLogs_Call
- type MockIMainStorage_GetMaxBlockNumber_Call
- func (_c *MockIMainStorage_GetMaxBlockNumber_Call) Return(maxBlockNumber *big.Int, err error) *MockIMainStorage_GetMaxBlockNumber_Call
- func (_c *MockIMainStorage_GetMaxBlockNumber_Call) Run(run func(chainId *big.Int)) *MockIMainStorage_GetMaxBlockNumber_Call
- func (_c *MockIMainStorage_GetMaxBlockNumber_Call) RunAndReturn(run func(*big.Int) (*big.Int, error)) *MockIMainStorage_GetMaxBlockNumber_Call
- type MockIMainStorage_GetTokenBalances_Call
- func (_c *MockIMainStorage_GetTokenBalances_Call) Return(_a0 storage.QueryResult[common.TokenBalance], _a1 error) *MockIMainStorage_GetTokenBalances_Call
- func (_c *MockIMainStorage_GetTokenBalances_Call) Run(run func(qf storage.BalancesQueryFilter, fields ...string)) *MockIMainStorage_GetTokenBalances_Call
- func (_c *MockIMainStorage_GetTokenBalances_Call) RunAndReturn(...) *MockIMainStorage_GetTokenBalances_Call
- type MockIMainStorage_GetTokenTransfers_Call
- func (_c *MockIMainStorage_GetTokenTransfers_Call) Return(_a0 storage.QueryResult[common.TokenTransfer], _a1 error) *MockIMainStorage_GetTokenTransfers_Call
- func (_c *MockIMainStorage_GetTokenTransfers_Call) Run(run func(qf storage.TransfersQueryFilter, fields ...string)) *MockIMainStorage_GetTokenTransfers_Call
- func (_c *MockIMainStorage_GetTokenTransfers_Call) RunAndReturn(...) *MockIMainStorage_GetTokenTransfers_Call
- type MockIMainStorage_GetTraces_Call
- func (_c *MockIMainStorage_GetTraces_Call) Return(traces storage.QueryResult[common.Trace], err error) *MockIMainStorage_GetTraces_Call
- func (_c *MockIMainStorage_GetTraces_Call) Run(run func(qf storage.QueryFilter, fields ...string)) *MockIMainStorage_GetTraces_Call
- func (_c *MockIMainStorage_GetTraces_Call) RunAndReturn(...) *MockIMainStorage_GetTraces_Call
- type MockIMainStorage_GetTransactions_Call
- func (_c *MockIMainStorage_GetTransactions_Call) Return(transactions storage.QueryResult[common.Transaction], err error) *MockIMainStorage_GetTransactions_Call
- func (_c *MockIMainStorage_GetTransactions_Call) Run(run func(qf storage.QueryFilter, fields ...string)) *MockIMainStorage_GetTransactions_Call
- func (_c *MockIMainStorage_GetTransactions_Call) RunAndReturn(...) *MockIMainStorage_GetTransactions_Call
- type MockIMainStorage_InsertBlockData_Call
- func (_c *MockIMainStorage_InsertBlockData_Call) Return(_a0 error) *MockIMainStorage_InsertBlockData_Call
- func (_c *MockIMainStorage_InsertBlockData_Call) Run(run func(data []common.BlockData)) *MockIMainStorage_InsertBlockData_Call
- func (_c *MockIMainStorage_InsertBlockData_Call) RunAndReturn(run func([]common.BlockData) error) *MockIMainStorage_InsertBlockData_Call
- type MockIMainStorage_ReplaceBlockData_Call
- func (_c *MockIMainStorage_ReplaceBlockData_Call) Return(_a0 []common.BlockData, _a1 error) *MockIMainStorage_ReplaceBlockData_Call
- func (_c *MockIMainStorage_ReplaceBlockData_Call) Run(run func(data []common.BlockData)) *MockIMainStorage_ReplaceBlockData_Call
- func (_c *MockIMainStorage_ReplaceBlockData_Call) RunAndReturn(run func([]common.BlockData) ([]common.BlockData, error)) *MockIMainStorage_ReplaceBlockData_Call
- type MockIOrchestratorStorage
- func (_m *MockIOrchestratorStorage) DeleteBlockFailures(failures []common.BlockFailure) error
- func (_m *MockIOrchestratorStorage) EXPECT() *MockIOrchestratorStorage_Expecter
- func (_m *MockIOrchestratorStorage) GetBlockFailures(qf storage.QueryFilter) ([]common.BlockFailure, error)
- func (_m *MockIOrchestratorStorage) GetLastReorgCheckedBlockNumber(chainId *big.Int) (*big.Int, error)
- func (_m *MockIOrchestratorStorage) SetLastReorgCheckedBlockNumber(chainId *big.Int, blockNumber *big.Int) error
- func (_m *MockIOrchestratorStorage) StoreBlockFailures(failures []common.BlockFailure) error
- type MockIOrchestratorStorage_DeleteBlockFailures_Call
- func (_c *MockIOrchestratorStorage_DeleteBlockFailures_Call) Return(_a0 error) *MockIOrchestratorStorage_DeleteBlockFailures_Call
- func (_c *MockIOrchestratorStorage_DeleteBlockFailures_Call) Run(run func(failures []common.BlockFailure)) *MockIOrchestratorStorage_DeleteBlockFailures_Call
- func (_c *MockIOrchestratorStorage_DeleteBlockFailures_Call) RunAndReturn(run func([]common.BlockFailure) error) *MockIOrchestratorStorage_DeleteBlockFailures_Call
- type MockIOrchestratorStorage_Expecter
- func (_e *MockIOrchestratorStorage_Expecter) DeleteBlockFailures(failures interface{}) *MockIOrchestratorStorage_DeleteBlockFailures_Call
- func (_e *MockIOrchestratorStorage_Expecter) GetBlockFailures(qf interface{}) *MockIOrchestratorStorage_GetBlockFailures_Call
- func (_e *MockIOrchestratorStorage_Expecter) GetLastReorgCheckedBlockNumber(chainId interface{}) *MockIOrchestratorStorage_GetLastReorgCheckedBlockNumber_Call
- func (_e *MockIOrchestratorStorage_Expecter) SetLastReorgCheckedBlockNumber(chainId interface{}, blockNumber interface{}) *MockIOrchestratorStorage_SetLastReorgCheckedBlockNumber_Call
- func (_e *MockIOrchestratorStorage_Expecter) StoreBlockFailures(failures interface{}) *MockIOrchestratorStorage_StoreBlockFailures_Call
- type MockIOrchestratorStorage_GetBlockFailures_Call
- func (_c *MockIOrchestratorStorage_GetBlockFailures_Call) Return(_a0 []common.BlockFailure, _a1 error) *MockIOrchestratorStorage_GetBlockFailures_Call
- func (_c *MockIOrchestratorStorage_GetBlockFailures_Call) Run(run func(qf storage.QueryFilter)) *MockIOrchestratorStorage_GetBlockFailures_Call
- func (_c *MockIOrchestratorStorage_GetBlockFailures_Call) RunAndReturn(run func(storage.QueryFilter) ([]common.BlockFailure, error)) *MockIOrchestratorStorage_GetBlockFailures_Call
- type MockIOrchestratorStorage_GetLastReorgCheckedBlockNumber_Call
- func (_c *MockIOrchestratorStorage_GetLastReorgCheckedBlockNumber_Call) Return(_a0 *big.Int, _a1 error) *MockIOrchestratorStorage_GetLastReorgCheckedBlockNumber_Call
- func (_c *MockIOrchestratorStorage_GetLastReorgCheckedBlockNumber_Call) Run(run func(chainId *big.Int)) *MockIOrchestratorStorage_GetLastReorgCheckedBlockNumber_Call
- func (_c *MockIOrchestratorStorage_GetLastReorgCheckedBlockNumber_Call) RunAndReturn(run func(*big.Int) (*big.Int, error)) *MockIOrchestratorStorage_GetLastReorgCheckedBlockNumber_Call
- type MockIOrchestratorStorage_SetLastReorgCheckedBlockNumber_Call
- func (_c *MockIOrchestratorStorage_SetLastReorgCheckedBlockNumber_Call) Return(_a0 error) *MockIOrchestratorStorage_SetLastReorgCheckedBlockNumber_Call
- func (_c *MockIOrchestratorStorage_SetLastReorgCheckedBlockNumber_Call) Run(run func(chainId *big.Int, blockNumber *big.Int)) *MockIOrchestratorStorage_SetLastReorgCheckedBlockNumber_Call
- func (_c *MockIOrchestratorStorage_SetLastReorgCheckedBlockNumber_Call) RunAndReturn(run func(*big.Int, *big.Int) error) *MockIOrchestratorStorage_SetLastReorgCheckedBlockNumber_Call
- type MockIOrchestratorStorage_StoreBlockFailures_Call
- func (_c *MockIOrchestratorStorage_StoreBlockFailures_Call) Return(_a0 error) *MockIOrchestratorStorage_StoreBlockFailures_Call
- func (_c *MockIOrchestratorStorage_StoreBlockFailures_Call) Run(run func(failures []common.BlockFailure)) *MockIOrchestratorStorage_StoreBlockFailures_Call
- func (_c *MockIOrchestratorStorage_StoreBlockFailures_Call) RunAndReturn(run func([]common.BlockFailure) error) *MockIOrchestratorStorage_StoreBlockFailures_Call
- type MockIRPCClient
- func (_m *MockIRPCClient) Close()
- func (_m *MockIRPCClient) EXPECT() *MockIRPCClient_Expecter
- func (_m *MockIRPCClient) GetBlocks(ctx context.Context, blockNumbers []*big.Int) []rpc.GetBlocksResult
- func (_m *MockIRPCClient) GetBlocksPerRequest() rpc.BlocksPerRequestConfig
- func (_m *MockIRPCClient) GetChainID() *big.Int
- func (_m *MockIRPCClient) GetFullBlocks(ctx context.Context, blockNumbers []*big.Int) []rpc.GetFullBlockResult
- func (_m *MockIRPCClient) GetLatestBlockNumber(ctx context.Context) (*big.Int, error)
- func (_m *MockIRPCClient) GetTransactions(ctx context.Context, txHashes []string) []rpc.GetTransactionsResult
- func (_m *MockIRPCClient) GetURL() string
- func (_m *MockIRPCClient) HasCode(ctx context.Context, address string) (bool, error)
- func (_m *MockIRPCClient) IsWebsocket() bool
- func (_m *MockIRPCClient) SupportsTraceBlock() bool
- type MockIRPCClient_Close_Call
- type MockIRPCClient_Expecter
- func (_e *MockIRPCClient_Expecter) Close() *MockIRPCClient_Close_Call
- func (_e *MockIRPCClient_Expecter) GetBlocks(ctx interface{}, blockNumbers interface{}) *MockIRPCClient_GetBlocks_Call
- func (_e *MockIRPCClient_Expecter) GetBlocksPerRequest() *MockIRPCClient_GetBlocksPerRequest_Call
- func (_e *MockIRPCClient_Expecter) GetChainID() *MockIRPCClient_GetChainID_Call
- func (_e *MockIRPCClient_Expecter) GetFullBlocks(ctx interface{}, blockNumbers interface{}) *MockIRPCClient_GetFullBlocks_Call
- func (_e *MockIRPCClient_Expecter) GetLatestBlockNumber(ctx interface{}) *MockIRPCClient_GetLatestBlockNumber_Call
- func (_e *MockIRPCClient_Expecter) GetTransactions(ctx interface{}, txHashes interface{}) *MockIRPCClient_GetTransactions_Call
- func (_e *MockIRPCClient_Expecter) GetURL() *MockIRPCClient_GetURL_Call
- func (_e *MockIRPCClient_Expecter) HasCode(ctx interface{}, address interface{}) *MockIRPCClient_HasCode_Call
- func (_e *MockIRPCClient_Expecter) IsWebsocket() *MockIRPCClient_IsWebsocket_Call
- func (_e *MockIRPCClient_Expecter) SupportsTraceBlock() *MockIRPCClient_SupportsTraceBlock_Call
- type MockIRPCClient_GetBlocksPerRequest_Call
- func (_c *MockIRPCClient_GetBlocksPerRequest_Call) Return(_a0 rpc.BlocksPerRequestConfig) *MockIRPCClient_GetBlocksPerRequest_Call
- func (_c *MockIRPCClient_GetBlocksPerRequest_Call) Run(run func()) *MockIRPCClient_GetBlocksPerRequest_Call
- func (_c *MockIRPCClient_GetBlocksPerRequest_Call) RunAndReturn(run func() rpc.BlocksPerRequestConfig) *MockIRPCClient_GetBlocksPerRequest_Call
- type MockIRPCClient_GetBlocks_Call
- func (_c *MockIRPCClient_GetBlocks_Call) Return(_a0 []rpc.GetBlocksResult) *MockIRPCClient_GetBlocks_Call
- func (_c *MockIRPCClient_GetBlocks_Call) Run(run func(ctx context.Context, blockNumbers []*big.Int)) *MockIRPCClient_GetBlocks_Call
- func (_c *MockIRPCClient_GetBlocks_Call) RunAndReturn(run func(context.Context, []*big.Int) []rpc.GetBlocksResult) *MockIRPCClient_GetBlocks_Call
- type MockIRPCClient_GetChainID_Call
- type MockIRPCClient_GetFullBlocks_Call
- func (_c *MockIRPCClient_GetFullBlocks_Call) Return(_a0 []rpc.GetFullBlockResult) *MockIRPCClient_GetFullBlocks_Call
- func (_c *MockIRPCClient_GetFullBlocks_Call) Run(run func(ctx context.Context, blockNumbers []*big.Int)) *MockIRPCClient_GetFullBlocks_Call
- func (_c *MockIRPCClient_GetFullBlocks_Call) RunAndReturn(run func(context.Context, []*big.Int) []rpc.GetFullBlockResult) *MockIRPCClient_GetFullBlocks_Call
- type MockIRPCClient_GetLatestBlockNumber_Call
- func (_c *MockIRPCClient_GetLatestBlockNumber_Call) Return(_a0 *big.Int, _a1 error) *MockIRPCClient_GetLatestBlockNumber_Call
- func (_c *MockIRPCClient_GetLatestBlockNumber_Call) Run(run func(ctx context.Context)) *MockIRPCClient_GetLatestBlockNumber_Call
- func (_c *MockIRPCClient_GetLatestBlockNumber_Call) RunAndReturn(run func(context.Context) (*big.Int, error)) *MockIRPCClient_GetLatestBlockNumber_Call
- type MockIRPCClient_GetTransactions_Call
- func (_c *MockIRPCClient_GetTransactions_Call) Return(_a0 []rpc.GetTransactionsResult) *MockIRPCClient_GetTransactions_Call
- func (_c *MockIRPCClient_GetTransactions_Call) Run(run func(ctx context.Context, txHashes []string)) *MockIRPCClient_GetTransactions_Call
- func (_c *MockIRPCClient_GetTransactions_Call) RunAndReturn(run func(context.Context, []string) []rpc.GetTransactionsResult) *MockIRPCClient_GetTransactions_Call
- type MockIRPCClient_GetURL_Call
- type MockIRPCClient_HasCode_Call
- func (_c *MockIRPCClient_HasCode_Call) Return(_a0 bool, _a1 error) *MockIRPCClient_HasCode_Call
- func (_c *MockIRPCClient_HasCode_Call) Run(run func(ctx context.Context, address string)) *MockIRPCClient_HasCode_Call
- func (_c *MockIRPCClient_HasCode_Call) RunAndReturn(run func(context.Context, string) (bool, error)) *MockIRPCClient_HasCode_Call
- type MockIRPCClient_IsWebsocket_Call
- type MockIRPCClient_SupportsTraceBlock_Call
- func (_c *MockIRPCClient_SupportsTraceBlock_Call) Return(_a0 bool) *MockIRPCClient_SupportsTraceBlock_Call
- func (_c *MockIRPCClient_SupportsTraceBlock_Call) Run(run func()) *MockIRPCClient_SupportsTraceBlock_Call
- func (_c *MockIRPCClient_SupportsTraceBlock_Call) RunAndReturn(run func() bool) *MockIRPCClient_SupportsTraceBlock_Call
- type MockIStagingStorage
- func (_m *MockIStagingStorage) DeleteStagingData(data []common.BlockData) error
- func (_m *MockIStagingStorage) EXPECT() *MockIStagingStorage_Expecter
- func (_m *MockIStagingStorage) GetLastStagedBlockNumber(chainId *big.Int, rangeStart *big.Int, rangeEnd *big.Int) (*big.Int, error)
- func (_m *MockIStagingStorage) GetStagingData(qf storage.QueryFilter) ([]common.BlockData, error)
- func (_m *MockIStagingStorage) InsertStagingData(data []common.BlockData) error
- type MockIStagingStorage_DeleteStagingData_Call
- func (_c *MockIStagingStorage_DeleteStagingData_Call) Return(_a0 error) *MockIStagingStorage_DeleteStagingData_Call
- func (_c *MockIStagingStorage_DeleteStagingData_Call) Run(run func(data []common.BlockData)) *MockIStagingStorage_DeleteStagingData_Call
- func (_c *MockIStagingStorage_DeleteStagingData_Call) RunAndReturn(run func([]common.BlockData) error) *MockIStagingStorage_DeleteStagingData_Call
- type MockIStagingStorage_Expecter
- func (_e *MockIStagingStorage_Expecter) DeleteStagingData(data interface{}) *MockIStagingStorage_DeleteStagingData_Call
- func (_e *MockIStagingStorage_Expecter) GetLastStagedBlockNumber(chainId interface{}, rangeStart interface{}, rangeEnd interface{}) *MockIStagingStorage_GetLastStagedBlockNumber_Call
- func (_e *MockIStagingStorage_Expecter) GetStagingData(qf interface{}) *MockIStagingStorage_GetStagingData_Call
- func (_e *MockIStagingStorage_Expecter) InsertStagingData(data interface{}) *MockIStagingStorage_InsertStagingData_Call
- type MockIStagingStorage_GetLastStagedBlockNumber_Call
- func (_c *MockIStagingStorage_GetLastStagedBlockNumber_Call) Return(maxBlockNumber *big.Int, err error) *MockIStagingStorage_GetLastStagedBlockNumber_Call
- func (_c *MockIStagingStorage_GetLastStagedBlockNumber_Call) Run(run func(chainId *big.Int, rangeStart *big.Int, rangeEnd *big.Int)) *MockIStagingStorage_GetLastStagedBlockNumber_Call
- func (_c *MockIStagingStorage_GetLastStagedBlockNumber_Call) RunAndReturn(run func(*big.Int, *big.Int, *big.Int) (*big.Int, error)) *MockIStagingStorage_GetLastStagedBlockNumber_Call
- type MockIStagingStorage_GetStagingData_Call
- func (_c *MockIStagingStorage_GetStagingData_Call) Return(data []common.BlockData, err error) *MockIStagingStorage_GetStagingData_Call
- func (_c *MockIStagingStorage_GetStagingData_Call) Run(run func(qf storage.QueryFilter)) *MockIStagingStorage_GetStagingData_Call
- func (_c *MockIStagingStorage_GetStagingData_Call) RunAndReturn(run func(storage.QueryFilter) ([]common.BlockData, error)) *MockIStagingStorage_GetStagingData_Call
- type MockIStagingStorage_InsertStagingData_Call
- func (_c *MockIStagingStorage_InsertStagingData_Call) Return(_a0 error) *MockIStagingStorage_InsertStagingData_Call
- func (_c *MockIStagingStorage_InsertStagingData_Call) Run(run func(data []common.BlockData)) *MockIStagingStorage_InsertStagingData_Call
- func (_c *MockIStagingStorage_InsertStagingData_Call) RunAndReturn(run func([]common.BlockData) error) *MockIStagingStorage_InsertStagingData_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockIMainStorage ¶
MockIMainStorage is an autogenerated mock type for the IMainStorage type
func NewMockIMainStorage ¶
func NewMockIMainStorage(t interface { mock.TestingT Cleanup(func()) }) *MockIMainStorage
NewMockIMainStorage creates a new instance of MockIMainStorage. 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 (*MockIMainStorage) EXPECT ¶
func (_m *MockIMainStorage) EXPECT() *MockIMainStorage_Expecter
func (*MockIMainStorage) GetAggregations ¶
func (_m *MockIMainStorage) GetAggregations(table string, qf storage.QueryFilter) (storage.QueryResult[interface{}], error)
GetAggregations provides a mock function with given fields: table, qf
func (*MockIMainStorage) GetBlockHeadersDescending ¶
func (_m *MockIMainStorage) GetBlockHeadersDescending(chainId *big.Int, from *big.Int, to *big.Int) ([]common.BlockHeader, error)
GetBlockHeadersDescending provides a mock function with given fields: chainId, from, to
func (*MockIMainStorage) GetBlocks ¶
func (_m *MockIMainStorage) GetBlocks(qf storage.QueryFilter, fields ...string) (storage.QueryResult[common.Block], error)
GetBlocks provides a mock function with given fields: qf, fields
func (*MockIMainStorage) GetLogs ¶
func (_m *MockIMainStorage) GetLogs(qf storage.QueryFilter, fields ...string) (storage.QueryResult[common.Log], error)
GetLogs provides a mock function with given fields: qf, fields
func (*MockIMainStorage) GetMaxBlockNumber ¶
GetMaxBlockNumber provides a mock function with given fields: chainId
func (*MockIMainStorage) GetTokenBalances ¶
func (_m *MockIMainStorage) GetTokenBalances(qf storage.BalancesQueryFilter, fields ...string) (storage.QueryResult[common.TokenBalance], error)
GetTokenBalances provides a mock function with given fields: qf, fields
func (*MockIMainStorage) GetTokenTransfers ¶
func (_m *MockIMainStorage) GetTokenTransfers(qf storage.TransfersQueryFilter, fields ...string) (storage.QueryResult[common.TokenTransfer], error)
GetTokenTransfers provides a mock function with given fields: qf, fields
func (*MockIMainStorage) GetTraces ¶
func (_m *MockIMainStorage) GetTraces(qf storage.QueryFilter, fields ...string) (storage.QueryResult[common.Trace], error)
GetTraces provides a mock function with given fields: qf, fields
func (*MockIMainStorage) GetTransactions ¶
func (_m *MockIMainStorage) GetTransactions(qf storage.QueryFilter, fields ...string) (storage.QueryResult[common.Transaction], error)
GetTransactions provides a mock function with given fields: qf, fields
func (*MockIMainStorage) InsertBlockData ¶
func (_m *MockIMainStorage) InsertBlockData(data []common.BlockData) error
InsertBlockData provides a mock function with given fields: data
func (*MockIMainStorage) ReplaceBlockData ¶
ReplaceBlockData provides a mock function with given fields: data
type MockIMainStorage_Expecter ¶
type MockIMainStorage_Expecter struct {
// contains filtered or unexported fields
}
func (*MockIMainStorage_Expecter) GetAggregations ¶
func (_e *MockIMainStorage_Expecter) GetAggregations(table interface{}, qf interface{}) *MockIMainStorage_GetAggregations_Call
GetAggregations is a helper method to define mock.On call
- table string
- qf storage.QueryFilter
func (*MockIMainStorage_Expecter) GetBlockHeadersDescending ¶
func (_e *MockIMainStorage_Expecter) GetBlockHeadersDescending(chainId interface{}, from interface{}, to interface{}) *MockIMainStorage_GetBlockHeadersDescending_Call
GetBlockHeadersDescending is a helper method to define mock.On call
- chainId *big.Int
- from *big.Int
- to *big.Int
func (*MockIMainStorage_Expecter) GetBlocks ¶
func (_e *MockIMainStorage_Expecter) GetBlocks(qf interface{}, fields ...interface{}) *MockIMainStorage_GetBlocks_Call
GetBlocks is a helper method to define mock.On call
- qf storage.QueryFilter
- fields ...string
func (*MockIMainStorage_Expecter) GetLogs ¶
func (_e *MockIMainStorage_Expecter) GetLogs(qf interface{}, fields ...interface{}) *MockIMainStorage_GetLogs_Call
GetLogs is a helper method to define mock.On call
- qf storage.QueryFilter
- fields ...string
func (*MockIMainStorage_Expecter) GetMaxBlockNumber ¶
func (_e *MockIMainStorage_Expecter) GetMaxBlockNumber(chainId interface{}) *MockIMainStorage_GetMaxBlockNumber_Call
GetMaxBlockNumber is a helper method to define mock.On call
- chainId *big.Int
func (*MockIMainStorage_Expecter) GetTokenBalances ¶
func (_e *MockIMainStorage_Expecter) GetTokenBalances(qf interface{}, fields ...interface{}) *MockIMainStorage_GetTokenBalances_Call
GetTokenBalances is a helper method to define mock.On call
- qf storage.BalancesQueryFilter
- fields ...string
func (*MockIMainStorage_Expecter) GetTokenTransfers ¶
func (_e *MockIMainStorage_Expecter) GetTokenTransfers(qf interface{}, fields ...interface{}) *MockIMainStorage_GetTokenTransfers_Call
GetTokenTransfers is a helper method to define mock.On call
- qf storage.TransfersQueryFilter
- fields ...string
func (*MockIMainStorage_Expecter) GetTraces ¶
func (_e *MockIMainStorage_Expecter) GetTraces(qf interface{}, fields ...interface{}) *MockIMainStorage_GetTraces_Call
GetTraces is a helper method to define mock.On call
- qf storage.QueryFilter
- fields ...string
func (*MockIMainStorage_Expecter) GetTransactions ¶
func (_e *MockIMainStorage_Expecter) GetTransactions(qf interface{}, fields ...interface{}) *MockIMainStorage_GetTransactions_Call
GetTransactions is a helper method to define mock.On call
- qf storage.QueryFilter
- fields ...string
func (*MockIMainStorage_Expecter) InsertBlockData ¶
func (_e *MockIMainStorage_Expecter) InsertBlockData(data interface{}) *MockIMainStorage_InsertBlockData_Call
InsertBlockData is a helper method to define mock.On call
- data []common.BlockData
func (*MockIMainStorage_Expecter) ReplaceBlockData ¶
func (_e *MockIMainStorage_Expecter) ReplaceBlockData(data interface{}) *MockIMainStorage_ReplaceBlockData_Call
ReplaceBlockData is a helper method to define mock.On call
- data []common.BlockData
type MockIMainStorage_GetAggregations_Call ¶
MockIMainStorage_GetAggregations_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAggregations'
func (*MockIMainStorage_GetAggregations_Call) Return ¶
func (_c *MockIMainStorage_GetAggregations_Call) Return(_a0 storage.QueryResult[interface{}], _a1 error) *MockIMainStorage_GetAggregations_Call
func (*MockIMainStorage_GetAggregations_Call) Run ¶
func (_c *MockIMainStorage_GetAggregations_Call) Run(run func(table string, qf storage.QueryFilter)) *MockIMainStorage_GetAggregations_Call
func (*MockIMainStorage_GetAggregations_Call) RunAndReturn ¶
func (_c *MockIMainStorage_GetAggregations_Call) RunAndReturn(run func(string, storage.QueryFilter) (storage.QueryResult[interface{}], error)) *MockIMainStorage_GetAggregations_Call
type MockIMainStorage_GetBlockHeadersDescending_Call ¶
MockIMainStorage_GetBlockHeadersDescending_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetBlockHeadersDescending'
func (*MockIMainStorage_GetBlockHeadersDescending_Call) Return ¶
func (_c *MockIMainStorage_GetBlockHeadersDescending_Call) Return(blockHeaders []common.BlockHeader, err error) *MockIMainStorage_GetBlockHeadersDescending_Call
func (*MockIMainStorage_GetBlockHeadersDescending_Call) Run ¶
func (_c *MockIMainStorage_GetBlockHeadersDescending_Call) Run(run func(chainId *big.Int, from *big.Int, to *big.Int)) *MockIMainStorage_GetBlockHeadersDescending_Call
func (*MockIMainStorage_GetBlockHeadersDescending_Call) RunAndReturn ¶
func (_c *MockIMainStorage_GetBlockHeadersDescending_Call) RunAndReturn(run func(*big.Int, *big.Int, *big.Int) ([]common.BlockHeader, error)) *MockIMainStorage_GetBlockHeadersDescending_Call
type MockIMainStorage_GetBlocks_Call ¶
MockIMainStorage_GetBlocks_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetBlocks'
func (*MockIMainStorage_GetBlocks_Call) Return ¶
func (_c *MockIMainStorage_GetBlocks_Call) Return(blocks storage.QueryResult[common.Block], err error) *MockIMainStorage_GetBlocks_Call
func (*MockIMainStorage_GetBlocks_Call) Run ¶
func (_c *MockIMainStorage_GetBlocks_Call) Run(run func(qf storage.QueryFilter, fields ...string)) *MockIMainStorage_GetBlocks_Call
func (*MockIMainStorage_GetBlocks_Call) RunAndReturn ¶
func (_c *MockIMainStorage_GetBlocks_Call) RunAndReturn(run func(storage.QueryFilter, ...string) (storage.QueryResult[common.Block], error)) *MockIMainStorage_GetBlocks_Call
type MockIMainStorage_GetLogs_Call ¶
MockIMainStorage_GetLogs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLogs'
func (*MockIMainStorage_GetLogs_Call) Return ¶
func (_c *MockIMainStorage_GetLogs_Call) Return(logs storage.QueryResult[common.Log], err error) *MockIMainStorage_GetLogs_Call
func (*MockIMainStorage_GetLogs_Call) Run ¶
func (_c *MockIMainStorage_GetLogs_Call) Run(run func(qf storage.QueryFilter, fields ...string)) *MockIMainStorage_GetLogs_Call
func (*MockIMainStorage_GetLogs_Call) RunAndReturn ¶
func (_c *MockIMainStorage_GetLogs_Call) RunAndReturn(run func(storage.QueryFilter, ...string) (storage.QueryResult[common.Log], error)) *MockIMainStorage_GetLogs_Call
type MockIMainStorage_GetMaxBlockNumber_Call ¶
MockIMainStorage_GetMaxBlockNumber_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetMaxBlockNumber'
func (*MockIMainStorage_GetMaxBlockNumber_Call) Return ¶
func (_c *MockIMainStorage_GetMaxBlockNumber_Call) Return(maxBlockNumber *big.Int, err error) *MockIMainStorage_GetMaxBlockNumber_Call
func (*MockIMainStorage_GetMaxBlockNumber_Call) Run ¶
func (_c *MockIMainStorage_GetMaxBlockNumber_Call) Run(run func(chainId *big.Int)) *MockIMainStorage_GetMaxBlockNumber_Call
func (*MockIMainStorage_GetMaxBlockNumber_Call) RunAndReturn ¶
func (_c *MockIMainStorage_GetMaxBlockNumber_Call) RunAndReturn(run func(*big.Int) (*big.Int, error)) *MockIMainStorage_GetMaxBlockNumber_Call
type MockIMainStorage_GetTokenBalances_Call ¶
MockIMainStorage_GetTokenBalances_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTokenBalances'
func (*MockIMainStorage_GetTokenBalances_Call) Return ¶
func (_c *MockIMainStorage_GetTokenBalances_Call) Return(_a0 storage.QueryResult[common.TokenBalance], _a1 error) *MockIMainStorage_GetTokenBalances_Call
func (*MockIMainStorage_GetTokenBalances_Call) Run ¶
func (_c *MockIMainStorage_GetTokenBalances_Call) Run(run func(qf storage.BalancesQueryFilter, fields ...string)) *MockIMainStorage_GetTokenBalances_Call
func (*MockIMainStorage_GetTokenBalances_Call) RunAndReturn ¶
func (_c *MockIMainStorage_GetTokenBalances_Call) RunAndReturn(run func(storage.BalancesQueryFilter, ...string) (storage.QueryResult[common.TokenBalance], error)) *MockIMainStorage_GetTokenBalances_Call
type MockIMainStorage_GetTokenTransfers_Call ¶
MockIMainStorage_GetTokenTransfers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTokenTransfers'
func (*MockIMainStorage_GetTokenTransfers_Call) Return ¶
func (_c *MockIMainStorage_GetTokenTransfers_Call) Return(_a0 storage.QueryResult[common.TokenTransfer], _a1 error) *MockIMainStorage_GetTokenTransfers_Call
func (*MockIMainStorage_GetTokenTransfers_Call) Run ¶
func (_c *MockIMainStorage_GetTokenTransfers_Call) Run(run func(qf storage.TransfersQueryFilter, fields ...string)) *MockIMainStorage_GetTokenTransfers_Call
func (*MockIMainStorage_GetTokenTransfers_Call) RunAndReturn ¶
func (_c *MockIMainStorage_GetTokenTransfers_Call) RunAndReturn(run func(storage.TransfersQueryFilter, ...string) (storage.QueryResult[common.TokenTransfer], error)) *MockIMainStorage_GetTokenTransfers_Call
type MockIMainStorage_GetTraces_Call ¶
MockIMainStorage_GetTraces_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTraces'
func (*MockIMainStorage_GetTraces_Call) Return ¶
func (_c *MockIMainStorage_GetTraces_Call) Return(traces storage.QueryResult[common.Trace], err error) *MockIMainStorage_GetTraces_Call
func (*MockIMainStorage_GetTraces_Call) Run ¶
func (_c *MockIMainStorage_GetTraces_Call) Run(run func(qf storage.QueryFilter, fields ...string)) *MockIMainStorage_GetTraces_Call
func (*MockIMainStorage_GetTraces_Call) RunAndReturn ¶
func (_c *MockIMainStorage_GetTraces_Call) RunAndReturn(run func(storage.QueryFilter, ...string) (storage.QueryResult[common.Trace], error)) *MockIMainStorage_GetTraces_Call
type MockIMainStorage_GetTransactions_Call ¶
MockIMainStorage_GetTransactions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTransactions'
func (*MockIMainStorage_GetTransactions_Call) Return ¶
func (_c *MockIMainStorage_GetTransactions_Call) Return(transactions storage.QueryResult[common.Transaction], err error) *MockIMainStorage_GetTransactions_Call
func (*MockIMainStorage_GetTransactions_Call) Run ¶
func (_c *MockIMainStorage_GetTransactions_Call) Run(run func(qf storage.QueryFilter, fields ...string)) *MockIMainStorage_GetTransactions_Call
func (*MockIMainStorage_GetTransactions_Call) RunAndReturn ¶
func (_c *MockIMainStorage_GetTransactions_Call) RunAndReturn(run func(storage.QueryFilter, ...string) (storage.QueryResult[common.Transaction], error)) *MockIMainStorage_GetTransactions_Call
type MockIMainStorage_InsertBlockData_Call ¶
MockIMainStorage_InsertBlockData_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InsertBlockData'
func (*MockIMainStorage_InsertBlockData_Call) Return ¶
func (_c *MockIMainStorage_InsertBlockData_Call) Return(_a0 error) *MockIMainStorage_InsertBlockData_Call
func (*MockIMainStorage_InsertBlockData_Call) Run ¶
func (_c *MockIMainStorage_InsertBlockData_Call) Run(run func(data []common.BlockData)) *MockIMainStorage_InsertBlockData_Call
func (*MockIMainStorage_InsertBlockData_Call) RunAndReturn ¶
func (_c *MockIMainStorage_InsertBlockData_Call) RunAndReturn(run func([]common.BlockData) error) *MockIMainStorage_InsertBlockData_Call
type MockIMainStorage_ReplaceBlockData_Call ¶
MockIMainStorage_ReplaceBlockData_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReplaceBlockData'
func (*MockIMainStorage_ReplaceBlockData_Call) Return ¶
func (_c *MockIMainStorage_ReplaceBlockData_Call) Return(_a0 []common.BlockData, _a1 error) *MockIMainStorage_ReplaceBlockData_Call
func (*MockIMainStorage_ReplaceBlockData_Call) Run ¶
func (_c *MockIMainStorage_ReplaceBlockData_Call) Run(run func(data []common.BlockData)) *MockIMainStorage_ReplaceBlockData_Call
func (*MockIMainStorage_ReplaceBlockData_Call) RunAndReturn ¶
func (_c *MockIMainStorage_ReplaceBlockData_Call) RunAndReturn(run func([]common.BlockData) ([]common.BlockData, error)) *MockIMainStorage_ReplaceBlockData_Call
type MockIOrchestratorStorage ¶
MockIOrchestratorStorage is an autogenerated mock type for the IOrchestratorStorage type
func NewMockIOrchestratorStorage ¶
func NewMockIOrchestratorStorage(t interface { mock.TestingT Cleanup(func()) }) *MockIOrchestratorStorage
NewMockIOrchestratorStorage creates a new instance of MockIOrchestratorStorage. 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 (*MockIOrchestratorStorage) DeleteBlockFailures ¶
func (_m *MockIOrchestratorStorage) DeleteBlockFailures(failures []common.BlockFailure) error
DeleteBlockFailures provides a mock function with given fields: failures
func (*MockIOrchestratorStorage) EXPECT ¶
func (_m *MockIOrchestratorStorage) EXPECT() *MockIOrchestratorStorage_Expecter
func (*MockIOrchestratorStorage) GetBlockFailures ¶
func (_m *MockIOrchestratorStorage) GetBlockFailures(qf storage.QueryFilter) ([]common.BlockFailure, error)
GetBlockFailures provides a mock function with given fields: qf
func (*MockIOrchestratorStorage) GetLastReorgCheckedBlockNumber ¶
func (_m *MockIOrchestratorStorage) GetLastReorgCheckedBlockNumber(chainId *big.Int) (*big.Int, error)
GetLastReorgCheckedBlockNumber provides a mock function with given fields: chainId
func (*MockIOrchestratorStorage) SetLastReorgCheckedBlockNumber ¶
func (_m *MockIOrchestratorStorage) SetLastReorgCheckedBlockNumber(chainId *big.Int, blockNumber *big.Int) error
SetLastReorgCheckedBlockNumber provides a mock function with given fields: chainId, blockNumber
func (*MockIOrchestratorStorage) StoreBlockFailures ¶
func (_m *MockIOrchestratorStorage) StoreBlockFailures(failures []common.BlockFailure) error
StoreBlockFailures provides a mock function with given fields: failures
type MockIOrchestratorStorage_DeleteBlockFailures_Call ¶
MockIOrchestratorStorage_DeleteBlockFailures_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteBlockFailures'
func (*MockIOrchestratorStorage_DeleteBlockFailures_Call) Return ¶
func (_c *MockIOrchestratorStorage_DeleteBlockFailures_Call) Return(_a0 error) *MockIOrchestratorStorage_DeleteBlockFailures_Call
func (*MockIOrchestratorStorage_DeleteBlockFailures_Call) Run ¶
func (_c *MockIOrchestratorStorage_DeleteBlockFailures_Call) Run(run func(failures []common.BlockFailure)) *MockIOrchestratorStorage_DeleteBlockFailures_Call
func (*MockIOrchestratorStorage_DeleteBlockFailures_Call) RunAndReturn ¶
func (_c *MockIOrchestratorStorage_DeleteBlockFailures_Call) RunAndReturn(run func([]common.BlockFailure) error) *MockIOrchestratorStorage_DeleteBlockFailures_Call
type MockIOrchestratorStorage_Expecter ¶
type MockIOrchestratorStorage_Expecter struct {
// contains filtered or unexported fields
}
func (*MockIOrchestratorStorage_Expecter) DeleteBlockFailures ¶
func (_e *MockIOrchestratorStorage_Expecter) DeleteBlockFailures(failures interface{}) *MockIOrchestratorStorage_DeleteBlockFailures_Call
DeleteBlockFailures is a helper method to define mock.On call
- failures []common.BlockFailure
func (*MockIOrchestratorStorage_Expecter) GetBlockFailures ¶
func (_e *MockIOrchestratorStorage_Expecter) GetBlockFailures(qf interface{}) *MockIOrchestratorStorage_GetBlockFailures_Call
GetBlockFailures is a helper method to define mock.On call
- qf storage.QueryFilter
func (*MockIOrchestratorStorage_Expecter) GetLastReorgCheckedBlockNumber ¶
func (_e *MockIOrchestratorStorage_Expecter) GetLastReorgCheckedBlockNumber(chainId interface{}) *MockIOrchestratorStorage_GetLastReorgCheckedBlockNumber_Call
GetLastReorgCheckedBlockNumber is a helper method to define mock.On call
- chainId *big.Int
func (*MockIOrchestratorStorage_Expecter) SetLastReorgCheckedBlockNumber ¶
func (_e *MockIOrchestratorStorage_Expecter) SetLastReorgCheckedBlockNumber(chainId interface{}, blockNumber interface{}) *MockIOrchestratorStorage_SetLastReorgCheckedBlockNumber_Call
SetLastReorgCheckedBlockNumber is a helper method to define mock.On call
- chainId *big.Int
- blockNumber *big.Int
func (*MockIOrchestratorStorage_Expecter) StoreBlockFailures ¶
func (_e *MockIOrchestratorStorage_Expecter) StoreBlockFailures(failures interface{}) *MockIOrchestratorStorage_StoreBlockFailures_Call
StoreBlockFailures is a helper method to define mock.On call
- failures []common.BlockFailure
type MockIOrchestratorStorage_GetBlockFailures_Call ¶
MockIOrchestratorStorage_GetBlockFailures_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetBlockFailures'
func (*MockIOrchestratorStorage_GetBlockFailures_Call) Return ¶
func (_c *MockIOrchestratorStorage_GetBlockFailures_Call) Return(_a0 []common.BlockFailure, _a1 error) *MockIOrchestratorStorage_GetBlockFailures_Call
func (*MockIOrchestratorStorage_GetBlockFailures_Call) Run ¶
func (_c *MockIOrchestratorStorage_GetBlockFailures_Call) Run(run func(qf storage.QueryFilter)) *MockIOrchestratorStorage_GetBlockFailures_Call
func (*MockIOrchestratorStorage_GetBlockFailures_Call) RunAndReturn ¶
func (_c *MockIOrchestratorStorage_GetBlockFailures_Call) RunAndReturn(run func(storage.QueryFilter) ([]common.BlockFailure, error)) *MockIOrchestratorStorage_GetBlockFailures_Call
type MockIOrchestratorStorage_GetLastReorgCheckedBlockNumber_Call ¶
MockIOrchestratorStorage_GetLastReorgCheckedBlockNumber_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLastReorgCheckedBlockNumber'
func (*MockIOrchestratorStorage_GetLastReorgCheckedBlockNumber_Call) Return ¶
func (_c *MockIOrchestratorStorage_GetLastReorgCheckedBlockNumber_Call) Return(_a0 *big.Int, _a1 error) *MockIOrchestratorStorage_GetLastReorgCheckedBlockNumber_Call
func (*MockIOrchestratorStorage_GetLastReorgCheckedBlockNumber_Call) Run ¶
func (_c *MockIOrchestratorStorage_GetLastReorgCheckedBlockNumber_Call) Run(run func(chainId *big.Int)) *MockIOrchestratorStorage_GetLastReorgCheckedBlockNumber_Call
func (*MockIOrchestratorStorage_GetLastReorgCheckedBlockNumber_Call) RunAndReturn ¶
func (_c *MockIOrchestratorStorage_GetLastReorgCheckedBlockNumber_Call) RunAndReturn(run func(*big.Int) (*big.Int, error)) *MockIOrchestratorStorage_GetLastReorgCheckedBlockNumber_Call
type MockIOrchestratorStorage_SetLastReorgCheckedBlockNumber_Call ¶
MockIOrchestratorStorage_SetLastReorgCheckedBlockNumber_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetLastReorgCheckedBlockNumber'
func (*MockIOrchestratorStorage_SetLastReorgCheckedBlockNumber_Call) Run ¶
func (_c *MockIOrchestratorStorage_SetLastReorgCheckedBlockNumber_Call) Run(run func(chainId *big.Int, blockNumber *big.Int)) *MockIOrchestratorStorage_SetLastReorgCheckedBlockNumber_Call
func (*MockIOrchestratorStorage_SetLastReorgCheckedBlockNumber_Call) RunAndReturn ¶
func (_c *MockIOrchestratorStorage_SetLastReorgCheckedBlockNumber_Call) RunAndReturn(run func(*big.Int, *big.Int) error) *MockIOrchestratorStorage_SetLastReorgCheckedBlockNumber_Call
type MockIOrchestratorStorage_StoreBlockFailures_Call ¶
MockIOrchestratorStorage_StoreBlockFailures_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StoreBlockFailures'
func (*MockIOrchestratorStorage_StoreBlockFailures_Call) Return ¶
func (_c *MockIOrchestratorStorage_StoreBlockFailures_Call) Return(_a0 error) *MockIOrchestratorStorage_StoreBlockFailures_Call
func (*MockIOrchestratorStorage_StoreBlockFailures_Call) Run ¶
func (_c *MockIOrchestratorStorage_StoreBlockFailures_Call) Run(run func(failures []common.BlockFailure)) *MockIOrchestratorStorage_StoreBlockFailures_Call
func (*MockIOrchestratorStorage_StoreBlockFailures_Call) RunAndReturn ¶
func (_c *MockIOrchestratorStorage_StoreBlockFailures_Call) RunAndReturn(run func([]common.BlockFailure) error) *MockIOrchestratorStorage_StoreBlockFailures_Call
type MockIRPCClient ¶
MockIRPCClient is an autogenerated mock type for the IRPCClient type
func NewMockIRPCClient ¶
func NewMockIRPCClient(t interface { mock.TestingT Cleanup(func()) }) *MockIRPCClient
NewMockIRPCClient creates a new instance of MockIRPCClient. 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 (*MockIRPCClient) Close ¶
func (_m *MockIRPCClient) Close()
Close provides a mock function with no fields
func (*MockIRPCClient) EXPECT ¶
func (_m *MockIRPCClient) EXPECT() *MockIRPCClient_Expecter
func (*MockIRPCClient) GetBlocks ¶
func (_m *MockIRPCClient) GetBlocks(ctx context.Context, blockNumbers []*big.Int) []rpc.GetBlocksResult
GetBlocks provides a mock function with given fields: ctx, blockNumbers
func (*MockIRPCClient) GetBlocksPerRequest ¶
func (_m *MockIRPCClient) GetBlocksPerRequest() rpc.BlocksPerRequestConfig
GetBlocksPerRequest provides a mock function with no fields
func (*MockIRPCClient) GetChainID ¶
func (_m *MockIRPCClient) GetChainID() *big.Int
GetChainID provides a mock function with no fields
func (*MockIRPCClient) GetFullBlocks ¶
func (_m *MockIRPCClient) GetFullBlocks(ctx context.Context, blockNumbers []*big.Int) []rpc.GetFullBlockResult
GetFullBlocks provides a mock function with given fields: ctx, blockNumbers
func (*MockIRPCClient) GetLatestBlockNumber ¶
GetLatestBlockNumber provides a mock function with given fields: ctx
func (*MockIRPCClient) GetTransactions ¶
func (_m *MockIRPCClient) GetTransactions(ctx context.Context, txHashes []string) []rpc.GetTransactionsResult
GetTransactions provides a mock function with given fields: ctx, txHashes
func (*MockIRPCClient) GetURL ¶
func (_m *MockIRPCClient) GetURL() string
GetURL provides a mock function with no fields
func (*MockIRPCClient) IsWebsocket ¶
func (_m *MockIRPCClient) IsWebsocket() bool
IsWebsocket provides a mock function with no fields
func (*MockIRPCClient) SupportsTraceBlock ¶
func (_m *MockIRPCClient) SupportsTraceBlock() bool
SupportsTraceBlock provides a mock function with no fields
type MockIRPCClient_Close_Call ¶
MockIRPCClient_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*MockIRPCClient_Close_Call) Return ¶
func (_c *MockIRPCClient_Close_Call) Return() *MockIRPCClient_Close_Call
func (*MockIRPCClient_Close_Call) Run ¶
func (_c *MockIRPCClient_Close_Call) Run(run func()) *MockIRPCClient_Close_Call
func (*MockIRPCClient_Close_Call) RunAndReturn ¶
func (_c *MockIRPCClient_Close_Call) RunAndReturn(run func()) *MockIRPCClient_Close_Call
type MockIRPCClient_Expecter ¶
type MockIRPCClient_Expecter struct {
// contains filtered or unexported fields
}
func (*MockIRPCClient_Expecter) Close ¶
func (_e *MockIRPCClient_Expecter) Close() *MockIRPCClient_Close_Call
Close is a helper method to define mock.On call
func (*MockIRPCClient_Expecter) GetBlocks ¶
func (_e *MockIRPCClient_Expecter) GetBlocks(ctx interface{}, blockNumbers interface{}) *MockIRPCClient_GetBlocks_Call
GetBlocks is a helper method to define mock.On call
- ctx context.Context
- blockNumbers []*big.Int
func (*MockIRPCClient_Expecter) GetBlocksPerRequest ¶
func (_e *MockIRPCClient_Expecter) GetBlocksPerRequest() *MockIRPCClient_GetBlocksPerRequest_Call
GetBlocksPerRequest is a helper method to define mock.On call
func (*MockIRPCClient_Expecter) GetChainID ¶
func (_e *MockIRPCClient_Expecter) GetChainID() *MockIRPCClient_GetChainID_Call
GetChainID is a helper method to define mock.On call
func (*MockIRPCClient_Expecter) GetFullBlocks ¶
func (_e *MockIRPCClient_Expecter) GetFullBlocks(ctx interface{}, blockNumbers interface{}) *MockIRPCClient_GetFullBlocks_Call
GetFullBlocks is a helper method to define mock.On call
- ctx context.Context
- blockNumbers []*big.Int
func (*MockIRPCClient_Expecter) GetLatestBlockNumber ¶
func (_e *MockIRPCClient_Expecter) GetLatestBlockNumber(ctx interface{}) *MockIRPCClient_GetLatestBlockNumber_Call
GetLatestBlockNumber is a helper method to define mock.On call
- ctx context.Context
func (*MockIRPCClient_Expecter) GetTransactions ¶
func (_e *MockIRPCClient_Expecter) GetTransactions(ctx interface{}, txHashes interface{}) *MockIRPCClient_GetTransactions_Call
GetTransactions is a helper method to define mock.On call
- ctx context.Context
- txHashes []string
func (*MockIRPCClient_Expecter) GetURL ¶
func (_e *MockIRPCClient_Expecter) GetURL() *MockIRPCClient_GetURL_Call
GetURL is a helper method to define mock.On call
func (*MockIRPCClient_Expecter) HasCode ¶
func (_e *MockIRPCClient_Expecter) HasCode(ctx interface{}, address interface{}) *MockIRPCClient_HasCode_Call
HasCode is a helper method to define mock.On call
- ctx context.Context
- address string
func (*MockIRPCClient_Expecter) IsWebsocket ¶
func (_e *MockIRPCClient_Expecter) IsWebsocket() *MockIRPCClient_IsWebsocket_Call
IsWebsocket is a helper method to define mock.On call
func (*MockIRPCClient_Expecter) SupportsTraceBlock ¶
func (_e *MockIRPCClient_Expecter) SupportsTraceBlock() *MockIRPCClient_SupportsTraceBlock_Call
SupportsTraceBlock is a helper method to define mock.On call
type MockIRPCClient_GetBlocksPerRequest_Call ¶
MockIRPCClient_GetBlocksPerRequest_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetBlocksPerRequest'
func (*MockIRPCClient_GetBlocksPerRequest_Call) Return ¶
func (_c *MockIRPCClient_GetBlocksPerRequest_Call) Return(_a0 rpc.BlocksPerRequestConfig) *MockIRPCClient_GetBlocksPerRequest_Call
func (*MockIRPCClient_GetBlocksPerRequest_Call) Run ¶
func (_c *MockIRPCClient_GetBlocksPerRequest_Call) Run(run func()) *MockIRPCClient_GetBlocksPerRequest_Call
func (*MockIRPCClient_GetBlocksPerRequest_Call) RunAndReturn ¶
func (_c *MockIRPCClient_GetBlocksPerRequest_Call) RunAndReturn(run func() rpc.BlocksPerRequestConfig) *MockIRPCClient_GetBlocksPerRequest_Call
type MockIRPCClient_GetBlocks_Call ¶
MockIRPCClient_GetBlocks_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetBlocks'
func (*MockIRPCClient_GetBlocks_Call) Return ¶
func (_c *MockIRPCClient_GetBlocks_Call) Return(_a0 []rpc.GetBlocksResult) *MockIRPCClient_GetBlocks_Call
func (*MockIRPCClient_GetBlocks_Call) Run ¶
func (_c *MockIRPCClient_GetBlocks_Call) Run(run func(ctx context.Context, blockNumbers []*big.Int)) *MockIRPCClient_GetBlocks_Call
func (*MockIRPCClient_GetBlocks_Call) RunAndReturn ¶
func (_c *MockIRPCClient_GetBlocks_Call) RunAndReturn(run func(context.Context, []*big.Int) []rpc.GetBlocksResult) *MockIRPCClient_GetBlocks_Call
type MockIRPCClient_GetChainID_Call ¶
MockIRPCClient_GetChainID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetChainID'
func (*MockIRPCClient_GetChainID_Call) Return ¶
func (_c *MockIRPCClient_GetChainID_Call) Return(_a0 *big.Int) *MockIRPCClient_GetChainID_Call
func (*MockIRPCClient_GetChainID_Call) Run ¶
func (_c *MockIRPCClient_GetChainID_Call) Run(run func()) *MockIRPCClient_GetChainID_Call
func (*MockIRPCClient_GetChainID_Call) RunAndReturn ¶
func (_c *MockIRPCClient_GetChainID_Call) RunAndReturn(run func() *big.Int) *MockIRPCClient_GetChainID_Call
type MockIRPCClient_GetFullBlocks_Call ¶
MockIRPCClient_GetFullBlocks_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetFullBlocks'
func (*MockIRPCClient_GetFullBlocks_Call) Return ¶
func (_c *MockIRPCClient_GetFullBlocks_Call) Return(_a0 []rpc.GetFullBlockResult) *MockIRPCClient_GetFullBlocks_Call
func (*MockIRPCClient_GetFullBlocks_Call) Run ¶
func (_c *MockIRPCClient_GetFullBlocks_Call) Run(run func(ctx context.Context, blockNumbers []*big.Int)) *MockIRPCClient_GetFullBlocks_Call
func (*MockIRPCClient_GetFullBlocks_Call) RunAndReturn ¶
func (_c *MockIRPCClient_GetFullBlocks_Call) RunAndReturn(run func(context.Context, []*big.Int) []rpc.GetFullBlockResult) *MockIRPCClient_GetFullBlocks_Call
type MockIRPCClient_GetLatestBlockNumber_Call ¶
MockIRPCClient_GetLatestBlockNumber_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLatestBlockNumber'
func (*MockIRPCClient_GetLatestBlockNumber_Call) Return ¶
func (_c *MockIRPCClient_GetLatestBlockNumber_Call) Return(_a0 *big.Int, _a1 error) *MockIRPCClient_GetLatestBlockNumber_Call
func (*MockIRPCClient_GetLatestBlockNumber_Call) Run ¶
func (_c *MockIRPCClient_GetLatestBlockNumber_Call) Run(run func(ctx context.Context)) *MockIRPCClient_GetLatestBlockNumber_Call
func (*MockIRPCClient_GetLatestBlockNumber_Call) RunAndReturn ¶
func (_c *MockIRPCClient_GetLatestBlockNumber_Call) RunAndReturn(run func(context.Context) (*big.Int, error)) *MockIRPCClient_GetLatestBlockNumber_Call
type MockIRPCClient_GetTransactions_Call ¶
MockIRPCClient_GetTransactions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTransactions'
func (*MockIRPCClient_GetTransactions_Call) Return ¶
func (_c *MockIRPCClient_GetTransactions_Call) Return(_a0 []rpc.GetTransactionsResult) *MockIRPCClient_GetTransactions_Call
func (*MockIRPCClient_GetTransactions_Call) Run ¶
func (_c *MockIRPCClient_GetTransactions_Call) Run(run func(ctx context.Context, txHashes []string)) *MockIRPCClient_GetTransactions_Call
func (*MockIRPCClient_GetTransactions_Call) RunAndReturn ¶
func (_c *MockIRPCClient_GetTransactions_Call) RunAndReturn(run func(context.Context, []string) []rpc.GetTransactionsResult) *MockIRPCClient_GetTransactions_Call
type MockIRPCClient_GetURL_Call ¶
MockIRPCClient_GetURL_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetURL'
func (*MockIRPCClient_GetURL_Call) Return ¶
func (_c *MockIRPCClient_GetURL_Call) Return(_a0 string) *MockIRPCClient_GetURL_Call
func (*MockIRPCClient_GetURL_Call) Run ¶
func (_c *MockIRPCClient_GetURL_Call) Run(run func()) *MockIRPCClient_GetURL_Call
func (*MockIRPCClient_GetURL_Call) RunAndReturn ¶
func (_c *MockIRPCClient_GetURL_Call) RunAndReturn(run func() string) *MockIRPCClient_GetURL_Call
type MockIRPCClient_HasCode_Call ¶
MockIRPCClient_HasCode_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HasCode'
func (*MockIRPCClient_HasCode_Call) Return ¶
func (_c *MockIRPCClient_HasCode_Call) Return(_a0 bool, _a1 error) *MockIRPCClient_HasCode_Call
func (*MockIRPCClient_HasCode_Call) Run ¶
func (_c *MockIRPCClient_HasCode_Call) Run(run func(ctx context.Context, address string)) *MockIRPCClient_HasCode_Call
func (*MockIRPCClient_HasCode_Call) RunAndReturn ¶
func (_c *MockIRPCClient_HasCode_Call) RunAndReturn(run func(context.Context, string) (bool, error)) *MockIRPCClient_HasCode_Call
type MockIRPCClient_IsWebsocket_Call ¶
MockIRPCClient_IsWebsocket_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsWebsocket'
func (*MockIRPCClient_IsWebsocket_Call) Return ¶
func (_c *MockIRPCClient_IsWebsocket_Call) Return(_a0 bool) *MockIRPCClient_IsWebsocket_Call
func (*MockIRPCClient_IsWebsocket_Call) Run ¶
func (_c *MockIRPCClient_IsWebsocket_Call) Run(run func()) *MockIRPCClient_IsWebsocket_Call
func (*MockIRPCClient_IsWebsocket_Call) RunAndReturn ¶
func (_c *MockIRPCClient_IsWebsocket_Call) RunAndReturn(run func() bool) *MockIRPCClient_IsWebsocket_Call
type MockIRPCClient_SupportsTraceBlock_Call ¶
MockIRPCClient_SupportsTraceBlock_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SupportsTraceBlock'
func (*MockIRPCClient_SupportsTraceBlock_Call) Return ¶
func (_c *MockIRPCClient_SupportsTraceBlock_Call) Return(_a0 bool) *MockIRPCClient_SupportsTraceBlock_Call
func (*MockIRPCClient_SupportsTraceBlock_Call) Run ¶
func (_c *MockIRPCClient_SupportsTraceBlock_Call) Run(run func()) *MockIRPCClient_SupportsTraceBlock_Call
func (*MockIRPCClient_SupportsTraceBlock_Call) RunAndReturn ¶
func (_c *MockIRPCClient_SupportsTraceBlock_Call) RunAndReturn(run func() bool) *MockIRPCClient_SupportsTraceBlock_Call
type MockIStagingStorage ¶
MockIStagingStorage is an autogenerated mock type for the IStagingStorage type
func NewMockIStagingStorage ¶
func NewMockIStagingStorage(t interface { mock.TestingT Cleanup(func()) }) *MockIStagingStorage
NewMockIStagingStorage creates a new instance of MockIStagingStorage. 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 (*MockIStagingStorage) DeleteStagingData ¶
func (_m *MockIStagingStorage) DeleteStagingData(data []common.BlockData) error
DeleteStagingData provides a mock function with given fields: data
func (*MockIStagingStorage) EXPECT ¶
func (_m *MockIStagingStorage) EXPECT() *MockIStagingStorage_Expecter
func (*MockIStagingStorage) GetLastStagedBlockNumber ¶
func (_m *MockIStagingStorage) GetLastStagedBlockNumber(chainId *big.Int, rangeStart *big.Int, rangeEnd *big.Int) (*big.Int, error)
GetLastStagedBlockNumber provides a mock function with given fields: chainId, rangeStart, rangeEnd
func (*MockIStagingStorage) GetStagingData ¶
func (_m *MockIStagingStorage) GetStagingData(qf storage.QueryFilter) ([]common.BlockData, error)
GetStagingData provides a mock function with given fields: qf
func (*MockIStagingStorage) InsertStagingData ¶
func (_m *MockIStagingStorage) InsertStagingData(data []common.BlockData) error
InsertStagingData provides a mock function with given fields: data
type MockIStagingStorage_DeleteStagingData_Call ¶
MockIStagingStorage_DeleteStagingData_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteStagingData'
func (*MockIStagingStorage_DeleteStagingData_Call) Return ¶
func (_c *MockIStagingStorage_DeleteStagingData_Call) Return(_a0 error) *MockIStagingStorage_DeleteStagingData_Call
func (*MockIStagingStorage_DeleteStagingData_Call) Run ¶
func (_c *MockIStagingStorage_DeleteStagingData_Call) Run(run func(data []common.BlockData)) *MockIStagingStorage_DeleteStagingData_Call
func (*MockIStagingStorage_DeleteStagingData_Call) RunAndReturn ¶
func (_c *MockIStagingStorage_DeleteStagingData_Call) RunAndReturn(run func([]common.BlockData) error) *MockIStagingStorage_DeleteStagingData_Call
type MockIStagingStorage_Expecter ¶
type MockIStagingStorage_Expecter struct {
// contains filtered or unexported fields
}
func (*MockIStagingStorage_Expecter) DeleteStagingData ¶
func (_e *MockIStagingStorage_Expecter) DeleteStagingData(data interface{}) *MockIStagingStorage_DeleteStagingData_Call
DeleteStagingData is a helper method to define mock.On call
- data []common.BlockData
func (*MockIStagingStorage_Expecter) GetLastStagedBlockNumber ¶
func (_e *MockIStagingStorage_Expecter) GetLastStagedBlockNumber(chainId interface{}, rangeStart interface{}, rangeEnd interface{}) *MockIStagingStorage_GetLastStagedBlockNumber_Call
GetLastStagedBlockNumber is a helper method to define mock.On call
- chainId *big.Int
- rangeStart *big.Int
- rangeEnd *big.Int
func (*MockIStagingStorage_Expecter) GetStagingData ¶
func (_e *MockIStagingStorage_Expecter) GetStagingData(qf interface{}) *MockIStagingStorage_GetStagingData_Call
GetStagingData is a helper method to define mock.On call
- qf storage.QueryFilter
func (*MockIStagingStorage_Expecter) InsertStagingData ¶
func (_e *MockIStagingStorage_Expecter) InsertStagingData(data interface{}) *MockIStagingStorage_InsertStagingData_Call
InsertStagingData is a helper method to define mock.On call
- data []common.BlockData
type MockIStagingStorage_GetLastStagedBlockNumber_Call ¶
MockIStagingStorage_GetLastStagedBlockNumber_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLastStagedBlockNumber'
func (*MockIStagingStorage_GetLastStagedBlockNumber_Call) Return ¶
func (_c *MockIStagingStorage_GetLastStagedBlockNumber_Call) Return(maxBlockNumber *big.Int, err error) *MockIStagingStorage_GetLastStagedBlockNumber_Call
func (*MockIStagingStorage_GetLastStagedBlockNumber_Call) Run ¶
func (_c *MockIStagingStorage_GetLastStagedBlockNumber_Call) Run(run func(chainId *big.Int, rangeStart *big.Int, rangeEnd *big.Int)) *MockIStagingStorage_GetLastStagedBlockNumber_Call
func (*MockIStagingStorage_GetLastStagedBlockNumber_Call) RunAndReturn ¶
type MockIStagingStorage_GetStagingData_Call ¶
MockIStagingStorage_GetStagingData_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetStagingData'
func (*MockIStagingStorage_GetStagingData_Call) Return ¶
func (_c *MockIStagingStorage_GetStagingData_Call) Return(data []common.BlockData, err error) *MockIStagingStorage_GetStagingData_Call
func (*MockIStagingStorage_GetStagingData_Call) Run ¶
func (_c *MockIStagingStorage_GetStagingData_Call) Run(run func(qf storage.QueryFilter)) *MockIStagingStorage_GetStagingData_Call
func (*MockIStagingStorage_GetStagingData_Call) RunAndReturn ¶
func (_c *MockIStagingStorage_GetStagingData_Call) RunAndReturn(run func(storage.QueryFilter) ([]common.BlockData, error)) *MockIStagingStorage_GetStagingData_Call
type MockIStagingStorage_InsertStagingData_Call ¶
MockIStagingStorage_InsertStagingData_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InsertStagingData'
func (*MockIStagingStorage_InsertStagingData_Call) Return ¶
func (_c *MockIStagingStorage_InsertStagingData_Call) Return(_a0 error) *MockIStagingStorage_InsertStagingData_Call
func (*MockIStagingStorage_InsertStagingData_Call) Run ¶
func (_c *MockIStagingStorage_InsertStagingData_Call) Run(run func(data []common.BlockData)) *MockIStagingStorage_InsertStagingData_Call
func (*MockIStagingStorage_InsertStagingData_Call) RunAndReturn ¶
func (_c *MockIStagingStorage_InsertStagingData_Call) RunAndReturn(run func([]common.BlockData) error) *MockIStagingStorage_InsertStagingData_Call