Documentation
¶
Index ¶
- type Storager
- func (_m *Storager) EXPECT() *Storager_Expecter
- func (_m *Storager) GetBlockHeaderByNumber(tx types.Querier, blockNumber uint64) (*aggkittypes.BlockHeader, bool, error)
- func (_m *Storager) GetEthLogs(tx types.Querier, query multidownloadertypes.LogQuery) ([]coretypes.Log, error)
- func (_m *Storager) GetSyncedBlockRangePerContract(tx types.Querier) (multidownloadertypes.SetSyncSegment, error)
- func (_m *Storager) GetValue(tx types.Querier, owner string, key string) (string, error)
- func (_m *Storager) InsertValue(tx types.Querier, owner string, key string, value string) error
- func (_m *Storager) NewTx(ctx context.Context) (types.Txer, error)
- func (_m *Storager) SaveEthLogsWithHeaders(tx types.Querier, blockHeaders []*aggkittypes.BlockHeader, ...) error
- func (_m *Storager) UpdateSyncedStatus(tx types.Querier, segments []multidownloadertypes.SyncSegment) error
- func (_m *Storager) UpdateValue(tx types.Querier, owner string, key string, value string) error
- func (_m *Storager) UpsertSyncerConfigs(tx types.Querier, configs []multidownloadertypes.ContractConfig) error
- type Storager_Expecter
- func (_e *Storager_Expecter) GetBlockHeaderByNumber(tx interface{}, blockNumber interface{}) *Storager_GetBlockHeaderByNumber_Call
- func (_e *Storager_Expecter) GetEthLogs(tx interface{}, query interface{}) *Storager_GetEthLogs_Call
- func (_e *Storager_Expecter) GetSyncedBlockRangePerContract(tx interface{}) *Storager_GetSyncedBlockRangePerContract_Call
- func (_e *Storager_Expecter) GetValue(tx interface{}, owner interface{}, key interface{}) *Storager_GetValue_Call
- func (_e *Storager_Expecter) InsertValue(tx interface{}, owner interface{}, key interface{}, value interface{}) *Storager_InsertValue_Call
- func (_e *Storager_Expecter) NewTx(ctx interface{}) *Storager_NewTx_Call
- func (_e *Storager_Expecter) SaveEthLogsWithHeaders(tx interface{}, blockHeaders interface{}, logs interface{}, ...) *Storager_SaveEthLogsWithHeaders_Call
- func (_e *Storager_Expecter) UpdateSyncedStatus(tx interface{}, segments interface{}) *Storager_UpdateSyncedStatus_Call
- func (_e *Storager_Expecter) UpdateValue(tx interface{}, owner interface{}, key interface{}, value interface{}) *Storager_UpdateValue_Call
- func (_e *Storager_Expecter) UpsertSyncerConfigs(tx interface{}, configs interface{}) *Storager_UpsertSyncerConfigs_Call
- type Storager_GetBlockHeaderByNumber_Call
- func (_c *Storager_GetBlockHeaderByNumber_Call) Return(_a0 *aggkittypes.BlockHeader, _a1 bool, _a2 error) *Storager_GetBlockHeaderByNumber_Call
- func (_c *Storager_GetBlockHeaderByNumber_Call) Run(run func(tx types.Querier, blockNumber uint64)) *Storager_GetBlockHeaderByNumber_Call
- func (_c *Storager_GetBlockHeaderByNumber_Call) RunAndReturn(run func(types.Querier, uint64) (*aggkittypes.BlockHeader, bool, error)) *Storager_GetBlockHeaderByNumber_Call
- type Storager_GetEthLogs_Call
- func (_c *Storager_GetEthLogs_Call) Return(_a0 []coretypes.Log, _a1 error) *Storager_GetEthLogs_Call
- func (_c *Storager_GetEthLogs_Call) Run(run func(tx types.Querier, query multidownloadertypes.LogQuery)) *Storager_GetEthLogs_Call
- func (_c *Storager_GetEthLogs_Call) RunAndReturn(...) *Storager_GetEthLogs_Call
- type Storager_GetSyncedBlockRangePerContract_Call
- func (_c *Storager_GetSyncedBlockRangePerContract_Call) Return(_a0 multidownloadertypes.SetSyncSegment, _a1 error) *Storager_GetSyncedBlockRangePerContract_Call
- func (_c *Storager_GetSyncedBlockRangePerContract_Call) Run(run func(tx types.Querier)) *Storager_GetSyncedBlockRangePerContract_Call
- func (_c *Storager_GetSyncedBlockRangePerContract_Call) RunAndReturn(run func(types.Querier) (multidownloadertypes.SetSyncSegment, error)) *Storager_GetSyncedBlockRangePerContract_Call
- type Storager_GetValue_Call
- func (_c *Storager_GetValue_Call) Return(_a0 string, _a1 error) *Storager_GetValue_Call
- func (_c *Storager_GetValue_Call) Run(run func(tx types.Querier, owner string, key string)) *Storager_GetValue_Call
- func (_c *Storager_GetValue_Call) RunAndReturn(run func(types.Querier, string, string) (string, error)) *Storager_GetValue_Call
- type Storager_InsertValue_Call
- func (_c *Storager_InsertValue_Call) Return(_a0 error) *Storager_InsertValue_Call
- func (_c *Storager_InsertValue_Call) Run(run func(tx types.Querier, owner string, key string, value string)) *Storager_InsertValue_Call
- func (_c *Storager_InsertValue_Call) RunAndReturn(run func(types.Querier, string, string, string) error) *Storager_InsertValue_Call
- type Storager_NewTx_Call
- type Storager_SaveEthLogsWithHeaders_Call
- func (_c *Storager_SaveEthLogsWithHeaders_Call) Return(_a0 error) *Storager_SaveEthLogsWithHeaders_Call
- func (_c *Storager_SaveEthLogsWithHeaders_Call) Run(run func(tx types.Querier, blockHeaders []*aggkittypes.BlockHeader, ...)) *Storager_SaveEthLogsWithHeaders_Call
- func (_c *Storager_SaveEthLogsWithHeaders_Call) RunAndReturn(...) *Storager_SaveEthLogsWithHeaders_Call
- type Storager_UpdateSyncedStatus_Call
- func (_c *Storager_UpdateSyncedStatus_Call) Return(_a0 error) *Storager_UpdateSyncedStatus_Call
- func (_c *Storager_UpdateSyncedStatus_Call) Run(run func(tx types.Querier, segments []multidownloadertypes.SyncSegment)) *Storager_UpdateSyncedStatus_Call
- func (_c *Storager_UpdateSyncedStatus_Call) RunAndReturn(run func(types.Querier, []multidownloadertypes.SyncSegment) error) *Storager_UpdateSyncedStatus_Call
- type Storager_UpdateValue_Call
- func (_c *Storager_UpdateValue_Call) Return(_a0 error) *Storager_UpdateValue_Call
- func (_c *Storager_UpdateValue_Call) Run(run func(tx types.Querier, owner string, key string, value string)) *Storager_UpdateValue_Call
- func (_c *Storager_UpdateValue_Call) RunAndReturn(run func(types.Querier, string, string, string) error) *Storager_UpdateValue_Call
- type Storager_UpsertSyncerConfigs_Call
- func (_c *Storager_UpsertSyncerConfigs_Call) Return(_a0 error) *Storager_UpsertSyncerConfigs_Call
- func (_c *Storager_UpsertSyncerConfigs_Call) Run(run func(tx types.Querier, configs []multidownloadertypes.ContractConfig)) *Storager_UpsertSyncerConfigs_Call
- func (_c *Storager_UpsertSyncerConfigs_Call) RunAndReturn(run func(types.Querier, []multidownloadertypes.ContractConfig) error) *Storager_UpsertSyncerConfigs_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Storager ¶
Storager is an autogenerated mock type for the Storager type
func NewStorager ¶
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, bool, error)
GetBlockHeaderByNumber provides a mock function with given fields: tx, blockNumber
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) GetSyncedBlockRangePerContract ¶
func (_m *Storager) GetSyncedBlockRangePerContract(tx types.Querier) (multidownloadertypes.SetSyncSegment, error)
GetSyncedBlockRangePerContract provides a mock function with given fields: tx
func (*Storager) InsertValue ¶
InsertValue provides a mock function with given fields: tx, owner, key, value
func (*Storager) SaveEthLogsWithHeaders ¶
func (_m *Storager) SaveEthLogsWithHeaders(tx types.Querier, blockHeaders []*aggkittypes.BlockHeader, logs []coretypes.Log, isFinal bool) error
SaveEthLogsWithHeaders provides a mock function with given fields: tx, blockHeaders, logs, isFinal
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 ¶
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 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) 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) 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) 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) 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.BlockHeader
- logs []coretypes.Log
- isFinal bool
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 ¶
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 bool, _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, bool, error)) *Storager_GetBlockHeaderByNumber_Call
type Storager_GetEthLogs_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_GetSyncedBlockRangePerContract_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 ¶
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_InsertValue_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_NewTx_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 ¶
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.BlockHeader, logs []coretypes.Log, isFinal bool)) *Storager_SaveEthLogsWithHeaders_Call
func (*Storager_SaveEthLogsWithHeaders_Call) RunAndReturn ¶
func (_c *Storager_SaveEthLogsWithHeaders_Call) RunAndReturn(run func(types.Querier, []*aggkittypes.BlockHeader, []coretypes.Log, bool) error) *Storager_SaveEthLogsWithHeaders_Call
type Storager_UpdateSyncedStatus_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 ¶
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 ¶
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