Versions in this module Expand all Collapse all v2 v2.0.1 Oct 5, 2021 Changes in this version + type ChainService struct + Balance *precompute.Balance + Block block.SignedBeaconBlock + BlocksReceived []block.SignedBeaconBlock + CanonicalRoots map[[32]byte]bool + CurrentJustifiedCheckPoint *ethpb.Checkpoint + DB db.Database + ETH1Data *ethpb.Eth1Data + FinalizedCheckPoint *ethpb.Checkpoint + Fork *ethpb.Fork + ForkChoiceStore *protoarray.Store + Genesis time.Time + InitSyncBlockRoots map[[32]byte]bool + PreviousJustifiedCheckPoint *ethpb.Checkpoint + PublicKey [48]byte + Root []byte + Slot *types.Slot + State state.BeaconState + SyncCommitteeDomain []byte + SyncCommitteeIndices []types.CommitteeIndex + SyncCommitteePubkeys [][]byte + SyncContributionProofDomain []byte + SyncSelectionProofDomain []byte + ValidAttestation bool + ValidatorsRoot [32]byte + VerifyBlkDescendantErr error + func (s *ChainService) AttestationTargetState(_ context.Context, _ *ethpb.Checkpoint) (state.BeaconState, error) + func (s *ChainService) BlockNotifier() blockfeed.Notifier + func (s *ChainService) ChainHeads() ([][32]byte, []types.Slot) + func (s *ChainService) CurrentFork() *ethpb.Fork + func (s *ChainService) CurrentJustifiedCheckpt() *ethpb.Checkpoint + func (s *ChainService) CurrentSlot() types.Slot + func (s *ChainService) FinalizedCheckpt() *ethpb.Checkpoint + func (s *ChainService) GenesisTime() time.Time + func (s *ChainService) GenesisValidatorRoot() [32]byte + func (s *ChainService) HasInitSyncBlock(rt [32]byte) bool + func (s *ChainService) HeadBlock(context.Context) (block.SignedBeaconBlock, error) + func (s *ChainService) HeadETH1Data() *ethpb.Eth1Data + func (s *ChainService) HeadGenesisValidatorRoot() [32]byte + func (s *ChainService) HeadPublicKeyToValidatorIndex(_ context.Context, _ [48]byte) (types.ValidatorIndex, bool) + func (s *ChainService) HeadRoot(_ context.Context) ([]byte, error) + func (s *ChainService) HeadSeed(_ context.Context, epoch types.Epoch) ([32]byte, error) + func (s *ChainService) HeadSlot() types.Slot + func (s *ChainService) HeadState(context.Context) (state.BeaconState, error) + func (s *ChainService) HeadSyncCommitteeDomain(_ context.Context, _ types.Slot) ([]byte, error) + func (s *ChainService) HeadSyncCommitteeIndices(_ context.Context, index types.ValidatorIndex, slot types.Slot) ([]types.CommitteeIndex, error) + func (s *ChainService) HeadSyncCommitteePubKeys(_ context.Context, _ types.Slot, _ types.CommitteeIndex) ([][]byte, error) + func (s *ChainService) HeadSyncContributionProofDomain(_ context.Context, _ types.Slot) ([]byte, error) + func (s *ChainService) HeadSyncSelectionProofDomain(_ context.Context, _ types.Slot) ([]byte, error) + func (s *ChainService) HeadValidatorIndexToPublicKey(_ context.Context, _ types.ValidatorIndex) ([48]byte, error) + func (s *ChainService) HeadValidatorsIndices(ctx context.Context, epoch types.Epoch) ([]types.ValidatorIndex, error) + func (s *ChainService) IsCanonical(_ context.Context, r [32]byte) (bool, error) + func (s *ChainService) IsValidAttestation(_ context.Context, _ *ethpb.Attestation) bool + func (s *ChainService) OperationNotifier() opfeed.Notifier + func (s *ChainService) Participation(_ uint64) *precompute.Balance + func (s *ChainService) PreviousJustifiedCheckpt() *ethpb.Checkpoint + func (s *ChainService) ProtoArrayStore() *protoarray.Store + func (s *ChainService) ReceiveAttestation(_ context.Context, _ *ethpb.Attestation) error + func (s *ChainService) ReceiveAttestationNoPubsub(context.Context, *ethpb.Attestation) error + func (s *ChainService) ReceiveBlock(ctx context.Context, block block.SignedBeaconBlock, _ [32]byte) error + func (s *ChainService) ReceiveBlockBatch(ctx context.Context, blks []block.SignedBeaconBlock, _ [][32]byte) error + func (s *ChainService) ReceiveBlockInitialSync(ctx context.Context, block block.SignedBeaconBlock, _ [32]byte) error + func (s *ChainService) StateNotifier() statefeed.Notifier + func (s *ChainService) VerifyBlkDescendant(_ context.Context, _ [32]byte) error + func (s *ChainService) VerifyFinalizedConsistency(_ context.Context, r []byte) error + func (s *ChainService) VerifyLmdFfgConsistency(_ context.Context, a *ethpb.Attestation) error + type MockBlockNotifier struct + func (mbn *MockBlockNotifier) BlockFeed() *event.Feed + type MockOperationNotifier struct + func (mon *MockOperationNotifier) OperationFeed() *event.Feed + type MockStateNotifier struct + RecordEvents bool + func (msn *MockStateNotifier) ReceivedEvents() []*feed.Event + func (msn *MockStateNotifier) StateFeed() *event.Feed Other modules containing this package github.com/prysmaticlabs/prysm github.com/prysmaticlabs/prysm/v3 github.com/prysmaticlabs/prysm/v4 github.com/prysmaticlabs/prysm/v5