logs

Documentation

Index

• Variables
• type ILogDelegator
• type ILogExtractor
• type LogDelegator
  • func NewLogDelegator(db *postgres.DB) *LogDelegator
  • func (delegator *LogDelegator) AddTransformer(t transformer.EventTransformer)
  • func (delegator *LogDelegator) DelegateLogs() error
• type LogExtractor
  • func NewLogExtractor(db *postgres.DB, bc core.BlockChain) *LogExtractor
  • func (extractor *LogExtractor) AddTransformerConfig(config transformer.EventTransformerConfig) error
  • func (extractor LogExtractor) ExtractLogs(recheckHeaders constants.TransformerExecution) error

Variables

var (
	ErrNoLogs         = errors.New("no logs available for transforming")
	ErrNoTransformers = errors.New("no event transformers configured in the log delegator")
)

var (
	ErrNoUncheckedHeaders = errors.New("no unchecked headers available for log fetching")
	ErrNoWatchedAddresses = errors.New("no watched addresses configured in the log extractor")
)

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.EventLogRepository
	Transformers  []transformer.EventTransformer
}

func NewLogDelegator

func NewLogDelegator(db *postgres.DB) *LogDelegator

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.EventLogRepository
	StartingBlock            *int64
	EndingBlock              *int64
	Syncer                   transactions.ITransactionsSyncer
	Topics                   []common.Hash
	RecheckHeaderCap         int64
}

func NewLogExtractor

func NewLogExtractor(db *postgres.DB, bc core.BlockChain) *LogExtractor

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