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. Changes to this field don't
	// cause data inconsistencies and therefore don't need to be stored in the id field of the checkpoint.
	RPCThreadBlocks *uint64 `json:"-" mapstructure:"rpc_thread_blocks"`
}

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

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