Documentation ¶
Index ¶
- type BatchProcessor
- type BatchProcessor_Expecter
- type BatchProcessor_ProcessTrustedBatch_Call
- func (_c *BatchProcessor_ProcessTrustedBatch_Call) Return(_a0 *l2_shared.TrustedState, _a1 error) *BatchProcessor_ProcessTrustedBatch_Call
- func (_c *BatchProcessor_ProcessTrustedBatch_Call) Run(...) *BatchProcessor_ProcessTrustedBatch_Call
- func (_c *BatchProcessor_ProcessTrustedBatch_Call) RunAndReturn(...) *BatchProcessor_ProcessTrustedBatch_Call
- type StateInterface
- type StateInterface_BeginStateTransaction_Call
- func (_c *StateInterface_BeginStateTransaction_Call) Return(_a0 pgx.Tx, _a1 error) *StateInterface_BeginStateTransaction_Call
- func (_c *StateInterface_BeginStateTransaction_Call) Run(run func(ctx context.Context)) *StateInterface_BeginStateTransaction_Call
- func (_c *StateInterface_BeginStateTransaction_Call) RunAndReturn(run func(context.Context) (pgx.Tx, error)) *StateInterface_BeginStateTransaction_Call
- type StateInterface_Expecter
- type StateInterface_GetBatchByNumber_Call
- func (_c *StateInterface_GetBatchByNumber_Call) Return(_a0 *state.Batch, _a1 error) *StateInterface_GetBatchByNumber_Call
- func (_c *StateInterface_GetBatchByNumber_Call) Run(run func(ctx context.Context, batchNumber uint64, dbTx pgx.Tx)) *StateInterface_GetBatchByNumber_Call
- func (_c *StateInterface_GetBatchByNumber_Call) RunAndReturn(run func(context.Context, uint64, pgx.Tx) (*state.Batch, error)) *StateInterface_GetBatchByNumber_Call
- type SyncTrustedBatchExecutor
- func (_m *SyncTrustedBatchExecutor) EXPECT() *SyncTrustedBatchExecutor_Expecter
- func (_m *SyncTrustedBatchExecutor) FullProcess(ctx context.Context, data *l2_shared.ProcessData, dbTx pgx.Tx) (*l2_shared.ProcessResponse, error)
- func (_m *SyncTrustedBatchExecutor) IncrementalProcess(ctx context.Context, data *l2_shared.ProcessData, dbTx pgx.Tx) (*l2_shared.ProcessResponse, error)
- func (_m *SyncTrustedBatchExecutor) NothingProcess(ctx context.Context, data *l2_shared.ProcessData, dbTx pgx.Tx) (*l2_shared.ProcessResponse, error)
- func (_m *SyncTrustedBatchExecutor) ReProcess(ctx context.Context, data *l2_shared.ProcessData, dbTx pgx.Tx) (*l2_shared.ProcessResponse, error)
- type SyncTrustedBatchExecutor_Expecter
- func (_e *SyncTrustedBatchExecutor_Expecter) FullProcess(ctx interface{}, data interface{}, dbTx interface{}) *SyncTrustedBatchExecutor_FullProcess_Call
- func (_e *SyncTrustedBatchExecutor_Expecter) IncrementalProcess(ctx interface{}, data interface{}, dbTx interface{}) *SyncTrustedBatchExecutor_IncrementalProcess_Call
- func (_e *SyncTrustedBatchExecutor_Expecter) NothingProcess(ctx interface{}, data interface{}, dbTx interface{}) *SyncTrustedBatchExecutor_NothingProcess_Call
- func (_e *SyncTrustedBatchExecutor_Expecter) ReProcess(ctx interface{}, data interface{}, dbTx interface{}) *SyncTrustedBatchExecutor_ReProcess_Call
- type SyncTrustedBatchExecutor_FullProcess_Call
- func (_c *SyncTrustedBatchExecutor_FullProcess_Call) Return(_a0 *l2_shared.ProcessResponse, _a1 error) *SyncTrustedBatchExecutor_FullProcess_Call
- func (_c *SyncTrustedBatchExecutor_FullProcess_Call) Run(run func(ctx context.Context, data *l2_shared.ProcessData, dbTx pgx.Tx)) *SyncTrustedBatchExecutor_FullProcess_Call
- func (_c *SyncTrustedBatchExecutor_FullProcess_Call) RunAndReturn(...) *SyncTrustedBatchExecutor_FullProcess_Call
- type SyncTrustedBatchExecutor_IncrementalProcess_Call
- func (_c *SyncTrustedBatchExecutor_IncrementalProcess_Call) Return(_a0 *l2_shared.ProcessResponse, _a1 error) *SyncTrustedBatchExecutor_IncrementalProcess_Call
- func (_c *SyncTrustedBatchExecutor_IncrementalProcess_Call) Run(run func(ctx context.Context, data *l2_shared.ProcessData, dbTx pgx.Tx)) *SyncTrustedBatchExecutor_IncrementalProcess_Call
- func (_c *SyncTrustedBatchExecutor_IncrementalProcess_Call) RunAndReturn(...) *SyncTrustedBatchExecutor_IncrementalProcess_Call
- type SyncTrustedBatchExecutor_NothingProcess_Call
- func (_c *SyncTrustedBatchExecutor_NothingProcess_Call) Return(_a0 *l2_shared.ProcessResponse, _a1 error) *SyncTrustedBatchExecutor_NothingProcess_Call
- func (_c *SyncTrustedBatchExecutor_NothingProcess_Call) Run(run func(ctx context.Context, data *l2_shared.ProcessData, dbTx pgx.Tx)) *SyncTrustedBatchExecutor_NothingProcess_Call
- func (_c *SyncTrustedBatchExecutor_NothingProcess_Call) RunAndReturn(...) *SyncTrustedBatchExecutor_NothingProcess_Call
- type SyncTrustedBatchExecutor_ReProcess_Call
- func (_c *SyncTrustedBatchExecutor_ReProcess_Call) Return(_a0 *l2_shared.ProcessResponse, _a1 error) *SyncTrustedBatchExecutor_ReProcess_Call
- func (_c *SyncTrustedBatchExecutor_ReProcess_Call) Run(run func(ctx context.Context, data *l2_shared.ProcessData, dbTx pgx.Tx)) *SyncTrustedBatchExecutor_ReProcess_Call
- func (_c *SyncTrustedBatchExecutor_ReProcess_Call) RunAndReturn(...) *SyncTrustedBatchExecutor_ReProcess_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BatchProcessor ¶
BatchProcessor is an autogenerated mock type for the BatchProcessor type
func NewBatchProcessor ¶
func NewBatchProcessor(t interface { mock.TestingT Cleanup(func()) }) *BatchProcessor
NewBatchProcessor creates a new instance of BatchProcessor. 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 (*BatchProcessor) EXPECT ¶
func (_m *BatchProcessor) EXPECT() *BatchProcessor_Expecter
func (*BatchProcessor) ProcessTrustedBatch ¶
func (_m *BatchProcessor) ProcessTrustedBatch(ctx context.Context, trustedBatch *types.Batch, status l2_shared.TrustedState, dbTx pgx.Tx, debugPrefix string) (*l2_shared.TrustedState, error)
ProcessTrustedBatch provides a mock function with given fields: ctx, trustedBatch, status, dbTx, debugPrefix
type BatchProcessor_Expecter ¶
type BatchProcessor_Expecter struct {
// contains filtered or unexported fields
}
func (*BatchProcessor_Expecter) ProcessTrustedBatch ¶
func (_e *BatchProcessor_Expecter) ProcessTrustedBatch(ctx interface{}, trustedBatch interface{}, status interface{}, dbTx interface{}, debugPrefix interface{}) *BatchProcessor_ProcessTrustedBatch_Call
ProcessTrustedBatch is a helper method to define mock.On call
- ctx context.Context
- trustedBatch *types.Batch
- status l2_shared.TrustedState
- dbTx pgx.Tx
- debugPrefix string
type BatchProcessor_ProcessTrustedBatch_Call ¶
BatchProcessor_ProcessTrustedBatch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ProcessTrustedBatch'
func (*BatchProcessor_ProcessTrustedBatch_Call) Return ¶
func (_c *BatchProcessor_ProcessTrustedBatch_Call) Return(_a0 *l2_shared.TrustedState, _a1 error) *BatchProcessor_ProcessTrustedBatch_Call
func (*BatchProcessor_ProcessTrustedBatch_Call) Run ¶
func (_c *BatchProcessor_ProcessTrustedBatch_Call) Run(run func(ctx context.Context, trustedBatch *types.Batch, status l2_shared.TrustedState, dbTx pgx.Tx, debugPrefix string)) *BatchProcessor_ProcessTrustedBatch_Call
func (*BatchProcessor_ProcessTrustedBatch_Call) RunAndReturn ¶
func (_c *BatchProcessor_ProcessTrustedBatch_Call) RunAndReturn(run func(context.Context, *types.Batch, l2_shared.TrustedState, pgx.Tx, string) (*l2_shared.TrustedState, error)) *BatchProcessor_ProcessTrustedBatch_Call
type StateInterface ¶
StateInterface is an autogenerated mock type for the StateInterface type
func NewStateInterface ¶
func NewStateInterface(t interface { mock.TestingT Cleanup(func()) }) *StateInterface
NewStateInterface creates a new instance of StateInterface. 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 (*StateInterface) BeginStateTransaction ¶
BeginStateTransaction provides a mock function with given fields: ctx
func (*StateInterface) EXPECT ¶
func (_m *StateInterface) EXPECT() *StateInterface_Expecter
type StateInterface_BeginStateTransaction_Call ¶
StateInterface_BeginStateTransaction_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BeginStateTransaction'
func (*StateInterface_BeginStateTransaction_Call) Return ¶
func (_c *StateInterface_BeginStateTransaction_Call) Return(_a0 pgx.Tx, _a1 error) *StateInterface_BeginStateTransaction_Call
func (*StateInterface_BeginStateTransaction_Call) Run ¶
func (_c *StateInterface_BeginStateTransaction_Call) Run(run func(ctx context.Context)) *StateInterface_BeginStateTransaction_Call
func (*StateInterface_BeginStateTransaction_Call) RunAndReturn ¶
func (_c *StateInterface_BeginStateTransaction_Call) RunAndReturn(run func(context.Context) (pgx.Tx, error)) *StateInterface_BeginStateTransaction_Call
type StateInterface_Expecter ¶
type StateInterface_Expecter struct {
// contains filtered or unexported fields
}
func (*StateInterface_Expecter) BeginStateTransaction ¶
func (_e *StateInterface_Expecter) BeginStateTransaction(ctx interface{}) *StateInterface_BeginStateTransaction_Call
BeginStateTransaction is a helper method to define mock.On call
- ctx context.Context
func (*StateInterface_Expecter) GetBatchByNumber ¶
func (_e *StateInterface_Expecter) GetBatchByNumber(ctx interface{}, batchNumber interface{}, dbTx interface{}) *StateInterface_GetBatchByNumber_Call
GetBatchByNumber is a helper method to define mock.On call
- ctx context.Context
- batchNumber uint64
- dbTx pgx.Tx
type StateInterface_GetBatchByNumber_Call ¶
StateInterface_GetBatchByNumber_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetBatchByNumber'
func (*StateInterface_GetBatchByNumber_Call) Return ¶
func (_c *StateInterface_GetBatchByNumber_Call) Return(_a0 *state.Batch, _a1 error) *StateInterface_GetBatchByNumber_Call
func (*StateInterface_GetBatchByNumber_Call) Run ¶
func (_c *StateInterface_GetBatchByNumber_Call) Run(run func(ctx context.Context, batchNumber uint64, dbTx pgx.Tx)) *StateInterface_GetBatchByNumber_Call
func (*StateInterface_GetBatchByNumber_Call) RunAndReturn ¶
func (_c *StateInterface_GetBatchByNumber_Call) RunAndReturn(run func(context.Context, uint64, pgx.Tx) (*state.Batch, error)) *StateInterface_GetBatchByNumber_Call
type SyncTrustedBatchExecutor ¶
SyncTrustedBatchExecutor is an autogenerated mock type for the SyncTrustedBatchExecutor type
func NewSyncTrustedBatchExecutor ¶
func NewSyncTrustedBatchExecutor(t interface { mock.TestingT Cleanup(func()) }) *SyncTrustedBatchExecutor
NewSyncTrustedBatchExecutor creates a new instance of SyncTrustedBatchExecutor. 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 (*SyncTrustedBatchExecutor) EXPECT ¶
func (_m *SyncTrustedBatchExecutor) EXPECT() *SyncTrustedBatchExecutor_Expecter
func (*SyncTrustedBatchExecutor) FullProcess ¶
func (_m *SyncTrustedBatchExecutor) FullProcess(ctx context.Context, data *l2_shared.ProcessData, dbTx pgx.Tx) (*l2_shared.ProcessResponse, error)
FullProcess provides a mock function with given fields: ctx, data, dbTx
func (*SyncTrustedBatchExecutor) IncrementalProcess ¶
func (_m *SyncTrustedBatchExecutor) IncrementalProcess(ctx context.Context, data *l2_shared.ProcessData, dbTx pgx.Tx) (*l2_shared.ProcessResponse, error)
IncrementalProcess provides a mock function with given fields: ctx, data, dbTx
func (*SyncTrustedBatchExecutor) NothingProcess ¶
func (_m *SyncTrustedBatchExecutor) NothingProcess(ctx context.Context, data *l2_shared.ProcessData, dbTx pgx.Tx) (*l2_shared.ProcessResponse, error)
NothingProcess provides a mock function with given fields: ctx, data, dbTx
func (*SyncTrustedBatchExecutor) ReProcess ¶
func (_m *SyncTrustedBatchExecutor) ReProcess(ctx context.Context, data *l2_shared.ProcessData, dbTx pgx.Tx) (*l2_shared.ProcessResponse, error)
ReProcess provides a mock function with given fields: ctx, data, dbTx
type SyncTrustedBatchExecutor_Expecter ¶
type SyncTrustedBatchExecutor_Expecter struct {
// contains filtered or unexported fields
}
func (*SyncTrustedBatchExecutor_Expecter) FullProcess ¶
func (_e *SyncTrustedBatchExecutor_Expecter) FullProcess(ctx interface{}, data interface{}, dbTx interface{}) *SyncTrustedBatchExecutor_FullProcess_Call
FullProcess is a helper method to define mock.On call
- ctx context.Context
- data *l2_shared.ProcessData
- dbTx pgx.Tx
func (*SyncTrustedBatchExecutor_Expecter) IncrementalProcess ¶
func (_e *SyncTrustedBatchExecutor_Expecter) IncrementalProcess(ctx interface{}, data interface{}, dbTx interface{}) *SyncTrustedBatchExecutor_IncrementalProcess_Call
IncrementalProcess is a helper method to define mock.On call
- ctx context.Context
- data *l2_shared.ProcessData
- dbTx pgx.Tx
func (*SyncTrustedBatchExecutor_Expecter) NothingProcess ¶
func (_e *SyncTrustedBatchExecutor_Expecter) NothingProcess(ctx interface{}, data interface{}, dbTx interface{}) *SyncTrustedBatchExecutor_NothingProcess_Call
NothingProcess is a helper method to define mock.On call
- ctx context.Context
- data *l2_shared.ProcessData
- dbTx pgx.Tx
func (*SyncTrustedBatchExecutor_Expecter) ReProcess ¶
func (_e *SyncTrustedBatchExecutor_Expecter) ReProcess(ctx interface{}, data interface{}, dbTx interface{}) *SyncTrustedBatchExecutor_ReProcess_Call
ReProcess is a helper method to define mock.On call
- ctx context.Context
- data *l2_shared.ProcessData
- dbTx pgx.Tx
type SyncTrustedBatchExecutor_FullProcess_Call ¶
SyncTrustedBatchExecutor_FullProcess_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FullProcess'
func (*SyncTrustedBatchExecutor_FullProcess_Call) Return ¶
func (_c *SyncTrustedBatchExecutor_FullProcess_Call) Return(_a0 *l2_shared.ProcessResponse, _a1 error) *SyncTrustedBatchExecutor_FullProcess_Call
func (*SyncTrustedBatchExecutor_FullProcess_Call) Run ¶
func (_c *SyncTrustedBatchExecutor_FullProcess_Call) Run(run func(ctx context.Context, data *l2_shared.ProcessData, dbTx pgx.Tx)) *SyncTrustedBatchExecutor_FullProcess_Call
func (*SyncTrustedBatchExecutor_FullProcess_Call) RunAndReturn ¶
func (_c *SyncTrustedBatchExecutor_FullProcess_Call) RunAndReturn(run func(context.Context, *l2_shared.ProcessData, pgx.Tx) (*l2_shared.ProcessResponse, error)) *SyncTrustedBatchExecutor_FullProcess_Call
type SyncTrustedBatchExecutor_IncrementalProcess_Call ¶
SyncTrustedBatchExecutor_IncrementalProcess_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IncrementalProcess'
func (*SyncTrustedBatchExecutor_IncrementalProcess_Call) Return ¶
func (_c *SyncTrustedBatchExecutor_IncrementalProcess_Call) Return(_a0 *l2_shared.ProcessResponse, _a1 error) *SyncTrustedBatchExecutor_IncrementalProcess_Call
func (*SyncTrustedBatchExecutor_IncrementalProcess_Call) Run ¶
func (_c *SyncTrustedBatchExecutor_IncrementalProcess_Call) Run(run func(ctx context.Context, data *l2_shared.ProcessData, dbTx pgx.Tx)) *SyncTrustedBatchExecutor_IncrementalProcess_Call
func (*SyncTrustedBatchExecutor_IncrementalProcess_Call) RunAndReturn ¶
func (_c *SyncTrustedBatchExecutor_IncrementalProcess_Call) RunAndReturn(run func(context.Context, *l2_shared.ProcessData, pgx.Tx) (*l2_shared.ProcessResponse, error)) *SyncTrustedBatchExecutor_IncrementalProcess_Call
type SyncTrustedBatchExecutor_NothingProcess_Call ¶
SyncTrustedBatchExecutor_NothingProcess_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NothingProcess'
func (*SyncTrustedBatchExecutor_NothingProcess_Call) Return ¶
func (_c *SyncTrustedBatchExecutor_NothingProcess_Call) Return(_a0 *l2_shared.ProcessResponse, _a1 error) *SyncTrustedBatchExecutor_NothingProcess_Call
func (*SyncTrustedBatchExecutor_NothingProcess_Call) Run ¶
func (_c *SyncTrustedBatchExecutor_NothingProcess_Call) Run(run func(ctx context.Context, data *l2_shared.ProcessData, dbTx pgx.Tx)) *SyncTrustedBatchExecutor_NothingProcess_Call
func (*SyncTrustedBatchExecutor_NothingProcess_Call) RunAndReturn ¶
func (_c *SyncTrustedBatchExecutor_NothingProcess_Call) RunAndReturn(run func(context.Context, *l2_shared.ProcessData, pgx.Tx) (*l2_shared.ProcessResponse, error)) *SyncTrustedBatchExecutor_NothingProcess_Call
type SyncTrustedBatchExecutor_ReProcess_Call ¶
SyncTrustedBatchExecutor_ReProcess_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReProcess'
func (*SyncTrustedBatchExecutor_ReProcess_Call) Return ¶
func (_c *SyncTrustedBatchExecutor_ReProcess_Call) Return(_a0 *l2_shared.ProcessResponse, _a1 error) *SyncTrustedBatchExecutor_ReProcess_Call
func (*SyncTrustedBatchExecutor_ReProcess_Call) Run ¶
func (_c *SyncTrustedBatchExecutor_ReProcess_Call) Run(run func(ctx context.Context, data *l2_shared.ProcessData, dbTx pgx.Tx)) *SyncTrustedBatchExecutor_ReProcess_Call
func (*SyncTrustedBatchExecutor_ReProcess_Call) RunAndReturn ¶
func (_c *SyncTrustedBatchExecutor_ReProcess_Call) RunAndReturn(run func(context.Context, *l2_shared.ProcessData, pgx.Tx) (*l2_shared.ProcessResponse, error)) *SyncTrustedBatchExecutor_ReProcess_Call