stages

Documentation

Index

• func NewStagedSync(ctx context.Context, sm ethdb.StorageMode, headers stagedsync.HeadersCfg, ...) *stagedsync.StagedSync
• func StageLoop(ctx context.Context, db ethdb.Database, sync *stagedsync.StagedSync, ...)
• func StageLoopStep(ctx context.Context, db ethdb.Database, sync *stagedsync.StagedSync, ...) (err error)

Functions

func NewStagedSync

func NewStagedSync(
	ctx context.Context,
	sm ethdb.StorageMode,
	headers stagedsync.HeadersCfg,
	blockHashes stagedsync.BlockHashesCfg,
	bodies stagedsync.BodiesCfg,
	senders stagedsync.SendersCfg,
	exec stagedsync.ExecuteBlockCfg,
	hashState stagedsync.HashStateCfg,
	trieCfg stagedsync.TrieCfg,
	history stagedsync.HistoryCfg,
	logIndex stagedsync.LogIndexCfg,
	callTraces stagedsync.CallTracesCfg,
	txLookup stagedsync.TxLookupCfg,
	txPool stagedsync.TxPoolCfg,
	finish stagedsync.FinishCfg,
) *stagedsync.StagedSync

func StageLoop

func StageLoop(
	ctx context.Context,
	db ethdb.Database,
	sync *stagedsync.StagedSync,
	hd *headerdownload.HeaderDownload,
	chainConfig *params.ChainConfig,
	notifier stagedsync.ChainEventNotifier,
	waitForDone chan struct{},
)

StageLoop runs the continuous loop of staged sync

func StageLoopStep

func StageLoopStep(
	ctx context.Context,
	db ethdb.Database,
	sync *stagedsync.StagedSync,
	highestSeenHeader uint64,
	chainConfig *params.ChainConfig,
	notifier stagedsync.ChainEventNotifier,
	initialCycle bool,
) (err error)