fetcher

package
v0.1.2 Latest Latest
Warning

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

Go to latest
Published: Sep 30, 2021 License: AGPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CsvTailStorageFetcher

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

func NewCsvTailStorageFetcher

func NewCsvTailStorageFetcher(tailer fs.Tailer, statusWriter fs.StatusWriter) CsvTailStorageFetcher

func (CsvTailStorageFetcher) FetchStorageDiffs

func (storageFetcher CsvTailStorageFetcher) FetchStorageDiffs(out chan<- types.RawDiff, errs chan<- error)

type GethRpcStorageFetcher

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

func NewGethRpcStorageFetcher

func NewGethRpcStorageFetcher(streamer streamer.Streamer, statediffPayloadChan chan filters.Payload, statusWriter fs.StatusWriter) GethRpcStorageFetcher

func (GethRpcStorageFetcher) FetchStorageDiffs

func (fetcher GethRpcStorageFetcher) FetchStorageDiffs(out chan<- types.RawDiff, errs chan<- error)

type IStorageFetcher

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

Jump to

Keyboard shortcuts

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