processors

Documentation

Index

• type BridgeProcessor
  • func NewBridgeProcessor(log log.Logger, db *database.DB, metrics bridge.Metricer, l1Etl *etl.L1ETL, ...) (*BridgeProcessor, error)
  • func (b *BridgeProcessor) Close() error
  • func (b *BridgeProcessor) Start() error

Types

type BridgeProcessor

type BridgeProcessor struct {
	LastL1Header *database.L1BlockHeader
	LastL2Header *database.L2BlockHeader

	LastFinalizedL1Header *database.L1BlockHeader
	LastFinalizedL2Header *database.L2BlockHeader
	// contains filtered or unexported fields
}

func NewBridgeProcessor

func NewBridgeProcessor(log log.Logger, db *database.DB, metrics bridge.Metricer, l1Etl *etl.L1ETL, l2Etl *etl.L2ETL,
	chainConfig config.ChainConfig, shutdown context.CancelCauseFunc) (*BridgeProcessor, error)

func (*BridgeProcessor) Close

func (b *BridgeProcessor) Close() error

func (*BridgeProcessor) Start

func (b *BridgeProcessor) Start() error