processor

Documentation

Index

• type L1Contracts
• type L1Processor
  • func NewL1Processor(ethClient node.EthClient, db *database.DB, l1Contracts L1Contracts) (*L1Processor, error)
  • func (p L1Processor) Start()
• type L2Contracts
  • func L2ContractPredeploys() L2Contracts
• type L2Processor
  • func NewL2Processor(ethClient node.EthClient, db *database.DB, l2Contracts L2Contracts) (*L2Processor, error)
  • func (p L2Processor) Start()
• type ProcessFn

Types

type L1Contracts

type L1Contracts struct {
	SlicePortal            common.Address
	L2OutputOracle         common.Address
	L1CrossDomainMessenger common.Address
	L1StandardBridge       common.Address
	L1ERC721Bridge         common.Address
}

type L1Processor

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

func NewL1Processor

func NewL1Processor(ethClient node.EthClient, db *database.DB, l1Contracts L1Contracts) (*L1Processor, error)

func (L1Processor) Start

func (p L1Processor) Start()

Start kicks off the processing loop

type L2Contracts

type L2Contracts struct {
	L2CrossDomainMessenger common.Address
	L2StandardBridge       common.Address
	L2ERC721Bridge         common.Address
	L2ToL1MessagePasser    common.Address
}

func L2ContractPredeploys

func L2ContractPredeploys() L2Contracts

type L2Processor

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

func NewL2Processor

func NewL2Processor(ethClient node.EthClient, db *database.DB, l2Contracts L2Contracts) (*L2Processor, error)

func (L2Processor) Start

func (p L2Processor) Start()

Start kicks off the processing loop

type ProcessFn

type ProcessFn func(*database.DB, []*types.Header) error

ProcessFn is the the entrypoint for processing a batch of headers. In the event of failure, database operations are rolled back