watcher

type DiffStatusToWatch int

type EventWatcher struct {
	LogExtractor                 logs.ILogExtractor
	ExpectedExtractorError       error
	LogDelegator                 logs.ILogDelegator
	ExpectedDelegatorError       error
	MaxConsecutiveUnexpectedErrs int
	RetryInterval                time.Duration
	StatusWriter                 fs.StatusWriter
	// contains filtered or unexported fields
}

type IStorageWatcher interface {
	AddTransformers(initializers []storage2.TransformerInitializer)
	Execute() error
	StorageWatcherName() string
}

type StorageWatcher struct {
	HeaderRepository          datastore.HeaderRepository
	AddressTransformers       map[common.Address]storage2.ITransformer // contract address => transformer
	StorageDiffRepository     storage.DiffRepository
	DiffBlocksFromHeadOfChain int64 // the number of blocks from the head of the chain where diffs should be processed
	StatusWriter              fs.StatusWriter
	DiffStatus                DiffStatusToWatch
	Throttler                 utils.ThrottlerFunc
	// contains filtered or unexported fields
}