watcher

Documentation

Index

• Variables
• type DiffStatusToWatch
• type EventWatcher
  • func NewEventWatcher(db *postgres.DB, bc core.BlockChain, extractor logs.ILogExtractor, ...) EventWatcher
  • func (watcher *EventWatcher) AddTransformers(initializers []event.TransformerInitializer) error
  • func (watcher *EventWatcher) Execute(recheckHeaders constants.TransformerExecution) error
• type IStorageWatcher
• type StorageWatcher
  • func NewStorageWatcher(db *postgres.DB, backFromHeadOfChain int64, statusWriter fs.StatusWriter, ...) StorageWatcher
  • func PendingStorageWatcher(db *postgres.DB, backFromHeadOfChain int64, statusWriter fs.StatusWriter, ...) StorageWatcher
  • func UnrecognizedStorageWatcher(db *postgres.DB, backFromHeadOfChain int64, statusWriter fs.StatusWriter, ...) StorageWatcher
  • func (watcher StorageWatcher) AddTransformers(initializers []storage2.TransformerInitializer)
  • func (watcher StorageWatcher) Execute() error
  • func (watcher StorageWatcher) StorageWatcherName() string

Variables

var (
	ErrHeaderMismatch = errors.New("header hash doesn't match between db and diff")
	ReorgWindow       = 50
	ResultsLimit      = 500
)

Types

type DiffStatusToWatch

type DiffStatusToWatch int

const (
	New DiffStatusToWatch = iota
	Unrecognized
	Pending
)

type EventWatcher

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
}

func NewEventWatcher

func NewEventWatcher(db *postgres.DB, bc core.BlockChain, extractor logs.ILogExtractor, delegator logs.ILogDelegator, maxConsecutiveUnexpectedErrs int, retryInterval time.Duration, statusWriter fs.StatusWriter) EventWatcher

func (*EventWatcher) AddTransformers

func (watcher *EventWatcher) AddTransformers(initializers []event.TransformerInitializer) error

Adds transformers to the watcher so that their logs will be extracted and delegated.

func (*EventWatcher) Execute

func (watcher *EventWatcher) Execute(recheckHeaders constants.TransformerExecution) error

Extracts and delegates watched log events.

type IStorageWatcher

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

type StorageWatcher

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
}

func NewStorageWatcher

func NewStorageWatcher(db *postgres.DB, backFromHeadOfChain int64, statusWriter fs.StatusWriter, minWaitTime time.Duration) StorageWatcher

func PendingStorageWatcher

func PendingStorageWatcher(db *postgres.DB, backFromHeadOfChain int64, statusWriter fs.StatusWriter, minWaitTime time.Duration) StorageWatcher

func UnrecognizedStorageWatcher

func UnrecognizedStorageWatcher(db *postgres.DB, backFromHeadOfChain int64, statusWriter fs.StatusWriter, minWaitTime time.Duration) StorageWatcher

func (StorageWatcher) AddTransformers

func (watcher StorageWatcher) AddTransformers(initializers []storage2.TransformerInitializer)

func (StorageWatcher) Execute

func (watcher StorageWatcher) Execute() error

func (StorageWatcher) StorageWatcherName

func (watcher StorageWatcher) StorageWatcherName() string