indexer

package
v1.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 3, 2023 License: GPL-3.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CacheBlock added in v1.3.0 

type CacheBlock struct {
	Root []byte
	Slot uint64

	Refs struct {
		ExecutionHash   []byte
		ExecutionNumber uint64
	}
	// contains filtered or unexported fields
}

func (*CacheBlock) GetBlockBody added in v1.3.0 

func (block *CacheBlock) GetBlockBody() *rpctypes.SignedBeaconBlock

func (*CacheBlock) GetHeader added in v1.3.0 

func (block *CacheBlock) GetHeader() *rpctypes.SignedBeaconBlockHeader

func (*CacheBlock) GetParentRoot added in v1.3.0 

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

func (*CacheBlock) IsCanonical added in v1.3.0 

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

func (*CacheBlock) IsReady added in v1.3.1 

func (block *CacheBlock) IsReady() bool

type EpochStats 

type EpochStats struct {
	Epoch         uint64
	DependentRoot []byte
	// contains filtered or unexported fields
}

func (*EpochStats) GetAttestorAssignments added in v1.3.0 

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

func (*EpochStats) GetDependentStateRef added in v1.3.0 

func (epochStats *EpochStats) GetDependentStateRef() string

func (*EpochStats) GetProposerAssignments added in v1.3.0 

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

func (*EpochStats) GetSyncAssignments added in v1.3.0 

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

func (*EpochStats) IsReady added in v1.4.0 

func (epochStats *EpochStats) IsReady() bool

func (*EpochStats) IsValidatorsReady added in v1.4.0 

func (epochStats *EpochStats) IsValidatorsReady() bool

type EpochValidatorStats added in v1.3.0 

type EpochValidatorStats struct {
	ValidatorCount    uint64
	ValidatorBalance  uint64
	EligibleAmount    uint64
	ValidatorBalances map[uint64]uint64
}

type EpochVotes 

type EpochVotes struct {
	VoteCounts  bool
	ActivityMap map[uint64]bool
	// contains filtered or unexported fields
}

type HeadFork added in v1.3.0 

type HeadFork struct {
	Slot         uint64
	Root         []byte
	ReadyClients []*IndexerClient
	AllClients   []*IndexerClient
}

type Indexer 

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

func NewIndexer 

func NewIndexer() (*Indexer, error)

func (*Indexer) AddClient added in v1.3.0 

func (indexer *Indexer) AddClient(index uint8, endpoint *types.EndpointConfig) *IndexerClient

func (*Indexer) BuildLiveBlock 

func (indexer *Indexer) BuildLiveBlock(block *CacheBlock) *dbtypes.Block

func (*Indexer) BuildLiveEpoch 

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

func (*Indexer) GetCachedBlock 

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

func (*Indexer) GetCachedBlockByStateroot 

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

func (*Indexer) GetCachedBlocks 

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

func (*Indexer) GetCachedBlocksByExecutionBlockHash added in v1.4.0 

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

func (*Indexer) GetCachedBlocksByExecutionBlockNumber added in v1.4.0 

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

func (*Indexer) GetCachedBlocksByParentRoot added in v1.3.0 

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

func (*Indexer) GetCachedBlocksByProposer added in v1.3.0 

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

func (*Indexer) GetCachedEpochStats 

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

func (*Indexer) GetCachedValidatorSet 

func (indexer *Indexer) GetCachedValidatorSet() *rpctypes.StandardV1StateValidatorsResponse

func (*Indexer) GetCanonicalHead added in v1.3.0 

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

func (*Indexer) GetClients added in v1.3.0 

func (indexer *Indexer) GetClients() []*IndexerClient

func (*Indexer) GetEpochVotes added in v1.1.0 

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

func (*Indexer) GetFinalizedEpoch added in v1.3.0 

func (indexer *Indexer) GetFinalizedEpoch() (int64, []byte)

func (*Indexer) GetFirstCachedCanonicalBlock added in v1.3.1 

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

func (*Indexer) GetHeadForks added in v1.3.0 

func (indexer *Indexer) GetHeadForks() []*HeadFork

func (*Indexer) GetHighestSlot added in v1.3.0 

func (indexer *Indexer) GetHighestSlot() uint64

func (*Indexer) GetReadyClient added in v1.3.1 

func (indexer *Indexer) GetReadyClient(archive bool, head []byte, skip []*IndexerClient) *IndexerClient

func (*Indexer) GetReadyClients added in v1.3.1 

func (indexer *Indexer) GetReadyClients(archive bool, head []byte) []*IndexerClient

func (*Indexer) GetRpcClient added in v1.3.0 

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

type IndexerClient added in v1.3.0 

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

func (*IndexerClient) GetIndex added in v1.3.0 

func (client *IndexerClient) GetIndex() uint8

func (*IndexerClient) GetLastHead added in v1.3.0 

func (client *IndexerClient) GetLastHead() (int64, []byte)

func (*IndexerClient) GetName added in v1.3.0 

func (client *IndexerClient) GetName() string

func (*IndexerClient) GetRpcClient added in v1.3.1 

func (client *IndexerClient) GetRpcClient() *rpc.BeaconClient

func (*IndexerClient) GetStatus added in v1.3.0 

func (client *IndexerClient) GetStatus() string

func (*IndexerClient) GetVersion added in v1.3.0 

func (client *IndexerClient) GetVersion() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.