backfill

Documentation

Overview

Package backfill provides a command to backfill the consumer database.

Index

• func ProcessLogs(ctx context.Context, logs []ethTypes.Log, chainID uint32, ...) (parsedLogs []interface{}, _ error)
• type ChainBackfiller
  • func NewChainBackfiller(consumerDB db.ConsumerDB, bridgeParser *parser.BridgeParser, ...) *ChainBackfiller
  • func (c *ChainBackfiller) Backfill(ctx context.Context, livefill bool, refreshRate int) (err error)

Functions

func ProcessLogs

func ProcessLogs(ctx context.Context, logs []ethTypes.Log, chainID uint32, eventParser parser.Parser) (parsedLogs []interface{}, _ error)

ProcessLogs processes the logs and stores them in the consumer database.

Types

type ChainBackfiller

type ChainBackfiller struct {

	// Fetcher is the Fetcher to use to fetch logs.
	Fetcher fetcher.ScribeFetcher
	// contains filtered or unexported fields
}

ChainBackfiller is an explorer backfiller for a chain.

func NewChainBackfiller

func NewChainBackfiller(consumerDB db.ConsumerDB, bridgeParser *parser.BridgeParser, swapParsers map[common.Address]*parser.SwapParser, messageBusParser *parser.MessageBusParser, cctpParser *parser.CCTPParser, fetcher fetcher.ScribeFetcher, chainConfig indexerconfig.ChainConfig) *ChainBackfiller

NewChainBackfiller creates a new backfiller for a chain.

func (*ChainBackfiller) Backfill

func (c *ChainBackfiller) Backfill(ctx context.Context, livefill bool, refreshRate int) (err error)

Backfill fetches logs from the GraphQL database, parses them, and stores them in the consumer database. nolint:cyclop,gocognit