indexer/

Versions in this module

v1

v1.13.1

Dec 17, 2024

v1.13.0

Dec 6, 2024

v1.12.1

Nov 25, 2024

v1.12.0

Sep 18, 2024

v1.11.3

Sep 11, 2024

v1.11.2

Sep 9, 2024

v1.11.1

Aug 26, 2024

v1.11.0

Aug 19, 2024

v1.10.1

Aug 15, 2024

v1.10.0

Aug 12, 2024

Changes in this version

type ConsensusClient

+ func (client *ConsensusClient) GetNodePeers() []*v1.Peer

+ func (client *ConsensusClient) GetPeerID() string

type ExecutionClient

+ func (client *ExecutionClient) DidFetchPeers() bool

+ func (client *ExecutionClient) GetNodeInfo() *p2p.NodeInfo

+ func (client *ExecutionClient) GetNodePeers() []*p2p.PeerInfo

v1.9.0

Jun 17, 2024

Changes in this version

+ func BuildDbDeposits(block *CacheBlock, depositIndex *uint64) []*dbtypes.Deposit

+ func BuildDbSlashings(block *CacheBlock) []*dbtypes.Slashing

+ func BuildDbVoluntaryExits(block *CacheBlock) []*dbtypes.VoluntaryExit

+ func GetExecutionExtraData(v *spec.VersionedSignedBeaconBlock) ([]byte, error)

+ func MarshalVersionedSignedBeaconBlockSSZ(block *spec.VersionedSignedBeaconBlock) (version uint64, ssz []byte, err error)

+ func UnmarshalVersionedSignedBeaconBlockSSZ(version uint64, ssz []byte) (*spec.VersionedSignedBeaconBlock, error)

+ type BlobAssignment struct

+ Blob *deneb.BlobSidecar

+ Root []byte

+ Slot uint64

+ type BlobStore struct

+ func (store *BlobStore) LoadBlob(commitment []byte, blockroot []byte, client *ConsensusClient) (*dbtypes.Blob, error)

+ type CacheBlock struct

+ Refs struct{ ... }

+ Root []byte

+ Slot uint64

+ func (block *CacheBlock) GetBlockBody() *spec.VersionedSignedBeaconBlock

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

+ func (block *CacheBlock) GetParentRoot() []byte

+ func (block *CacheBlock) IsCanonical(indexer *Indexer, head []byte) bool

+ func (block *CacheBlock) IsReady() bool

+ type ConsensusClient struct

+ func (client *ConsensusClient) GetIndex() uint16

+ func (client *ConsensusClient) GetLastClientError() string

+ func (client *ConsensusClient) GetLastHead() (int64, []byte, time.Time)

+ func (client *ConsensusClient) GetName() string

+ func (client *ConsensusClient) GetRpcClient() *rpc.BeaconClient

+ func (client *ConsensusClient) GetStatus() string

+ func (client *ConsensusClient) GetVersion() string

+ type DepositIndexer struct

+ type EpochStateStats struct

+ DepositIndex uint64

+ EligibleAmount uint64

+ ValidatorBalance uint64

+ ValidatorBalances map[uint64]uint64

+ ValidatorCount uint64

+ type EpochStats struct

+ DependentRoot []byte

+ Epoch uint64

+ func (epochStats *EpochStats) GetAttestorAssignments() map[string][]uint64

+ func (epochStats *EpochStats) GetDependentStateRef() string

+ func (epochStats *EpochStats) GetInitialDepositIndex() *uint64

+ func (epochStats *EpochStats) GetProposerAssignments() map[uint64]uint64

+ func (epochStats *EpochStats) GetSyncAssignments() []uint64

+ func (epochStats *EpochStats) IsReady() bool

+ func (epochStats *EpochStats) IsStateStatsReady() bool

+ func (epochStats *EpochStats) TryGetProposerAssignments() map[uint64]uint64

+ func (epochStats *EpochStats) TryGetSyncAssignments() []uint64

+ type EpochVotes struct

+ ActivityMap map[uint64]bool

+ VoteCounts bool

+ type ExecutionClient struct

+ func (client *ExecutionClient) GetIndex() uint16

+ func (client *ExecutionClient) GetLastClientError() string

+ func (client *ExecutionClient) GetLastHead() (int64, []byte, time.Time)

+ func (client *ExecutionClient) GetName() string

+ func (client *ExecutionClient) GetRpcClient() *rpc.ExecutionClient

+ func (client *ExecutionClient) GetStatus() string

+ func (client *ExecutionClient) GetVersion() string

+ type HeadFork struct

+ AllClients []*ConsensusClient

+ ReadyClients []*ConsensusClient

+ Root []byte

+ Slot uint64

+ type Indexer struct

+ BlobStore *BlobStore

+ func NewIndexer() (*Indexer, error)

+ func (indexer *Indexer) AddConsensusClient(index uint16, endpoint *types.EndpointConfig) *ConsensusClient

+ func (indexer *Indexer) AddExecutionClient(index uint16, endpoint *types.EndpointConfig) *ExecutionClient

+ func (indexer *Indexer) BuildLiveBlock(block *CacheBlock) *dbtypes.Slot

+ func (indexer *Indexer) BuildLiveEpoch(epoch uint64) *dbtypes.Epoch

+ func (indexer *Indexer) GetCacheState() (highestSlot int64, finalizedEpoch int64, persistedEpoch int64, ...)

+ func (indexer *Indexer) GetCachedBlock(root []byte) *CacheBlock

+ func (indexer *Indexer) GetCachedBlockByStateroot(stateroot []byte) *CacheBlock

+ func (indexer *Indexer) GetCachedBlocks(slot uint64) []*CacheBlock

+ func (indexer *Indexer) GetCachedBlocksByExecutionBlockHash(hash []byte) []*CacheBlock

+ func (indexer *Indexer) GetCachedBlocksByExecutionBlockNumber(number uint64) []*CacheBlock

+ func (indexer *Indexer) GetCachedBlocksByParentRoot(parentRoot []byte) []*CacheBlock

+ func (indexer *Indexer) GetCachedBlocksByProposer(proposer uint64) []*CacheBlock

+ func (indexer *Indexer) GetCachedEpochStats(epoch uint64) *EpochStats

+ func (indexer *Indexer) GetCachedGenesis() *v1.Genesis

+ func (indexer *Indexer) GetCachedValidatorPubkeyMap() map[phase0.BLSPubKey]*v1.Validator

+ func (indexer *Indexer) GetCachedValidatorSet() map[phase0.ValidatorIndex]*v1.Validator

+ func (indexer *Indexer) GetCanonicalHead() (uint64, []byte)

+ func (indexer *Indexer) GetConsensusClients() []*ConsensusClient

+ func (indexer *Indexer) GetConsensusRpc(archive bool, head []byte) *rpc.BeaconClient

+ func (indexer *Indexer) GetEpochVotes(epoch uint64) (*EpochStats, *EpochVotes)

+ func (indexer *Indexer) GetExecutionClients() []*ExecutionClient

+ func (indexer *Indexer) GetFinalizationCheckpoints() (int64, []byte, int64, []byte)

+ func (indexer *Indexer) GetFinalizedElBlockNumber() uint64

+ func (indexer *Indexer) GetFirstCachedCanonicalBlock(epoch uint64, head []byte) *CacheBlock

+ func (indexer *Indexer) GetHeadForks(readyOnly bool) []*HeadFork

+ func (indexer *Indexer) GetHighestElBlockNumber(head []byte) uint64

+ func (indexer *Indexer) GetHighestSlot() uint64

+ func (indexer *Indexer) GetReadyClClient(archive bool, head []byte, skip []*ConsensusClient) *ConsensusClient

+ func (indexer *Indexer) GetReadyElClient(archive bool, head []byte, skip []*ExecutionClient) *ExecutionClient

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