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,
	ethClock eth_clock.EthereumClock,
	beaconCfg *clparams.BeaconChainConfig,
	state *state.CachingBeaconState,
	executionClient execution_client.ExecutionEngine,
	gossipManager *network2.GossipManager,
	forkChoice *forkchoice.ForkChoiceStore,
	indiciesDB kv.RwDB,
	sn *freezeblocks.CaplinSnapshots,
	blockReader freezeblocks.BeaconSnapshotReader,
	dirs datadir.Dirs,
	syncBackLoopLimit uint64,
	caplinConfig clparams.CaplinConfig,
	syncedData *synced_data.SyncedDataManager,
	emitters *beaconevents.EventEmitter,
	blobStore blob_storage.BlobStorage,
	attestationDataProducer attestation_producer.AttestationDataProducer,
) *Cfg

type StageHistoryReconstructionCfg

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

func StageHistoryReconstruction

func StageHistoryReconstruction(downloader *network.BackwardBeaconDownloader, antiquary *antiquary.Antiquary, sn *freezeblocks.CaplinSnapshots, indiciesDB kv.RwDB, engine execution_client.ExecutionEngine, beaconCfg *clparams.BeaconChainConfig, caplinConfig clparams.CaplinConfig, waitForAllRoutines bool, startingRoot libcommon.Hash, startinSlot uint64, tmpdir string, backfillingThrottling time.Duration, executionBlocksCollector block_collector.BlockCollector, blockReader freezeblocks.BeaconSnapshotReader, blobStorage blob_storage.BlobStorage, logger log.Logger) StageHistoryReconstructionCfg

type StageName

type StageName = string

const (
	ForwardSync              StageName = "ForwardSync"
	ChainTipSync             StageName = "ChainTipSync"
	ForkChoice               StageName = "ForkChoice"
	CleanupAndPruning        StageName = "CleanupAndPruning"
	SleepForSlot             StageName = "SleepForSlot"
	DownloadHistoricalBlocks StageName = "DownloadHistoricalBlocks"
)

func MetaCatchingUp

func MetaCatchingUp(args Args) StageName