blob

Documentation

Index

• type Syncer
  • func NewSyncer(ctx context.Context, client *rpc.Client, state *state.State, ...) (*Syncer, error)
  • func (s *Syncer) BlocksInserterOntake() *blocksInserter.BlocksInserterOntake
  • func (s *Syncer) BlocksInserterPacaya() *blocksInserter.BlocksInserterPacaya
  • func (s *Syncer) ProcessL1Blocks(ctx context.Context) error

Types

type Syncer

type Syncer struct {
	// contains filtered or unexported fields
}

Syncer responsible for letting the L2 execution engine catching up with protocol's latest pending block through deriving L1 calldata.

func NewSyncer

func NewSyncer(
	ctx context.Context,
	client *rpc.Client,
	state *state.State,
	progressTracker *beaconsync.SyncProgressTracker,
	blobServerEndpoint *url.URL,
) (*Syncer, error)

NewSyncer creates a new syncer instance.

func (*Syncer) BlocksInserterOntake

func (s *Syncer) BlocksInserterOntake() *blocksInserter.BlocksInserterOntake

BlocksInserterOntake returns the Ontake blocks inserter.

func (*Syncer) BlocksInserterPacaya

func (s *Syncer) BlocksInserterPacaya() *blocksInserter.BlocksInserterPacaya

BlocksInserterPacaya returns the Pacaya blocks inserter.

func (*Syncer) ProcessL1Blocks

func (s *Syncer) ProcessL1Blocks(ctx context.Context) error

ProcessL1Blocks fetches all `TaikoL1.BlockProposed` events between given L1 block heights, and then tries inserting them into L2 execution engine's blockchain.