backfill

Jul 11, 2023

Changes in this version

+ func BlockHashesInRange(ctx context.Context, backend ScribeBackend, startHeight uint64, ...) (*immutable.Map[uint64, string], error)

+ func MakeRange(min, max T) []T

+ type LogFetcher struct

+ func NewLogFetcher(address ethCommon.Address, backend ScribeBackend, ...) *LogFetcher

+ func (f *LogFetcher) FetchLogs(ctx context.Context, chunks []*util.Chunk) ([]types.Log, error)

+ func (f *LogFetcher) GetChunkArr() (chunkArr []*util.Chunk)

+ func (f *LogFetcher) Start(ctx context.Context) error

Apr 5, 2023

Changes in this version

type ScribeBackend

+ BatchWithContext func(ctx context.Context, calls ...w3types.Caller) error

Nov 26, 2022

Changes in this version

+ func GetLogsInRange(ctx context.Context, backend ScribeBackend, startHeight uint64, ...) (*immutable.List[*[]types.Log], error)

Nov 22, 2022

Changes in this version

+ func BlockTimesInRange(ctx context.Context, backend ScribeBackend, startHeight uint64, ...) (*immutable.Map[uint64, uint64], error)

type ScribeBackend

+ func DialBackend(ctx context.Context, url string) (ScribeBackend, error)

+ Batch func(ctx context.Context, calls ...w3types.Caller) error

Nov 10, 2022

Changes in this version

+ const ErrorLevel

+ const InfoLevel

+ const WarnLevel

+ func LogEvent(level logLevel, msg string, logData LogData)

+ type LogData map[string]interface

Sep 30, 2022

Changes in this version

type ScribeBackend

+ HeaderByNumber func(ctx context.Context, number *big.Int) (*types.Header, error)

Sep 13, 2022

Changes in this version

type ScribeBackend

+ BlockByNumber func(ctx context.Context, number *big.Int) (*types.Block, error)

Sep 1, 2022

Changes in this version

+ type LogFilterer interface

+ FilterLogs func(ctx context.Context, query ethereum.FilterQuery) ([]types.Log, error)

+ type ScribeBackend interface

+ BlockNumber func(ctx context.Context) (uint64, error)

+ ChainID func(ctx context.Context) (*big.Int, error)

+ FilterLogs func(ctx context.Context, query ethereum.FilterQuery) ([]types.Log, error)

+ TransactionByHash func(ctx context.Context, txHash common.Hash) (tx *types.Transaction, isPending bool, err error)

+ TransactionReceipt func(ctx context.Context, txHash common.Hash) (*types.Receipt, error)

type ScribeBackfiller

+ ChainBackfillers map[uint32]*ChainBackfiller

Aug 30, 2022

Changes in this version

+ type ScribeBackfiller struct

+ func NewScribeBackfiller(eventDB db.EventDB, clients []client.EVMClient, config config.Config) (*ScribeBackfiller, error)

+ func (s ScribeBackfiller) Backfill(ctx context.Context) error

Aug 29, 2022

Changes in this version

+ type ChainBackfiller struct

+ func NewChainBackfiller(eventDB db.EventDB, client client.EVMClient, chainConfig config.ChainConfig) (*ChainBackfiller, error)

+ func (c ChainBackfiller) Backfill(ctx context.Context, endHeight uint64) error

Aug 28, 2022

Changes in this version

+ type ContractBackfiller struct

+ func NewContractBackfiller(contract contracts.DeployedContract, eventDB db.EventDB, ...) (*ContractBackfiller, error)

+ func (c ContractBackfiller) Backfill(ctx context.Context, givenStart uint64, endHeight uint64) error

+ func (c ContractBackfiller) GetLogs(ctx context.Context, startHeight, endHeight uint64) (logsChan <-chan types.Log, errsChan <-chan error, completeChan <-chan bool)

+ func (c ContractBackfiller) StartHeightForBackfill(ctx context.Context, givenStart uint64) (startHeight uint64, err error)

+ func (c ContractBackfiller) Store(ctx context.Context, log types.Log) error

+ type LogInfo struct

+ type RangeFilter struct

+ func NewRangeFilter(address ethCommon.Address, filterer bind.ContractFilterer, ...) *RangeFilter

+ func (f *RangeFilter) Done() bool

+ func (f *RangeFilter) Drain(ctx context.Context) (filteredLogs []types.Log, err error)

+ func (f *RangeFilter) FilterLogs(ctx context.Context, chunk *common.Chunk) (*LogInfo, error)

+ func (f *RangeFilter) GetLogChan() chan *LogInfo

+ func (f *RangeFilter) Start(ctx context.Context) error