ethereum

type Filter struct {
	LogAddresses []common.Address `yaml:"log_addresses"`
	LogTopics    []common.Hash    `yaml:"log_topics"`
}

type Option struct {
	BlockNumberStart  *big.Int `json:"block_number_start" mapstructure:"block_number_start"`
	BlockNumberTarget *big.Int `json:"block_number_target" mapstructure:"block_number_target"`

	// RPCThreadBlocks is the number of concurrent RPC requests associated with the blocks.
	RPCThreadBlocks       *uint `json:"rpc_thread_blocks" mapstructure:"rpc_thread_blocks"`
	RPCBatchBlocks        *uint `json:"rpc_batch_blocks" mapstructure:"rpc_batch_blocks"`
	RPCBatchReceipts      *uint `json:"rpc_batch_receipts" mapstructure:"rpc_batch_blocks"`
	RPCBatchBlockReceipts *uint `json:"rpc_batch_block_receipts" mapstructure:"rpc_batch_block_receipts"`
}

type State struct {
	BlockHash   common.Hash `json:"block_hash"`
	BlockNumber uint64      `json:"block_number"`
}

type Task struct {
	Network     network.Network
	ChainID     uint64
	Header      *ethereum.Header
	Transaction *ethereum.Transaction
	Receipt     *ethereum.Receipt
}