beacon

package

Go to main page

Versions in this module

v1

v1.13.1

Dec 17, 2024

v1.13.0

Dec 6, 2024

Changes in this version

+ type CacheDebugMapSize struct

+ Length int

+ Size int64

+ type CacheDebugStats struct

+ BlockCache struct{ ... }

+ EpochCache struct{ ... }

+ ForkCache struct{ ... }

+ ValidatorCache struct{ ... }

+ type EpochVoteActivity struct

+ ActiveIndices []phase0.ValidatorIndex

+ ActivityBitfield bitfield.Bitfield

+ Epoch phase0.Epoch

type Indexer

+ func (indexer *Indexer) GetActivityHistoryLength() uint16

+ func (indexer *Indexer) GetCacheDebugStats() *CacheDebugStats

+ func (indexer *Indexer) GetEpochValidator(validatorIndex phase0.ValidatorIndex, epoch phase0.Epoch, ...) *v1.Validator

+ func (indexer *Indexer) GetEpochValidatorSet(epoch phase0.Epoch, overrideForkId *ForkKey, withBalances bool) []*v1.Validator

+ func (indexer *Indexer) GetValidatorActivity(validatorIndex phase0.ValidatorIndex) ([]ValidatorActivity, phase0.Epoch)

+ func (indexer *Indexer) GetValidatorByIndex(index phase0.ValidatorIndex, overrideForkId *ForkKey) *phase0.Validator

+ func (indexer *Indexer) GetValidatorIndexByPubkey(pubkey phase0.BLSPubKey) (phase0.ValidatorIndex, bool)

+ func (indexer *Indexer) GetValidatorSet(overrideForkId *ForkKey) []*phase0.Validator

+ type ValidatorActivity struct

+ VoteBlock *Block

+ VoteDelay uint16

v1.12.1

Nov 25, 2024

Changes in this version

type EpochStats

+ func (es *EpochStats) GetDependentRoot() phase0.Root

type Indexer

+ func (indexer *Indexer) GetParentForkIds(forkId ForkKey) []ForkKey

+ func (indexer *Indexer) GetSynchronizerState() (running bool, syncHead phase0.Epoch)

v1.12.0

Sep 18, 2024

Changes in this version

type Block

+ func (block *Block) GetDbWithdrawalRequests(indexer *Indexer) []*dbtypes.WithdrawalRequest

v1.11.3

Sep 11, 2024

v1.11.2

Sep 9, 2024

Changes in this version

type ChainHead

+ PerEpochVotingPercent []float64

v1.11.1

Aug 26, 2024

v1.11.0

Aug 19, 2024

Changes in this version

+ const EtherGweiFactor

+ const FarFutureEpoch

+ func LoadBeaconBlock(ctx context.Context, client *Client, root phase0.Root) (*spec.VersionedSignedBeaconBlock, error)

+ func LoadBeaconHeader(ctx context.Context, client *Client, root phase0.Root) (*phase0.SignedBeaconBlockHeader, error)

+ func LoadBeaconHeaderBySlot(ctx context.Context, client *Client, slot phase0.Slot) (*phase0.SignedBeaconBlockHeader, phase0.Root, bool, error)

+ func LoadBeaconState(ctx context.Context, client *Client, root phase0.Root) (*spec.VersionedBeaconState, error)

+ type Block struct

+ Root phase0.Root

+ Slot phase0.Slot

+ func (block *Block) AwaitBlock(ctx context.Context, timeout time.Duration) *spec.VersionedSignedBeaconBlock

+ func (block *Block) AwaitHeader(ctx context.Context, timeout time.Duration) *phase0.SignedBeaconBlockHeader

+ func (block *Block) EnsureBlock(loadBlock func() (*spec.VersionedSignedBeaconBlock, error)) (bool, error)

+ func (block *Block) EnsureHeader(loadHeader func() (*phase0.SignedBeaconBlockHeader, error)) error

+ func (block *Block) GetBlock() *spec.VersionedSignedBeaconBlock

+ func (block *Block) GetBlockIndex() *BlockBodyIndex

+ func (block *Block) GetDbBlock(indexer *Indexer) *dbtypes.Slot

+ func (block *Block) GetDbConsolidationRequests(indexer *Indexer) []*dbtypes.ConsolidationRequest

+ func (block *Block) GetDbDeposits(indexer *Indexer, depositIndex *uint64) []*dbtypes.Deposit

+ func (block *Block) GetDbSlashings(indexer *Indexer) []*dbtypes.Slashing

+ func (block *Block) GetDbVoluntaryExits(indexer *Indexer) []*dbtypes.VoluntaryExit

+ func (block *Block) GetExecutionExtraData() []byte

+ func (block *Block) GetForkId() ForkKey

+ func (block *Block) GetHeader() *phase0.SignedBeaconBlockHeader

+ func (block *Block) GetParentRoot() *phase0.Root

+ func (block *Block) GetSeenBy() []*Client

+ func (block *Block) SetBlock(body *spec.VersionedSignedBeaconBlock)

+ func (block *Block) SetHeader(header *phase0.SignedBeaconBlockHeader)

+ func (block *Block) SetSeenBy(client *Client)

+ type BlockBodyIndex struct

+ ExecutionExtraData []byte

+ ExecutionHash phase0.Hash32

+ ExecutionNumber uint64

+ Graffiti [32]byte

+ type ChainHead struct

+ AggregatedHeadVotes phase0.Gwei

+ HeadBlock *Block

+ LastEpochVotingPercent float64

+ ThisEpochVotingPercent float64

+ type Client struct

+ func (c *Client) GetClient() *consensus.Client

+ func (c *Client) GetIndex() uint16

+ func (c *Client) GetPriority() int

+ type EpochStats struct

+ func (es *EpochStats) GetDbEpoch(indexer *Indexer, headBlock *Block) *dbtypes.Epoch

+ func (es *EpochStats) GetEpoch() phase0.Epoch

+ func (es *EpochStats) GetEpochVotes(indexer *Indexer, headBlock *Block) *EpochVotes

+ func (es *EpochStats) GetOrLoadValues(indexer *Indexer, withPrecalc bool, keepInCache bool) *EpochStatsValues

+ func (es *EpochStats) GetValues(withPrecalc bool) *EpochStatsValues

+ type EpochStatsPacked struct

+ ActiveBalance phase0.Gwei

+ ActiveValidators []EpochStatsPackedValidator

+ FirstDepositIndex uint64

+ NextRandaoMix phase0.Hash32

+ RandaoMix phase0.Hash32

+ SyncCommitteeDuties []phase0.ValidatorIndex

+ TotalBalance phase0.Gwei

+ type EpochStatsPackedValidator struct

+ EffectiveBalanceEth uint16

+ ValidatorIndexOffset uint32

+ type EpochStatsValues struct

+ ActiveBalance phase0.Gwei

+ ActiveIndices []phase0.ValidatorIndex

+ ActiveValidators uint64

+ AttesterDuties [][][]duties.ActiveIndiceIndex

+ EffectiveBalance phase0.Gwei

+ EffectiveBalances []uint16

+ FirstDepositIndex uint64

+ NextRandaoMix phase0.Hash32

+ ProposerDuties []phase0.ValidatorIndex

+ RandaoMix phase0.Hash32

+ SyncCommitteeDuties []phase0.ValidatorIndex

+ TotalBalance phase0.Gwei

+ func (v *EpochStatsValues) GetEffectiveBalance(index duties.ActiveIndiceIndex) phase0.Gwei

+ type EpochVotes struct

+ ActivityBitfield bitfield.Bitfield

+ AmountIsCount bool

+ CurrentEpoch struct{ ... }

+ HeadVotePercent float64

+ NextEpoch struct{ ... }

+ TargetVotePercent float64

+ TotalVotePercent float64

+ type Fork struct

+ func (fork *Fork) GetBase() (phase0.Slot, phase0.Root)

+ func (fork *Fork) GetLeaf() (phase0.Slot, phase0.Root)

+ func (fork *Fork) GetParent() ForkKey

+ type ForkHead struct

+ Block *Block

+ Fork *Fork

+ ForkId ForkKey

+ type ForkKey uint64

+ type Indexer struct

+ func NewIndexer(logger logrus.FieldLogger, consensusPool *consensus.Pool) *Indexer

+ func (indexer *Indexer) AddClient(index uint16, client *consensus.Client, priority int, archive bool, ...) *Client

+ func (indexer *Indexer) GetAllClients() []*Client

+ func (indexer *Indexer) GetBlockByParentRoot(blockRoot phase0.Root) []*Block

+ func (indexer *Indexer) GetBlockByRoot(blockRoot phase0.Root) *Block

+ func (indexer *Indexer) GetBlockByStateRoot(stateRoot phase0.Root) *Block

+ func (indexer *Indexer) GetBlockCacheState() (finalizedEpoch phase0.Epoch, prunedEpoch phase0.Epoch)

+ func (indexer *Indexer) GetBlockDistance(baseRoot phase0.Root, headRoot phase0.Root) (bool, uint64)

+ func (indexer *Indexer) GetBlocksByExecutionBlockHash(blockHash phase0.Hash32) []*Block

+ func (indexer *Indexer) GetBlocksByExecutionBlockNumber(blockNumber uint64) []*Block

+ func (indexer *Indexer) GetBlocksBySlot(slot phase0.Slot) []*Block

+ func (indexer *Indexer) GetCanonicalHead(overrideForkId *ForkKey) *Block

+ func (indexer *Indexer) GetCanonicalValidatorSet(overrideForkId *ForkKey) []*v1.Validator

+ func (indexer *Indexer) GetChainHeads() []*ChainHead

+ func (indexer *Indexer) GetEpochStats(epoch phase0.Epoch, overrideForkId *ForkKey) *EpochStats

+ func (indexer *Indexer) GetForkHeads() []*ForkHead

+ func (indexer *Indexer) GetOrphanedBlockByRoot(blockRoot phase0.Root) (*Block, error)

+ func (indexer *Indexer) GetReadyClient(preferArchive bool) *Client

+ func (indexer *Indexer) GetReadyClientByBlockRoot(blockRoot phase0.Root, preferArchive bool) *Client

+ func (indexer *Indexer) GetReadyClients(preferArchive bool) []*Client

+ func (indexer *Indexer) GetReadyClientsByBlockRoot(blockRoot phase0.Root, preferArchive bool) []*Client

+ func (indexer *Indexer) GetReadyClientsByCheckpoint(finalizedRoot phase0.Root, preferArchive bool) []*Client

+ func (indexer *Indexer) IsCanonicalBlock(block *Block, overrideForkId *ForkKey) bool

+ func (indexer *Indexer) StartIndexer()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL