synchronizer

Apr 21, 2021

Changes in this version

type Config

+ StatsUpdateBlockNumDiffThreshold uint16

+ StatsUpdateFrequencyDivider uint16

Mar 25, 2021

Changes in this version

+ var ErrUnknownBlock = fmt.Errorf("unknown block")

+ type Config struct

+ ChainID uint16

+ StatsRefreshPeriod time.Duration

+ type StartBlockNums struct

+ Auction int64

+ Rollup int64

+ WDelayer int64

+ type Stats struct

+ Eth struct{ ... }

+ Sync struct{ ... }

+ func (s *Stats) Synced() bool

+ type StatsHolder struct

+ func NewStatsHolder(firstBlockNum int64, refreshPeriod time.Duration) *StatsHolder

+ func (s *StatsHolder) CopyStats() *Stats

+ func (s *StatsHolder) UpdateCurrentNextSlot(current *common.Slot, next *common.Slot)

+ func (s *StatsHolder) UpdateEth(ethClient eth.ClientInterface) error

+ func (s *StatsHolder) UpdateSync(lastBlock *common.Block, lastBatch *common.Batch, lastL1BatchBlock *int64, ...)

+ type Synchronizer struct

+ func NewSynchronizer(ethClient eth.ClientInterface, historyDB *historydb.HistoryDB, l2DB *l2db.L2DB, ...) (*Synchronizer, error)

+ func (s *Synchronizer) AuctionConstants() *common.AuctionConstants

+ func (s *Synchronizer) RollupConstants() *common.RollupConstants

+ func (s *Synchronizer) SCVars() *common.SCVariables

+ func (s *Synchronizer) StateDB() *statedb.StateDB

+ func (s *Synchronizer) Stats() *Stats

+ func (s *Synchronizer) Sync(ctx context.Context, lastSavedBlock *common.Block) (blockData *common.BlockData, discarded *int64, err error)

+ func (s *Synchronizer) WDelayerConstants() *common.WDelayerConstants