fetcher

package
v0.0.9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 28, 2019 License: AGPL-3.0 Imports: 12 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CsvTailStorageFetcher added in v0.0.2

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

func NewCsvTailStorageFetcher added in v0.0.2

func NewCsvTailStorageFetcher(tailer fs.Tailer) CsvTailStorageFetcher

func (CsvTailStorageFetcher) FetchStorageDiffs added in v0.0.2

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

type GethRpcStorageFetcher added in v0.0.8

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

func NewGethRpcStorageFetcher added in v0.0.8

func NewGethRpcStorageFetcher(streamer streamer.Streamer, statediffPayloadChan chan statediff.Payload) GethRpcStorageFetcher

func (GethRpcStorageFetcher) FetchStorageDiffs added in v0.0.8

func (fetcher GethRpcStorageFetcher) FetchStorageDiffs(out chan<- utils.StorageDiff, errs chan<- error)

type ILogFetcher added in v0.0.2

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

type IStorageFetcher added in v0.0.2

type IStorageFetcher interface {
	FetchStorageDiffs(out chan<- utils.StorageDiff, errs chan<- error)
}

type LogFetcher

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

func NewLogFetcher added in v0.0.2

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL