stages

Documentation

Index

• Variables
• func ConsensusStages(ctx context.Context, historyReconstruction StageHistoryReconstructionCfg, ...) []*sync_stages.Stage
• func NewConsensusStagedSync(ctx context.Context, db kv.RwDB, ...) (*sync_stages.Sync, error)
• func SpawnStageBeaconState(cfg StageBeaconStateCfg, tx kv.RwTx, ctx context.Context) error
• func SpawnStageBeaconsBlocks(cfg StageBeaconsBlockCfg, s *sync_stages.StageState, tx kv.RwTx, ...) error
• func SpawnStageHistoryReconstruction(cfg StageHistoryReconstructionCfg, s *sync_stages.StageState, tx kv.RwTx, ...) error
• type StageBeaconStateCfg
  • func StageBeaconState(db kv.RwDB, beaconCfg *clparams.BeaconChainConfig, state *state.BeaconState, ...) StageBeaconStateCfg
• type StageBeaconsBlockCfg
  • func StageBeaconsBlock(db kv.RwDB, downloader *network.ForwardBeaconDownloader, ...) StageBeaconsBlockCfg
• type StageHistoryReconstructionCfg
  • func StageHistoryReconstruction(db kv.RwDB, downloader *network.BackwardBeaconDownloader, ...) StageHistoryReconstructionCfg

Variables

var ConsensusPruneOrder = sync_stages.PruneOrder{
	sync_stages.BeaconState,
	sync_stages.BeaconBlocks,
}

var ConsensusUnwindOrder = sync_stages.UnwindOrder{
	sync_stages.BeaconState,
	sync_stages.BeaconBlocks,
}

Functions

func ConsensusStages

func ConsensusStages(ctx context.Context, historyReconstruction StageHistoryReconstructionCfg, beaconsBlocks StageBeaconsBlockCfg, beaconState StageBeaconStateCfg) []*sync_stages.Stage

StateStages are all stages necessary for basic unwind and stage computation, it is primarly used to process side forks and memory execution.

func NewConsensusStagedSync

func NewConsensusStagedSync(ctx context.Context,
	db kv.RwDB,
	forwardDownloader *network.ForwardBeaconDownloader,
	backwardDownloader *network.BackwardBeaconDownloader,
	genesisCfg *clparams.GenesisConfig,
	beaconCfg *clparams.BeaconChainConfig,
	state *state.BeaconState,
	tmpdir string,
	executionClient *execution_client.ExecutionClient,
	beaconDBCfg *rawdb.BeaconDataConfig,
) (*sync_stages.Sync, error)

func SpawnStageBeaconState

func SpawnStageBeaconState(cfg StageBeaconStateCfg, tx kv.RwTx, ctx context.Context) error

SpawnStageBeaconForward spawn the beacon forward stage

func SpawnStageBeaconsBlocks

func SpawnStageBeaconsBlocks(cfg StageBeaconsBlockCfg, s *sync_stages.StageState, tx kv.RwTx, ctx context.Context) error

SpawnStageBeaconsForward spawn the beacon forward stage

func SpawnStageHistoryReconstruction

func SpawnStageHistoryReconstruction(cfg StageHistoryReconstructionCfg, s *sync_stages.StageState, tx kv.RwTx, ctx context.Context) error

SpawnStageBeaconsForward spawn the beacon forward stage

Types

type StageBeaconStateCfg

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

func StageBeaconState

func StageBeaconState(db kv.RwDB,
	beaconCfg *clparams.BeaconChainConfig, state *state.BeaconState, executionClient *execution_client.ExecutionClient) StageBeaconStateCfg

type StageBeaconsBlockCfg

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

func StageBeaconsBlock

func StageBeaconsBlock(db kv.RwDB, downloader *network.ForwardBeaconDownloader, genesisCfg *clparams.GenesisConfig,
	beaconCfg *clparams.BeaconChainConfig, state *state.BeaconState, executionClient *execution_client.ExecutionClient) StageBeaconsBlockCfg

type StageHistoryReconstructionCfg

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

func StageHistoryReconstruction

func StageHistoryReconstruction(db kv.RwDB, downloader *network.BackwardBeaconDownloader, genesisCfg *clparams.GenesisConfig, beaconCfg *clparams.BeaconChainConfig, beaconDBCfg *rawdb.BeaconDataConfig, state *state.BeaconState, tmpdir string, executionClient *execution_client.ExecutionClient) StageHistoryReconstructionCfg