etl

type Config struct {
	LoopIntervalMsec uint
	HeaderBufferSize uint

	// Applicable only to the L1 ETL (all L2 block are indexed)
	AllowedInactivityWindowSeconds uint

	StartHeight       *big.Int
	ConfirmationDepth *big.Int
}

type ETL struct {
	EthClient node.EthClient
	// contains filtered or unexported fields
}

type ETLBatch struct {
	Logger log.Logger

	Headers   []types.Header
	HeaderMap map[common.Hash]*types.Header

	Logs           []types.Log
	HeadersWithLog map[common.Hash]bool
}

type L1ETL struct {
	ETL
	// contains filtered or unexported fields
}

type L2ETL struct {
	ETL
	// contains filtered or unexported fields
}

type Metricer interface {
	RecordInterval() (done func(err error))
	RecordLatestHeight(height *big.Int)

	RecordEtlLatestHeight(height *big.Int)
	RecordIndexedHeaders(size int)
	RecordIndexedLog(contractAddress common.Address)
}