Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrNoLogs = errors.New("no logs available for transforming") ErrNoTransformers = errors.New("no event transformers configured in the log delegator") )
View Source
var ( ErrNoUncheckedHeaders = errors.New("no unchecked headers available for log fetching") ErrNoWatchedAddresses = errors.New("no watched addresses configured in the log extractor") )
Functions ¶
This section is empty.
Types ¶
type ILogDelegator ¶
type ILogDelegator interface { AddTransformer(t transformer.EventTransformer) DelegateLogs() error }
type ILogExtractor ¶
type ILogExtractor interface { AddTransformerConfig(config transformer.EventTransformerConfig) error ExtractLogs(recheckHeaders constants.TransformerExecution) error }
type LogDelegator ¶
type LogDelegator struct { Chunker chunker.Chunker LogRepository datastore.HeaderSyncLogRepository Transformers []transformer.EventTransformer }
func (*LogDelegator) AddTransformer ¶
func (delegator *LogDelegator) AddTransformer(t transformer.EventTransformer)
func (*LogDelegator) DelegateLogs ¶
func (delegator *LogDelegator) DelegateLogs() error
type LogExtractor ¶
type LogExtractor struct { Addresses []common.Address CheckedHeadersRepository datastore.CheckedHeadersRepository CheckedLogsRepository datastore.CheckedLogsRepository Fetcher fetcher.ILogFetcher LogRepository datastore.HeaderSyncLogRepository StartingBlock *int64 Syncer transactions.ITransactionsSyncer Topics []common.Hash }
func (*LogExtractor) AddTransformerConfig ¶
func (extractor *LogExtractor) AddTransformerConfig(config transformer.EventTransformerConfig) error
Add additional logs to extract
func (LogExtractor) ExtractLogs ¶
func (extractor LogExtractor) ExtractLogs(recheckHeaders constants.TransformerExecution) error
Fetch and persist watched logs
Click to show internal directories.
Click to hide internal directories.