syncer

Documentation

Index

• type IEtherman
• type L1Syncer
  • func NewL1Syncer(em IEtherman, l1ContractAddress common.Address, blockRange, queryDelay uint64) *L1Syncer
  • func (s *L1Syncer) GetLastCheckedL1Block() uint64
  • func (s *L1Syncer) GetProgressMessageChan() chan string
  • func (s *L1Syncer) GetSequencesChan() chan types.L1BatchInfo
  • func (s *L1Syncer) GetVerificationsChan() chan types.L1BatchInfo
  • func (s *L1Syncer) IsDownloading() bool
  • func (s *L1Syncer) IsSyncStarted() bool
  • func (s *L1Syncer) Run(lastCheckedBlock uint64)

Types

type IEtherman

type IEtherman interface {
	BlockByNumber(ctx context.Context, blockNumber *big.Int) (*ethTypes.Block, error)
	FilterLogs(ctx context.Context, query ethereum.FilterQuery) ([]ethTypes.Log, error)
}

type L1Syncer

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

func NewL1Syncer

func NewL1Syncer(em IEtherman, l1ContractAddress common.Address, blockRange, queryDelay uint64) *L1Syncer

func (*L1Syncer) GetLastCheckedL1Block

func (s *L1Syncer) GetLastCheckedL1Block() uint64

func (*L1Syncer) GetProgressMessageChan

func (s *L1Syncer) GetProgressMessageChan() chan string

func (*L1Syncer) GetSequencesChan

func (s *L1Syncer) GetSequencesChan() chan types.L1BatchInfo

func (*L1Syncer) GetVerificationsChan

func (s *L1Syncer) GetVerificationsChan() chan types.L1BatchInfo

Channels

func (*L1Syncer) IsDownloading

func (s *L1Syncer) IsDownloading() bool

func (*L1Syncer) IsSyncStarted

func (s *L1Syncer) IsSyncStarted() bool

func (*L1Syncer) Run

func (s *L1Syncer) Run(lastCheckedBlock uint64)