indexer

package

v0.1.3 Latest Latest Go to latest Published: Dec 13, 2024 License: MIT Imports: 19 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type BlockTracker struct {
	// contains filtered or unexported fields
}

* BlockTracker keeps a database record of the latest block that has been indexed for a contract address and allows the user to increase the value. *

func NewBlockTracker(
	ctx context.Context,
	contractAddress string,
	queries *queries.Queries,
) (*BlockTracker, error)

Return a new BlockTracker initialized to the latest block from the DB

func (bt *BlockTracker) GetLatestBlock() uint64

func (bt *BlockTracker) UpdateLatestBlock(ctx context.Context, block uint64) error

type IBlockTracker interface {
	GetLatestBlock() uint64
	UpdateLatestBlock(ctx context.Context, block uint64) error
}

type Indexer struct {
	// contains filtered or unexported fields
}

func NewIndexer(
	ctx context.Context,
	log *zap.Logger,

) *Indexer

func (s *Indexer) Close()

func (i *Indexer) StartIndexer(
	db *sql.DB,
	cfg config.ContractsOptions,
	validationService mlsvalidate.MLSValidationService) error

Path	Synopsis
storer