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
Source Files
Click to show internal directories.
Click to hide internal directories.