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 + const L2BlockHeaderForGenesis + const ParallelMode + const SequentialMode + type ClientFlushIDControl struct + func NewFlushIDController(state syncinterfaces.StateFullInterface, ctx context.Context, ...) *ClientFlushIDControl + func (s *ClientFlushIDControl) BlockUntilLastFlushIDIsWritten(dbTx pgx.Tx) error + func (s *ClientFlushIDControl) SetPendingFlushIDAndCheckProverID(flushID uint64, proverID string, callDescription string) + func (s *ClientFlushIDControl) UpdateAndCheckProverID(proverID string) + type ClientSynchronizer struct + func (s *ClientSynchronizer) CheckFlushID(dbTx pgx.Tx) error + func (s *ClientSynchronizer) CleanTrustedState() + func (s *ClientSynchronizer) ExecuteReorgFromMismatchBlock(blockNumber uint64, reason string) error + func (s *ClientSynchronizer) IsTrustedSequencer() bool + func (s *ClientSynchronizer) OnDetectedMismatchL1BlockReorg() + func (s *ClientSynchronizer) PendingFlushID(flushID uint64, proverID string) + func (s *ClientSynchronizer) ProcessBlockRange(blocks []etherman.Block, order map[common.Hash][]etherman.Order) error + func (s *ClientSynchronizer) RequestAndProcessRollupGenesisBlock(dbTx pgx.Tx, lastEthBlockSynced *state.Block) error + func (s *ClientSynchronizer) Stop() + func (s *ClientSynchronizer) Sync() error + type Config struct + L1BlockCheck L1BlockCheckConfig + L1ParallelSynchronization L1ParallelSynchronizationConfig + L1SyncCheckL2BlockHash bool + L1SyncCheckL2BlockNumberhModulus uint64 + L1SynchronizationMode string + L2Synchronization l2_sync.Config + SyncBlockProtection string + SyncChunkSize uint64 + SyncInterval types.Duration + TrustedSequencerURL string + type ExtCmdArgs []string + type ExtControlCmd interface + FunctionName func() string + Help func() string + Process func(ExtCmdArgs) (string, error) + ValidateArguments func(ExtCmdArgs) error + type FlushIDController interface + BlockUntilLastFlushIDIsWritten func(dbTx pgx.Tx) error + SetPendingFlushIDAndCheckProverID func(flushID uint64, proverID string, callDescription string) + UpdateAndCheckProverID func(proverID string) + type L1BlockCheckConfig struct + Enable bool + ForceCheckBeforeStart bool + L1PreSafeBlockOffset int + L1PreSafeBlockPoint string + L1SafeBlockOffset int + L1SafeBlockPoint string + PreCheckEnable bool + func (c *L1BlockCheckConfig) String() string + type L1ParallelSynchronizationConfig struct + FallbackToSequentialModeOnSynchronized bool + MaxClients uint64 + MaxPendingNoProcessedBlocks uint64 + PerformanceWarning L1PerformanceCheckConfig + RequestLastBlockMaxRetries int + RequestLastBlockPeriod types.Duration + RequestLastBlockTimeout types.Duration + RollupInfoRetriesSpacing types.Duration + StatisticsPeriod types.Duration + TimeOutMainLoop types.Duration + type L1PerformanceCheckConfig struct + AceptableInacctivityTime types.Duration + ApplyAfterNumRollupReceived int + type Synchronizer interface + Stop func() + Sync func() error + func NewSynchronizer(isTrustedSequencer bool, ethMan syncinterfaces.EthermanFullInterface, ...) (Synchronizer, error) + type TrustedState struct + LastStateRoot *common.Hash + LastTrustedBatches []*state.Batch