Versions in this module Expand all Collapse all v1 v1.1.3 Jan 20, 2025 v1.1.2 Jan 20, 2025 Changes in this version + type BatchProcessor struct + func NewBatchProcessor(t interface{ ... }) *BatchProcessor + func (_m *BatchProcessor) EXPECT() *BatchProcessor_Expecter + func (_m *BatchProcessor) ProcessTrustedBatch(ctx context.Context, trustedBatch *types.Batch, status l2_shared.TrustedState, ...) (*l2_shared.TrustedState, error) + type BatchProcessor_Expecter struct + func (_e *BatchProcessor_Expecter) ProcessTrustedBatch(ctx interface{}, trustedBatch interface{}, status interface{}, ...) *BatchProcessor_ProcessTrustedBatch_Call + type BatchProcessor_ProcessTrustedBatch_Call struct + 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 L1SyncGlobalExitRootChecker struct + func NewL1SyncGlobalExitRootChecker(t interface{ ... }) *L1SyncGlobalExitRootChecker + func (_m *L1SyncGlobalExitRootChecker) CheckL1SyncGlobalExitRootEnoughToProcessBatch(ctx context.Context, batchNumber uint64, globalExitRoot common.Hash, ...) error + func (_m *L1SyncGlobalExitRootChecker) EXPECT() *L1SyncGlobalExitRootChecker_Expecter + type L1SyncGlobalExitRootChecker_CheckL1SyncGlobalExitRootEnoughToProcessBatch_Call struct + func (_c *L1SyncGlobalExitRootChecker_CheckL1SyncGlobalExitRootEnoughToProcessBatch_Call) Return(_a0 error) ... + func (_c *L1SyncGlobalExitRootChecker_CheckL1SyncGlobalExitRootEnoughToProcessBatch_Call) Run(...) ... + func (_c *L1SyncGlobalExitRootChecker_CheckL1SyncGlobalExitRootEnoughToProcessBatch_Call) RunAndReturn(run func(context.Context, uint64, common.Hash, pgx.Tx) error) ... + type L1SyncGlobalExitRootChecker_Expecter struct + func (_e *L1SyncGlobalExitRootChecker_Expecter) CheckL1SyncGlobalExitRootEnoughToProcessBatch(ctx interface{}, batchNumber interface{}, globalExitRoot interface{}, ...) ... + type PostClosedBatchChecker struct + func NewPostClosedBatchChecker(t interface{ ... }) *PostClosedBatchChecker + func (_m *PostClosedBatchChecker) CheckPostClosedBatch(ctx context.Context, processData l2_shared.ProcessData, dbTx pgx.Tx) error + func (_m *PostClosedBatchChecker) EXPECT() *PostClosedBatchChecker_Expecter + type PostClosedBatchChecker_CheckPostClosedBatch_Call struct + func (_c *PostClosedBatchChecker_CheckPostClosedBatch_Call) Return(_a0 error) *PostClosedBatchChecker_CheckPostClosedBatch_Call + func (_c *PostClosedBatchChecker_CheckPostClosedBatch_Call) Run(run func(ctx context.Context, processData l2_shared.ProcessData, dbTx pgx.Tx)) *PostClosedBatchChecker_CheckPostClosedBatch_Call + func (_c *PostClosedBatchChecker_CheckPostClosedBatch_Call) RunAndReturn(run func(context.Context, l2_shared.ProcessData, pgx.Tx) error) *PostClosedBatchChecker_CheckPostClosedBatch_Call + type PostClosedBatchChecker_Expecter struct + func (_e *PostClosedBatchChecker_Expecter) CheckPostClosedBatch(ctx interface{}, processData interface{}, dbTx interface{}) *PostClosedBatchChecker_CheckPostClosedBatch_Call + type StateInterface struct + func NewStateInterface(t interface{ ... }) *StateInterface + func (_m *StateInterface) BeginStateTransaction(ctx context.Context) (pgx.Tx, error) + func (_m *StateInterface) EXPECT() *StateInterface_Expecter + func (_m *StateInterface) GetBatchByNumber(ctx context.Context, batchNumber uint64, dbTx pgx.Tx) (*state.Batch, error) + type StateInterface_BeginStateTransaction_Call struct + 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 struct + func (_e *StateInterface_Expecter) BeginStateTransaction(ctx interface{}) *StateInterface_BeginStateTransaction_Call + func (_e *StateInterface_Expecter) GetBatchByNumber(ctx interface{}, batchNumber interface{}, dbTx interface{}) *StateInterface_GetBatchByNumber_Call + type StateInterface_GetBatchByNumber_Call struct + 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 struct + func NewSyncTrustedBatchExecutor(t interface{ ... }) *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 struct + 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 struct + 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 struct + 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 struct + 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 struct + 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
Go to main page