cold_import

Documentation

Index

• Constants
• Variables
• type ColdImportNodeBuilder
  • func NewColdImportNodeBuilder(reader fs.Reader, parser crypto.PublicKeyParser) ColdImportNodeBuilder
  • func (cinb ColdImportNodeBuilder) GetNode(genesisBlock []byte, levelPath string) (core.Node, error)
• type ColdImporter
  • func NewColdImporter(ethDB ethereum.Database, blockRepository datastore.BlockRepository, ...) *ColdImporter
  • func (ci *ColdImporter) Execute(startingBlockNumber int64, endingBlockNumber int64, nodeId string) error

Constants

const (
	ColdImportClientName         = "LevelDbColdImport"
	ColdImportNetworkId  float64 = 1
)

Variables

var (
	NoChainDataErr = errors.New("Level DB path does not include chaindata extension.")
	NoGethRootErr  = errors.New("Level DB path does not include root path to geth.")
)

Types

type ColdImportNodeBuilder

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

func NewColdImportNodeBuilder

func NewColdImportNodeBuilder(reader fs.Reader, parser crypto.PublicKeyParser) ColdImportNodeBuilder

func (ColdImportNodeBuilder) GetNode

func (cinb ColdImportNodeBuilder) GetNode(genesisBlock []byte, levelPath string) (core.Node, error)

type ColdImporter

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

func NewColdImporter

func NewColdImporter(ethDB ethereum.Database, blockRepository datastore.BlockRepository, receiptRepository datastore.ReceiptRepository, converter common.BlockConverter) *ColdImporter

func (*ColdImporter) Execute

func (ci *ColdImporter) Execute(startingBlockNumber int64, endingBlockNumber int64, nodeId string) error