Versions in this module Expand all Collapse all v2 v2.0.1 Oct 5, 2021 Changes in this version + type AttestationReceiver interface + ReceiveAttestationNoPubsub func(ctx context.Context, att *ethpb.Attestation) error + VerifyFinalizedConsistency func(ctx context.Context, root []byte) error + VerifyLmdFfgConsistency func(ctx context.Context, att *ethpb.Attestation) error + type AttestationStateFetcher interface + AttestationTargetState func(ctx context.Context, target *ethpb.Checkpoint) (state.BeaconState, error) + type BlockReceiver interface + HasInitSyncBlock func(root [32]byte) bool + ReceiveBlock func(ctx context.Context, block block.SignedBeaconBlock, blockRoot [32]byte) error + ReceiveBlockBatch func(ctx context.Context, blocks []block.SignedBeaconBlock, blkRoots [][32]byte) error + type CanonicalFetcher interface + IsCanonical func(ctx context.Context, blockRoot [32]byte) (bool, error) + VerifyBlkDescendant func(ctx context.Context, blockRoot [32]byte) error + type ChainInfoFetcher interface + type Config struct + AttPool attestations.Pool + AttService *attestations.Service + BeaconBlockBuf int + BeaconDB db.HeadAccessDatabase + ChainStartFetcher powchain.ChainStartFetcher + DepositCache *depositcache.DepositCache + ExitPool voluntaryexits.PoolManager + ForkChoiceStore f.ForkChoicer + MaxRoutines int + P2p p2p.Broadcaster + SlasherAttestationsFeed *event.Feed + SlashingPool slashings.PoolManager + StateGen *stategen.State + StateNotifier statefeed.Notifier + WeakSubjectivityCheckpt *ethpb.Checkpoint + type FinalizationFetcher interface + CurrentJustifiedCheckpt func() *ethpb.Checkpoint + FinalizedCheckpt func() *ethpb.Checkpoint + PreviousJustifiedCheckpt func() *ethpb.Checkpoint + type ForkFetcher interface + CurrentFork func() *ethpb.Fork + type GenesisFetcher interface + GenesisValidatorRoot func() [32]byte + type HeadDomainFetcher interface + HeadSyncCommitteeDomain func(ctx context.Context, slot types.Slot) ([]byte, error) + HeadSyncContributionProofDomain func(ctx context.Context, slot types.Slot) ([]byte, error) + HeadSyncSelectionProofDomain func(ctx context.Context, slot types.Slot) ([]byte, error) + type HeadFetcher interface + ChainHeads func() ([][32]byte, []types.Slot) + HeadBlock func(ctx context.Context) (block.SignedBeaconBlock, error) + HeadETH1Data func() *ethpb.Eth1Data + HeadGenesisValidatorRoot func() [32]byte + HeadPublicKeyToValidatorIndex func(ctx context.Context, pubKey [48]byte) (types.ValidatorIndex, bool) + HeadRoot func(ctx context.Context) ([]byte, error) + HeadSeed func(ctx context.Context, epoch types.Epoch) ([32]byte, error) + HeadSlot func() types.Slot + HeadState func(ctx context.Context) (state.BeaconState, error) + HeadValidatorIndexToPublicKey func(ctx context.Context, index types.ValidatorIndex) ([48]byte, error) + HeadValidatorsIndices func(ctx context.Context, epoch types.Epoch) ([]types.ValidatorIndex, error) + ProtoArrayStore func() *protoarray.Store + type HeadSyncCommitteeFetcher interface + HeadSyncCommitteeIndices func(ctx context.Context, index types.ValidatorIndex, slot types.Slot) ([]types.CommitteeIndex, error) + HeadSyncCommitteePubKeys func(ctx context.Context, slot types.Slot, committeeIndex types.CommitteeIndex) ([][]byte, error) + type Service struct + func NewService(ctx context.Context, cfg *Config) (*Service, error) + func (s *Service) AttestationTargetState(ctx context.Context, target *ethpb.Checkpoint) (state.BeaconState, error) + func (s *Service) ChainHeads() ([][32]byte, []types.Slot) + func (s *Service) CurrentFork() *ethpb.Fork + func (s *Service) CurrentJustifiedCheckpt() *ethpb.Checkpoint + func (s *Service) CurrentSlot() types.Slot + func (s *Service) FinalizedCheckpt() *ethpb.Checkpoint + func (s *Service) GenesisTime() time.Time + func (s *Service) GenesisValidatorRoot() [32]byte + func (s *Service) HasInitSyncBlock(root [32]byte) bool + func (s *Service) HeadBlock(ctx context.Context) (block.SignedBeaconBlock, error) + func (s *Service) HeadETH1Data() *ethpb.Eth1Data + func (s *Service) HeadGenesisValidatorRoot() [32]byte + func (s *Service) HeadPublicKeyToValidatorIndex(ctx context.Context, pubKey [48]byte) (types.ValidatorIndex, bool) + func (s *Service) HeadRoot(ctx context.Context) ([]byte, error) + func (s *Service) HeadSeed(ctx context.Context, epoch types.Epoch) ([32]byte, error) + func (s *Service) HeadSlot() types.Slot + func (s *Service) HeadState(ctx context.Context) (state.BeaconState, error) + func (s *Service) HeadSyncCommitteeDomain(ctx context.Context, slot types.Slot) ([]byte, error) + func (s *Service) HeadSyncCommitteeIndices(ctx context.Context, index types.ValidatorIndex, slot types.Slot) ([]types.CommitteeIndex, error) + func (s *Service) HeadSyncCommitteePubKeys(ctx context.Context, slot types.Slot, committeeIndex types.CommitteeIndex) ([][]byte, error) + func (s *Service) HeadSyncContributionProofDomain(ctx context.Context, slot types.Slot) ([]byte, error) + func (s *Service) HeadSyncSelectionProofDomain(ctx context.Context, slot types.Slot) ([]byte, error) + func (s *Service) HeadValidatorIndexToPublicKey(_ context.Context, index types.ValidatorIndex) ([48]byte, error) + func (s *Service) HeadValidatorsIndices(ctx context.Context, epoch types.Epoch) ([]types.ValidatorIndex, error) + func (s *Service) IsCanonical(ctx context.Context, blockRoot [32]byte) (bool, error) + func (s *Service) PreviousJustifiedCheckpt() *ethpb.Checkpoint + func (s *Service) ProtoArrayStore() *protoarray.Store + func (s *Service) ReceiveAttestationNoPubsub(ctx context.Context, att *ethpb.Attestation) error + func (s *Service) ReceiveBlock(ctx context.Context, block block.SignedBeaconBlock, blockRoot [32]byte) error + func (s *Service) ReceiveBlockBatch(ctx context.Context, blocks []block.SignedBeaconBlock, blkRoots [][32]byte) error + func (s *Service) Start() + func (s *Service) Status() error + func (s *Service) Stop() error + func (s *Service) TreeHandler(w http.ResponseWriter, r *http.Request) + func (s *Service) VerifyBlkDescendant(ctx context.Context, root [32]byte) error + func (s *Service) VerifyFinalizedConsistency(ctx context.Context, root []byte) error + func (s *Service) VerifyLmdFfgConsistency(ctx context.Context, a *ethpb.Attestation) error + func (s *Service) VerifyWeakSubjectivityRoot(ctx context.Context) error + type TimeFetcher interface + CurrentSlot func() types.Slot + GenesisTime func() time.Time Other modules containing this package github.com/prysmaticlabs/prysm github.com/prysmaticlabs/prysm/v3 github.com/prysmaticlabs/prysm/v4 github.com/prysmaticlabs/prysm/v5
Go to main page