replayer

type BlocksProvider ¶

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

This BlocksProvider implementation is used in the EVM events ingestion pipeline. The ingestion module notifies the BlocksProvider of incoming EVM blocks, by calling the `OnBlockReceived` method. This method guarantees that blocks are processed sequentially, and keeps track of the latest block, which is used for generating the proper `BlockContext`. This is necessary for replaying EVM blocks/transactions locally, and verifying that there are no state mismatches.

func NewBlocksProvider(
	blocks storage.BlockIndexer,
	chainID flowGo.ChainID,
) *BlocksProvider

func (bp *BlocksProvider) GetSnapshotAt(height uint64) (
	evmTypes.BlockSnapshot,
	error,
)

func (bp *BlocksProvider) OnBlockReceived(block *models.Block) error

type Config ¶

type Config struct {
	ChainID         flow.ChainID
	RootAddr        flow.Address
	ValidateResults bool
}