importer

Documentation

Index

• func EnsureInitialImport(db idb.IndexerDb, genesis bookkeeping.Genesis) (bool, error)
• func GetGenesisFile(genesisJSONPath string, client *algod.Client, l *log.Logger) io.Reader
• type ImportHelper
  • func NewImportHelper(genesisJSONPath string, blockFileLimite int, l *log.Logger) *ImportHelper
  • func (h *ImportHelper) Import(db idb.IndexerDb, args []string)
• type Importer
  • func NewImporter(db idb.IndexerDb) Importer

Functions

func EnsureInitialImport

func EnsureInitialImport(db idb.IndexerDb, genesis bookkeeping.Genesis) (bool, error)

EnsureInitialImport imports the genesis block if needed. Returns true if the initial import occurred.

func GetGenesisFile

func GetGenesisFile(genesisJSONPath string, client *algod.Client, l *log.Logger) io.Reader

GetGenesisFile creates a reader from the given genesis file

Types

type ImportHelper

type ImportHelper struct {
	// GenesisJSONPath is the location of the genesis file
	GenesisJSONPath string

	// BlockFileLimit is the number of block files to process.
	BlockFileLimit int

	Log *log.Logger
}

ImportHelper glues together a directory full of block files and an Importer objects.

func NewImportHelper

func NewImportHelper(genesisJSONPath string, blockFileLimite int, l *log.Logger) *ImportHelper

NewImportHelper builds an ImportHelper

func (*ImportHelper) Import

func (h *ImportHelper) Import(db idb.IndexerDb, args []string)

Import is the main ImportHelper function that glues together a directory full of block files and an Importer objects.

type Importer

type Importer interface {
	ImportBlock(vb *ledgercore.ValidatedBlock) error
}

Importer is used to import blocks into an idb.IndexerDb object.

func NewImporter

func NewImporter(db idb.IndexerDb) Importer

NewImporter creates a new importer object.