fetcher

Documentation

Index

• type CsvTailStorageFetcher
  • func NewCsvTailStorageFetcher(tailer fs.Tailer) CsvTailStorageFetcher
  • func (storageFetcher CsvTailStorageFetcher) FetchStorageDiffs(out chan<- utils.StorageDiffRow, errs chan<- error)
• type ILogFetcher
• type IStorageFetcher
• type LogFetcher
  • func NewLogFetcher(blockchain core.BlockChain) *LogFetcher
  • func (logFetcher LogFetcher) FetchLogs(addresses []common.Address, topic0s []common.Hash, header core.Header) ([]types.Log, error)

Types

type CsvTailStorageFetcher

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

func NewCsvTailStorageFetcher

func NewCsvTailStorageFetcher(tailer fs.Tailer) CsvTailStorageFetcher

func (CsvTailStorageFetcher) FetchStorageDiffs

func (storageFetcher CsvTailStorageFetcher) FetchStorageDiffs(out chan<- utils.StorageDiffRow, errs chan<- error)

type ILogFetcher

type ILogFetcher interface {
	FetchLogs(contractAddresses []common.Address, topics []common.Hash, missingHeader core.Header) ([]types.Log, error)
}

type IStorageFetcher

type IStorageFetcher interface {
	FetchStorageDiffs(chan<- utils.StorageDiffRow, chan<- error)
}

type LogFetcher

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

func NewLogFetcher

func NewLogFetcher(blockchain core.BlockChain) *LogFetcher

func (LogFetcher) FetchLogs

func (logFetcher LogFetcher) FetchLogs(addresses []common.Address, topic0s []common.Hash, header core.Header) ([]types.Log, error)

Checks all topic0s, on all addresses, fetching matching logs for the given header