ethereum

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

type Option struct {
	// BlockStart is the block height on Arweave that the worker should start from.
	BlockStart *big.Int `json:"block_start" mapstructure:"block_start"`
	// BlockTarget is the block height on Arweave that the worker should stop at.
	BlockTarget *big.Int `json:"block_target" mapstructure:"block_target"`
	// ConcurrentBlockRequests is the number of blocks to request concurrently.
	ConcurrentBlockRequests *uint64 `json:"concurrent_block_requests" mapstructure:"concurrent_block_requests"`
	// BlockBatchSize is the number of blocks to fetch in a single batch.
	BlockBatchSize *uint `json:"block_batch_size" mapstructure:"block_batch_size"`
	// ReceiptsBatchSize is the number of receipts to fetch in a single batch.
	ReceiptsBatchSize *uint `json:"receipts_batch_size" mapstructure:"receipts_batch_size"`
	// BlockReceiptsBatchSize is the number of block receipts to fetch in a single batch.
	BlockReceiptsBatchSize *uint `json:"block_receipts_batch_size" mapstructure:"block_receipts_batch_size"`
}

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
}