stages

Documentation

Index

• func ConsensusClStages(ctx context.Context, cfg *Cfg) *clstages.StageGraph[*Cfg, Args]
• func SpawnStageHistoryDownload(cfg StageHistoryReconstructionCfg, ctx context.Context, logger log.Logger) error
• type Args
• type Cfg
  • func ClStagesCfg(rpc *rpc.BeaconRpcP2P, antiquary *antiquary.Antiquary, ...) *Cfg
• type StageHistoryReconstructionCfg
  • func StageHistoryReconstruction(downloader *network.BackwardBeaconDownloader, antiquary *antiquary.Antiquary, ...) StageHistoryReconstructionCfg
• type StageName
  • func MetaCatchingUp(args Args) StageName

Functions

func ConsensusClStages

func ConsensusClStages(ctx context.Context,
	cfg *Cfg,
) *clstages.StageGraph[*Cfg, Args]

ConsensusClStages creates a stage loop container to be used to run caplin

func SpawnStageHistoryDownload

func SpawnStageHistoryDownload(cfg StageHistoryReconstructionCfg, ctx context.Context, logger log.Logger) error

SpawnStageBeaconsForward spawn the beacon forward stage

Types

type Args

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

type Cfg

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

func ClStagesCfg

func ClStagesCfg(
	rpc *rpc.BeaconRpcP2P,
	antiquary *antiquary.Antiquary,
	genesisCfg *clparams.GenesisConfig,
	beaconCfg *clparams.BeaconChainConfig,
	state *state.CachingBeaconState,
	executionClient execution_client.ExecutionEngine,
	gossipManager *network2.GossipManager,
	forkChoice *forkchoice.ForkChoiceStore,
	beaconDB persistence.BeaconChainDatabase,
	indiciesDB kv.RwDB,
	sn *freezeblocks.CaplinSnapshots,
	tmpdir string,
	dbConfig db_config.DatabaseConfiguration,
	backfilling bool,
	syncedData *synced_data.SyncedDataManager,
) *Cfg

type StageHistoryReconstructionCfg

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

func StageHistoryReconstruction

func StageHistoryReconstruction(downloader *network.BackwardBeaconDownloader, antiquary *antiquary.Antiquary, sn *freezeblocks.CaplinSnapshots, db persistence.BeaconChainDatabase, indiciesDB kv.RwDB, engine execution_client.ExecutionEngine, genesisCfg *clparams.GenesisConfig, beaconCfg *clparams.BeaconChainConfig, backfilling, waitForAllRoutines bool, startingRoot libcommon.Hash, startinSlot uint64, tmpdir string, logger log.Logger) StageHistoryReconstructionCfg

type StageName

type StageName = string

const (
	WaitForPeers             StageName = "WaitForPeers"
	CatchUpEpochs            StageName = "CatchUpEpochs"
	CatchUpBlocks            StageName = "CatchUpBlocks"
	ForkChoice               StageName = "ForkChoice"
	ListenForForks           StageName = "ListenForForks"
	CleanupAndPruning        StageName = "CleanupAndPruning"
	SleepForSlot             StageName = "SleepForSlot"
	DownloadHistoricalBlocks StageName = "DownloadHistoricalBlocks"
)

func MetaCatchingUp

func MetaCatchingUp(args Args) StageName