stages

Documentation

Index

• func MiningStep(ctx context.Context, db kv.RwDB, mining *stagedsync.Sync, tmpDir string, ...) (err error)
• func NewDefaultStages(ctx context.Context, db kv.RwDB, snapDb kv.RwDB, p2pCfg p2p.Config, ...) []*stagedsync.Stage
• func NewInMemoryExecution(ctx context.Context, db kv.RwDB, cfg *ethconfig.Config, ...) *stagedsync.Sync
• func NewPipelineStages(ctx context.Context, db kv.RwDB, cfg *ethconfig.Config, p2pCfg p2p.Config, ...) []*stagedsync.Stage
• func NewPolygonSyncStages(ctx context.Context, logger log.Logger, db kv.RwDB, config *ethconfig.Config, ...) []*stagedsync.Stage
• func ProcessFrozenBlocks(ctx context.Context, db kv.RwDB, blockReader services.FullBlockReader, ...) error
• func SilkwormForExecutionStage(silkworm *silkworm.Silkworm, cfg *ethconfig.Config) *silkworm.Silkworm
• func StageLoop(ctx context.Context, db kv.RwDB, sync *stagedsync.Sync, ...)
• func StageLoopIteration(ctx context.Context, db kv.RwDB, txc wrap.TxContainer, sync *stagedsync.Sync, ...) (err error)
• func StateStep(ctx context.Context, chainReader consensus.ChainReader, ...) (err error)
• type Hook
  • func NewHook(ctx context.Context, db kv.RoDB, notifications *shards.Notifications, ...) *Hook
  • func (h *Hook) AfterRun(tx kv.Tx, finishProgressBefore uint64) error
  • func (h *Hook) BeforeRun(tx kv.Tx, inSync bool) error
  • func (h *Hook) LastNewBlockSeen(n uint64)

Functions

func MiningStep

func MiningStep(ctx context.Context, db kv.RwDB, mining *stagedsync.Sync, tmpDir string, logger log.Logger) (err error)

func NewDefaultStages

func NewDefaultStages(ctx context.Context,
	db kv.RwDB,
	snapDb kv.RwDB,
	p2pCfg p2p.Config,
	cfg *ethconfig.Config,
	controlServer *sentry_multi_client.MultiClient,
	notifications *shards.Notifications,
	snapDownloader proto_downloader.DownloaderClient,
	blockReader services.FullBlockReader,
	blockRetire services.BlockRetire,
	silkworm *silkworm.Silkworm,
	forkValidator *engine_helpers.ForkValidator,
	heimdallClient heimdall.Client,
	heimdallStore heimdall.Store,
	bridgeStore bridge.Store,
	recents *lru.ARCCache[libcommon.Hash, *bor.Snapshot],
	signatures *lru.ARCCache[libcommon.Hash, libcommon.Address],
	logger log.Logger,
) []*stagedsync.Stage

func NewInMemoryExecution

func NewInMemoryExecution(ctx context.Context, db kv.RwDB, cfg *ethconfig.Config, controlServer *sentry_multi_client.MultiClient,
	dirs datadir.Dirs, notifications *shards.Notifications, blockReader services.FullBlockReader, blockWriter *blockio.BlockWriter,
	silkworm *silkworm.Silkworm, logger log.Logger) *stagedsync.Sync

func NewPipelineStages

func NewPipelineStages(ctx context.Context,
	db kv.RwDB,
	cfg *ethconfig.Config,
	p2pCfg p2p.Config,
	controlServer *sentry_multi_client.MultiClient,
	notifications *shards.Notifications,
	snapDownloader proto_downloader.DownloaderClient,
	blockReader services.FullBlockReader,
	blockRetire services.BlockRetire,
	silkworm *silkworm.Silkworm,
	forkValidator *engine_helpers.ForkValidator,
	logger log.Logger,
	checkStateRoot bool,
) []*stagedsync.Stage

func NewPolygonSyncStages

func NewPolygonSyncStages(
	ctx context.Context,
	logger log.Logger,
	db kv.RwDB,
	config *ethconfig.Config,
	chainConfig *chain.Config,
	consensusEngine consensus.Engine,
	notifications *shards.Notifications,
	snapDownloader proto_downloader.DownloaderClient,
	blockReader services.FullBlockReader,
	blockRetire services.BlockRetire,
	silkworm *silkworm.Silkworm,
	forkValidator *engine_helpers.ForkValidator,
	heimdallClient heimdall.Client,
	heimdallStore heimdall.Store,
	bridgeStore bridge.Store,
	sentry sentryproto.SentryClient,
	maxPeers int,
	statusDataProvider *sentry.StatusDataProvider,
	stopNode func() error,
) []*stagedsync.Stage

func ProcessFrozenBlocks

func ProcessFrozenBlocks(ctx context.Context, db kv.RwDB, blockReader services.FullBlockReader, sync *stagedsync.Sync, hook *Hook) error

ProcessFrozenBlocks - withuot global rwtx

func SilkwormForExecutionStage

func SilkwormForExecutionStage(silkworm *silkworm.Silkworm, cfg *ethconfig.Config) *silkworm.Silkworm

func StageLoop

func StageLoop(
	ctx context.Context,
	db kv.RwDB,
	sync *stagedsync.Sync,
	hd *headerdownload.HeaderDownload,
	waitForDone chan struct{},
	loopMinTime time.Duration,
	logger log.Logger,
	blockReader services.FullBlockReader,
	hook *Hook,
)

StageLoop runs the continuous loop of staged sync

func StageLoopIteration

func StageLoopIteration(ctx context.Context, db kv.RwDB, txc wrap.TxContainer, sync *stagedsync.Sync, initialCycle, firstCycle bool, logger log.Logger, blockReader services.FullBlockReader, hook *Hook) (err error)

func StateStep

func StateStep(ctx context.Context, chainReader consensus.ChainReader, engine consensus.Engine, txc wrap.TxContainer, stateSync *stagedsync.Sync, header *types.Header, body *types.RawBody, unwindPoint uint64, headersChain []*types.Header, bodiesChain []*types.RawBody, test bool) (err error)

Types

type Hook

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

func NewHook

func NewHook(ctx context.Context, db kv.RoDB, notifications *shards.Notifications, sync *stagedsync.Sync, blockReader services.FullBlockReader, chainConfig *chain.Config, logger log.Logger, updateHead func(ctx context.Context)) *Hook

func (*Hook) AfterRun

func (h *Hook) AfterRun(tx kv.Tx, finishProgressBefore uint64) error

func (*Hook) BeforeRun

func (h *Hook) BeforeRun(tx kv.Tx, inSync bool) error

func (*Hook) LastNewBlockSeen

func (h *Hook) LastNewBlockSeen(n uint64)