logs

Documentation

Index

• Variables
• func ChunkRanges(startingBlock, endingBlock, interval int64) ([]map[BlockIdentifier]int64, error)
• type BlockIdentifier
• type ILogDelegator
• type ILogExtractor
• type LogDelegator
  • func NewLogDelegator(db *postgres.DB) *LogDelegator
  • func (delegator *LogDelegator) AddTransformer(t event.ITransformer)
  • func (delegator *LogDelegator) DelegateLogs(limit int) error
• type LogExtractor
  • func NewLogExtractor(db *postgres.DB, bc core.BlockChain, chr datastore.CheckedHeadersRepository) *LogExtractor
  • func (extractor *LogExtractor) AddTransformerConfig(config event.TransformerConfig) error
  • func (extractor LogExtractor) BackFillLogs(endingBlock int64) 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 (
	StartInterval         BlockIdentifier = "start"
	EndInterval           BlockIdentifier = "end"
	ErrNoUncheckedHeaders                 = errors.New("no unchecked headers available for log fetching")
	ErrNoWatchedAddresses                 = errors.New("no watched addresses configured in the log extractor")
	HeaderChunkSize       int64           = 1000
)

Functions

func ChunkRanges

func ChunkRanges(startingBlock, endingBlock, interval int64) ([]map[BlockIdentifier]int64, error)

Types

type BlockIdentifier

type BlockIdentifier string

type ILogDelegator

type ILogDelegator interface {
	AddTransformer(t event.ITransformer)
	DelegateLogs(limit int) error
}

type ILogExtractor

type ILogExtractor interface {
	AddTransformerConfig(config event.TransformerConfig) error
	BackFillLogs(endingBlock int64) error
	ExtractLogs(recheckHeaders constants.TransformerExecution) error
}

type LogDelegator

type LogDelegator struct {
	Chunker       chunker.Chunker
	LogRepository datastore.EventLogRepository
	Transformers  []event.ITransformer
}

func NewLogDelegator

func NewLogDelegator(db *postgres.DB) *LogDelegator

func (*LogDelegator) AddTransformer

func (delegator *LogDelegator) AddTransformer(t event.ITransformer)

func (*LogDelegator) DelegateLogs

func (delegator *LogDelegator) DelegateLogs(limit int) error

type LogExtractor

type LogExtractor struct {
	Addresses                []common.Address
	CheckedHeadersRepository datastore.CheckedHeadersRepository
	CheckedLogsRepository    datastore.CheckedLogsRepository
	Fetcher                  fetcher.ILogFetcher
	HeaderRepository         datastore.HeaderRepository
	LogRepository            datastore.EventLogRepository
	StartingBlock            *int64
	EndingBlock              *int64
	Syncer                   transactions.ITransactionsSyncer
	Topics                   []common.Hash
	Throttler                utils.ThrottlerFuncWithArg

	RecheckHeaderCap int64
	// contains filtered or unexported fields
}

func NewLogExtractor

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

func (*LogExtractor) AddTransformerConfig

func (extractor *LogExtractor) AddTransformerConfig(config event.TransformerConfig) error

AddTransformerConfig adds additional logs to extract

func (LogExtractor) BackFillLogs

func (extractor LogExtractor) BackFillLogs(endingBlock int64) error

BackFillLogs fetches and persists watched logs from provided range of headers

func (LogExtractor) ExtractLogs

func (extractor LogExtractor) ExtractLogs(recheckHeaders constants.TransformerExecution) error

ExtractLogs fetches and persists watched logs from unchecked headers