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 + var ErrBatchResourceOverFlow = errors.New("batch resource overflow") + var ErrDecodeBatchL2Data = errors.New("decoding BatchL2Data error") + var ErrDuplicatedNonce = errors.New("duplicated nonce") + var ErrEffectiveGasPriceReprocess = errors.New("effective gas price requires reprocessing the transaction") + var ErrExecutorError = errors.New("executor error") + var ErrExpiredTransaction = errors.New("transaction expired") + var ErrGetBatchByNumber = errors.New("get batch by number error") + var ErrNoFittingTransaction = errors.New("no fit transaction") + var ErrProcessBatch = errors.New("processing batch error") + var ErrProcessBatchOOC = errors.New("processing batch OOC") + var ErrReplacedTransaction = errors.New("replaced transaction") + var ErrStateRootNoMatch = errors.New("state root no match") + var ErrTransactionsListEmpty = errors.New("transactions list empty") + var ErrUpdateBatchAsChecked = errors.New("update batch as checked error") + type Batch struct + type Config struct + DeletePoolTxsCheckInterval types.Duration + DeletePoolTxsL1BlockConfirmations uint64 + Finalizer FinalizerCfg + LoadPoolTxsCheckInterval types.Duration + StateConsistencyCheckInterval types.Duration + StreamServer StreamServerCfg + TxLifetimeCheckInterval types.Duration + TxLifetimeMax types.Duration + type DbTxMock struct + func NewDbTxMock(t interface{ ... }) *DbTxMock + func (_m *DbTxMock) Begin(ctx context.Context) (pgx.Tx, error) + func (_m *DbTxMock) BeginFunc(ctx context.Context, f func(pgx.Tx) error) error + func (_m *DbTxMock) Commit(ctx context.Context) error + func (_m *DbTxMock) Conn() *pgx.Conn + func (_m *DbTxMock) CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, ...) (int64, error) + func (_m *DbTxMock) Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error) + func (_m *DbTxMock) LargeObjects() pgx.LargeObjects + func (_m *DbTxMock) Prepare(ctx context.Context, name string, sql string) (*pgconn.StatementDescription, error) + func (_m *DbTxMock) Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error) + func (_m *DbTxMock) QueryFunc(ctx context.Context, sql string, args []interface{}, scans []interface{}, ...) (pgconn.CommandTag, error) + func (_m *DbTxMock) QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row + func (_m *DbTxMock) Rollback(ctx context.Context) error + func (_m *DbTxMock) SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults + type EthermanMock struct + func NewEthermanMock(t interface{ ... }) *EthermanMock + func (_m *EthermanMock) DepositCount(ctx context.Context, blockNumber *uint64) (*big.Int, error) + func (_m *EthermanMock) GetLatestBatchNumber() (uint64, error) + func (_m *EthermanMock) GetLatestBlockNumber(ctx context.Context) (uint64, error) + func (_m *EthermanMock) GetRollupInfoByBlockRange(ctx context.Context, fromBlock uint64, toBlock *uint64) ([]etherman.Block, map[common.Hash][]etherman.Order, error) + func (_m *EthermanMock) HeaderByNumber(ctx context.Context, number *big.Int) (*types.Header, error) + func (_m *EthermanMock) TrustedSequencer() (common.Address, error) + type FinalizerCfg struct + BatchMaxDeltaTimestamp types.Duration + ForcedBatchesCheckInterval types.Duration + ForcedBatchesL1BlockConfirmations uint64 + ForcedBatchesTimeout types.Duration + HaltOnBatchNumber uint64 + L1InfoTreeCheckInterval types.Duration + L1InfoTreeL1BlockConfirmations uint64 + L2BlockMaxDeltaTimestamp types.Duration + Metrics MetricsCfg + NewTxsWaitInterval types.Duration + ResourceExhaustedMarginPct uint32 + SequentialBatchSanityCheck bool + SequentialProcessL2Block bool + type L2Block struct + type MetricsCfg struct + EnableLog bool + Interval types.Duration + type PoolMock struct + func NewPoolMock(t interface{ ... }) *PoolMock + func (_m *PoolMock) DeleteFailedTransactionsOlderThan(ctx context.Context, date time.Time) error + func (_m *PoolMock) DeleteTransactionByHash(ctx context.Context, hash common.Hash) error + func (_m *PoolMock) DeleteTransactionsByHashes(ctx context.Context, hashes []common.Hash) error + func (_m *PoolMock) GetDefaultMinGasPriceAllowed() uint64 + func (_m *PoolMock) GetEarliestProcessedTx(ctx context.Context) (common.Hash, error) + func (_m *PoolMock) GetGasPrices(ctx context.Context) (pool.GasPrices, error) + func (_m *PoolMock) GetL1AndL2GasPrice() (uint64, uint64) + func (_m *PoolMock) GetNonWIPPendingTxs(ctx context.Context) ([]pool.Transaction, error) + func (_m *PoolMock) GetTxZkCountersByHash(ctx context.Context, hash common.Hash) (*state.ZKCounters, *state.ZKCounters, error) + func (_m *PoolMock) MarkWIPTxsAsPending(ctx context.Context) error + func (_m *PoolMock) UpdateTxStatus(ctx context.Context, hash common.Hash, newStatus pool.TxStatus, isWIP bool, ...) error + func (_m *PoolMock) UpdateTxWIPStatus(ctx context.Context, hash common.Hash, isWIP bool) error + type Sequencer struct + func New(cfg Config, batchCfg state.BatchConfig, poolCfg pool.Config, txPool txPool, ...) (*Sequencer, error) + func (s *Sequencer) Start(ctx context.Context) + type StateMock struct + func NewStateMock(t interface{ ... }) *StateMock + func (_m *StateMock) BeginStateTransaction(ctx context.Context) (pgx.Tx, error) + func (_m *StateMock) BuildChangeL2Block(deltaTimestamp uint32, l1InfoTreeIndex uint32) []byte + func (_m *StateMock) CloseBatch(ctx context.Context, receipt state.ProcessingReceipt, dbTx pgx.Tx) error + func (_m *StateMock) CloseWIPBatch(ctx context.Context, receipt state.ProcessingReceipt, dbTx pgx.Tx) error + func (_m *StateMock) CountReorgs(ctx context.Context, dbTx pgx.Tx) (uint64, error) + func (_m *StateMock) GetBalanceByStateRoot(ctx context.Context, address common.Address, root common.Hash) (*big.Int, error) + func (_m *StateMock) GetBatchByNumber(ctx context.Context, batchNumber uint64, dbTx pgx.Tx) (*state.Batch, error) + func (_m *StateMock) GetBlockByNumber(ctx context.Context, blockNumber uint64, dbTx pgx.Tx) (*state.Block, error) + func (_m *StateMock) GetDSBatches(ctx context.Context, firstBatchNumber uint64, lastBatchNumber uint64, ...) ([]*state.DSBatch, error) + func (_m *StateMock) GetDSGenesisBlock(ctx context.Context, dbTx pgx.Tx) (*state.DSL2Block, error) + func (_m *StateMock) GetDSL2Blocks(ctx context.Context, firstBatchNumber uint64, lastBatchNumber uint64, ...) ([]*state.DSL2Block, error) + func (_m *StateMock) GetDSL2Transactions(ctx context.Context, firstL2Block uint64, lastL2Block uint64, dbTx pgx.Tx) ([]*state.DSL2Transaction, error) + func (_m *StateMock) GetForcedBatch(ctx context.Context, forcedBatchNumber uint64, dbTx pgx.Tx) (*state.ForcedBatch, error) + func (_m *StateMock) GetForcedBatchParentHash(ctx context.Context, forcedBatchNumber uint64, dbTx pgx.Tx) (common.Hash, error) + func (_m *StateMock) GetForcedBatchesSince(ctx context.Context, forcedBatchNumber uint64, maxBlockNumber uint64, ...) ([]*state.ForcedBatch, error) + func (_m *StateMock) GetForkIDByBatchNumber(batchNumber uint64) uint64 + func (_m *StateMock) GetL1InfoRootLeafByIndex(ctx context.Context, l1InfoTreeIndex uint32, dbTx pgx.Tx) (state.L1InfoTreeExitRootStorageEntry, error) + func (_m *StateMock) GetL1InfoTreeDataFromBatchL2Data(ctx context.Context, batchL2Data []byte, dbTx pgx.Tx) (map[uint32]state.L1DataV2, common.Hash, common.Hash, error) + func (_m *StateMock) GetLastBatchNumber(ctx context.Context, dbTx pgx.Tx) (uint64, error) + func (_m *StateMock) GetLastBlock(ctx context.Context, dbTx pgx.Tx) (*state.Block, error) + func (_m *StateMock) GetLastL2Block(ctx context.Context, dbTx pgx.Tx) (*state.L2Block, error) + func (_m *StateMock) GetLastStateRoot(ctx context.Context, dbTx pgx.Tx) (common.Hash, error) + func (_m *StateMock) GetLastTrustedForcedBatchNumber(ctx context.Context, dbTx pgx.Tx) (uint64, error) + func (_m *StateMock) GetLastVirtualBatchNum(ctx context.Context, dbTx pgx.Tx) (uint64, error) + func (_m *StateMock) GetLatestBatchGlobalExitRoot(ctx context.Context, dbTx pgx.Tx) (common.Hash, error) + func (_m *StateMock) GetLatestL1InfoRoot(ctx context.Context, maxBlockNumber uint64) (state.L1InfoTreeExitRootStorageEntry, error) + func (_m *StateMock) GetNonceByStateRoot(ctx context.Context, address common.Address, root common.Hash) (*big.Int, error) + func (_m *StateMock) GetNotCheckedBatches(ctx context.Context, dbTx pgx.Tx) ([]*state.Batch, error) + func (_m *StateMock) GetStorageAt(ctx context.Context, address common.Address, position *big.Int, ...) (*big.Int, error) + func (_m *StateMock) GetStoredFlushID(ctx context.Context) (uint64, string, error) + func (_m *StateMock) GetTxsOlderThanNL1BlocksUntilTxHash(ctx context.Context, nL1Blocks uint64, earliestTxHash common.Hash, dbTx pgx.Tx) ([]common.Hash, error) + func (_m *StateMock) GetVirtualBatchParentHash(ctx context.Context, batchNumber uint64, dbTx pgx.Tx) (common.Hash, error) + func (_m *StateMock) OpenBatch(ctx context.Context, processingContext state.ProcessingContext, dbTx pgx.Tx) error + func (_m *StateMock) OpenWIPBatch(ctx context.Context, batch state.Batch, dbTx pgx.Tx) error + func (_m *StateMock) ProcessBatchV2(ctx context.Context, request state.ProcessRequest, updateMerkleTree bool) (*state.ProcessBatchResponse, error) + func (_m *StateMock) StoreL2Block(ctx context.Context, batchNumber uint64, l2Block *state.ProcessBlockResponse, ...) error + func (_m *StateMock) UpdateBatchAsChecked(ctx context.Context, batchNumber uint64, dbTx pgx.Tx) error + func (_m *StateMock) UpdateWIPBatch(ctx context.Context, receipt state.ProcessingReceipt, dbTx pgx.Tx) error + type StreamServerCfg struct + ChainID uint64 + Enabled bool + Filename string + Log log.Config + Port uint16 + UpgradeEtrogBatchNumber uint64 + Version uint8 + type TxTracker struct + Bytes uint64 + Cost *big.Int + EGPLog state.EffectiveGasPriceLog + EGPPercentage byte + EffectiveGasPrice *big.Int + FailedReason *string + From common.Address + FromStr string + Gas uint64 + GasPrice *big.Int + Hash common.Hash + HashStr string + IP string + IsLastExecution bool + L1GasPrice uint64 + L2GasPrice uint64 + Nonce uint64 + RawTx []byte + ReceivedAt time.Time + ReservedZKCounters state.ZKCounters + UsedZKCounters state.ZKCounters + type Worker struct + func NewWorker(state stateInterface, constraints state.BatchConstraintsCfg, ...) *Worker + func (w *Worker) AddForcedTx(txHash common.Hash, addr common.Address) + func (w *Worker) AddPendingTxToStore(txHash common.Hash, addr common.Address) + func (w *Worker) AddTxTracker(ctx context.Context, tx *TxTracker) (replacedTx *TxTracker, dropReason error) + func (w *Worker) DeleteForcedTx(txHash common.Hash, addr common.Address) + func (w *Worker) DeletePendingTxToStore(txHash common.Hash, addr common.Address) + func (w *Worker) DeleteTx(txHash common.Hash, addr common.Address) + func (w *Worker) ExpireTransactions(maxTime time.Duration) []*TxTracker + func (w *Worker) GetBestFittingTx(resources state.BatchResources) (*TxTracker, error) + func (w *Worker) MoveTxToNotReady(txHash common.Hash, from common.Address, actualNonce *uint64, ...) []*TxTracker + func (w *Worker) NewTxTracker(tx types.Transaction, usedZKCounters state.ZKCounters, ...) (*TxTracker, error) + func (w *Worker) UpdateAfterSingleSuccessfulTxExecution(from common.Address, touchedAddresses map[common.Address]*state.InfoReadWrite) []*TxTracker + func (w *Worker) UpdateTxZKCounters(txHash common.Hash, addr common.Address, usedZKCounters state.ZKCounters, ...) + type WorkerMock struct + func NewWorkerMock(t interface{ ... }) *WorkerMock + func (_m *WorkerMock) AddForcedTx(txHash common.Hash, addr common.Address) + func (_m *WorkerMock) AddPendingTxToStore(txHash common.Hash, addr common.Address) + func (_m *WorkerMock) AddTxTracker(ctx context.Context, txTracker *TxTracker) (*TxTracker, error) + func (_m *WorkerMock) DeleteForcedTx(txHash common.Hash, addr common.Address) + func (_m *WorkerMock) DeletePendingTxToStore(txHash common.Hash, addr common.Address) + func (_m *WorkerMock) DeleteTx(txHash common.Hash, from common.Address) + func (_m *WorkerMock) GetBestFittingTx(resources state.BatchResources) (*TxTracker, error) + func (_m *WorkerMock) MoveTxToNotReady(txHash common.Hash, from common.Address, actualNonce *uint64, ...) []*TxTracker + func (_m *WorkerMock) NewTxTracker(tx types.Transaction, usedZKcounters state.ZKCounters, ...) (*TxTracker, error) + func (_m *WorkerMock) UpdateAfterSingleSuccessfulTxExecution(from common.Address, touchedAddresses map[common.Address]*state.InfoReadWrite) []*TxTracker + func (_m *WorkerMock) UpdateTxZKCounters(txHash common.Hash, from common.Address, usedZKCounters state.ZKCounters, ...)
Go to main page