Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitStartBlock ¶ added in v0.0.3
InitStartBlock initializes the L1 sync task by finding the inception block for the CDKValidium contract
Types ¶
type BatchSynchronizer ¶
type BatchSynchronizer struct {
// contains filtered or unexported fields
}
BatchSynchronizer watches for number events, checks if they are "locally" stored, then retrieves and stores missing data
func NewBatchSynchronizer ¶
func NewBatchSynchronizer( cfg config.L1Config, self common.Address, db db.DB, reorgs <-chan BlockReorg, ethClient etherman.Etherman, sequencer SequencerTracker, rpcClientFactory client.Factory, ) (*BatchSynchronizer, error)
NewBatchSynchronizer creates the BatchSynchronizer
func (*BatchSynchronizer) Start ¶
func (bs *BatchSynchronizer) Start()
Start starts the synchronizer
type BlockReorg ¶
BlockReorg is emitted to subscribers when a reorg is detected. Number is the block to which the chain rewound.
type ReorgDetector ¶
type ReorgDetector struct {
// contains filtered or unexported fields
}
ReorgDetector watches for block reorganizations on chain, and sends messages to subscribing components when a reorg is detected.
func NewReorgDetector ¶
func NewReorgDetector(rpcUrl string, pollingPeriod time.Duration) (*ReorgDetector, error)
NewReorgDetector creates a new ReorgDetector
func (*ReorgDetector) Start ¶
func (rd *ReorgDetector) Start() error
Start starts the ReorgDetector tracking for reorg events
func (*ReorgDetector) Stop ¶
func (rd *ReorgDetector) Stop()
Stop stops the chain reorganization detector loop
func (*ReorgDetector) Subscribe ¶
func (rd *ReorgDetector) Subscribe() <-chan BlockReorg
Subscribe returns a channel on which the caller can receive reorg messages
Source Files