services

package
v1.9.0 Latest Latest
Warning

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

 Go to latest Published: Jun 17, 2024 License: GPL-3.0 Imports: 38 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func StartCallRateLimiter 

func StartCallRateLimiter(proxyCount uint, rateLimit uint, burstLimit uint) error

StartFrontendCache is used to start the global frontend cache service

func StartChainService 

func StartChainService() error

StartChainService is used to start the global beaconchain service

func StartFrontendCache 

func StartFrontendCache() error

StartFrontendCache is used to start the global frontend cache service

func StartTxSignaturesService 

func StartTxSignaturesService() error

StartTxSignaturesService is used to start the global transaction signatures service

Types

type CallRateLimiter 

type CallRateLimiter struct {
	// contains filtered or unexported fields
}
var GlobalCallRateLimiter *CallRateLimiter

func (*CallRateLimiter) CheckCallLimit 

func (crl *CallRateLimiter) CheckCallLimit(r *http.Request, callCost uint) error

type ChainService 

type ChainService struct {
	// contains filtered or unexported fields
}
var GlobalBeaconService *ChainService

func (*ChainService) CheckBlockOrphanedStatus 

func (bs *ChainService) CheckBlockOrphanedStatus(blockRoot []byte) dbtypes.SlotStatus

func (*ChainService) GetBlobSidecarsByBlockRoot 

func (bs *ChainService) GetBlobSidecarsByBlockRoot(blockroot []byte) ([]*deneb.BlobSidecar, error)

func (*ChainService) GetCachedEpochStats 

func (bs *ChainService) GetCachedEpochStats(epoch uint64) *indexer.EpochStats

func (*ChainService) GetCachedValidatorPubkeyMap 

func (bs *ChainService) GetCachedValidatorPubkeyMap() map[phase0.BLSPubKey]*v1.Validator

func (*ChainService) GetCachedValidatorSet 

func (bs *ChainService) GetCachedValidatorSet() map[phase0.ValidatorIndex]*v1.Validator

func (*ChainService) GetClients 

func (bs *ChainService) GetClients() []*indexer.ConsensusClient

func (*ChainService) GetDbBlocks 

func (bs *ChainService) GetDbBlocks(firstSlot uint64, limit int32, withMissing bool, withOrphaned bool) []*dbtypes.Slot

func (*ChainService) GetDbBlocksByFilter 

func (bs *ChainService) GetDbBlocksByFilter(filter *dbtypes.BlockFilter, pageIdx uint64, pageSize uint32) []*dbtypes.AssignedSlot

func (*ChainService) GetDbBlocksByParentRoot 

func (bs *ChainService) GetDbBlocksByParentRoot(parentRoot []byte) []*dbtypes.Slot

func (*ChainService) GetDbBlocksForSlots 

func (bs *ChainService) GetDbBlocksForSlots(firstSlot uint64, slotLimit uint32, withMissing bool, withOrphaned bool) []*dbtypes.Slot

func (*ChainService) GetDbEpochs 

func (bs *ChainService) GetDbEpochs(firstEpoch uint64, limit uint32) []*dbtypes.Epoch

func (*ChainService) GetEpochAssignments 

func (bs *ChainService) GetEpochAssignments(epoch uint64) (*rpc.EpochAssignments, error)

func (*ChainService) GetFinalizedEpoch 

func (bs *ChainService) GetFinalizedEpoch() (int64, []byte)

func (*ChainService) GetGenesis 

func (bs *ChainService) GetGenesis() (*v1.Genesis, error)

func (*ChainService) GetHeadForks 

func (bs *ChainService) GetHeadForks(readyOnly bool) []*indexer.HeadFork

func (*ChainService) GetIncludedDepositsByFilter 

func (bs *ChainService) GetIncludedDepositsByFilter(filter *dbtypes.DepositFilter, pageIdx uint64, pageSize uint32) ([]*dbtypes.Deposit, uint64)

func (*ChainService) GetIndexer 

func (bs *ChainService) GetIndexer() *indexer.Indexer

func (*ChainService) GetOrphanedBlock 

func (bs *ChainService) GetOrphanedBlock(blockroot []byte) *CombinedBlockResponse

func (*ChainService) GetProposerAssignments 

func (bs *ChainService) GetProposerAssignments(firstEpoch uint64, lastEpoch uint64) (proposerAssignments map[uint64]uint64, synchronizedEpochs map[uint64]bool)

func (*ChainService) GetSlashingsByFilter 

func (bs *ChainService) GetSlashingsByFilter(filter *dbtypes.SlashingFilter, pageIdx uint64, pageSize uint32) ([]*dbtypes.Slashing, uint64)

func (*ChainService) GetSlotDetailsByBlockroot 

func (bs *ChainService) GetSlotDetailsByBlockroot(blockroot []byte) (*CombinedBlockResponse, error)

func (*ChainService) GetSlotDetailsBySlot 

func (bs *ChainService) GetSlotDetailsBySlot(slot uint64) (*CombinedBlockResponse, error)

func (*ChainService) GetValidatorActivity 

func (bs *ChainService) GetValidatorActivity() (map[uint64]uint8, uint64)

func (*ChainService) GetValidatorName 

func (bs *ChainService) GetValidatorName(index uint64) string

func (*ChainService) GetValidatorNamesCount 

func (bs *ChainService) GetValidatorNamesCount() uint64

func (*ChainService) GetVoluntaryExitsByFilter 

func (bs *ChainService) GetVoluntaryExitsByFilter(filter *dbtypes.VoluntaryExitFilter, pageIdx uint64, pageSize uint32) ([]*dbtypes.VoluntaryExit, uint64)

type CombinedBlockResponse 

type CombinedBlockResponse struct {
	Root     []byte
	Header   *phase0.SignedBeaconBlockHeader
	Block    *spec.VersionedSignedBeaconBlock
	Orphaned bool
}

type FrontendCachePageError 

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

func (FrontendCachePageError) Error 

func (e FrontendCachePageError) Error() string

func (FrontendCachePageError) Name 

func (e FrontendCachePageError) Name() string

func (FrontendCachePageError) Stack 

func (e FrontendCachePageError) Stack() string

type FrontendCacheProcessingPage 

type FrontendCacheProcessingPage struct {
	PageKey      string
	CacheTimeout time.Duration
	// contains filtered or unexported fields
}

type FrontendCacheService 

type FrontendCacheService struct {
	// contains filtered or unexported fields
}
var GlobalFrontendCache *FrontendCacheService

func (*FrontendCacheService) ProcessCachedPage 

func (fc *FrontendCacheService) ProcessCachedPage(pageKey string, caching bool, returnValue interface{}, buildFn PageDataHandlerFn) (interface{}, error)

type MevIndexer 

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

func NewMevIndexer 

func NewMevIndexer() *MevIndexer

func (*MevIndexer) StartUpdater 

func (mev *MevIndexer) StartUpdater(indexer *indexer.Indexer)

type PageDataHandlerFn 

type PageDataHandlerFn = func(pageCall *FrontendCacheProcessingPage) interface{}

type TxSignaturesLookup 

type TxSignaturesLookup struct {
	Bytes     types.TxSignatureBytes
	Signature string
	Name      string
	Status    types.TxSignatureLookupStatus
}

type TxSignaturesService 

type TxSignaturesService struct {
}
var GlobalTxSignaturesService *TxSignaturesService

func (*TxSignaturesService) LookupSignatures 

func (tss *TxSignaturesService) LookupSignatures(sigBytes []types.TxSignatureBytes) map[types.TxSignatureBytes]*TxSignaturesLookup

type ValidatorNames 

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

func NewValidatorNames 

func NewValidatorNames() *ValidatorNames

func (*ValidatorNames) GetValidatorName 

func (vn *ValidatorNames) GetValidatorName(index uint64) string

func (*ValidatorNames) GetValidatorNameByPubkey 

func (vn *ValidatorNames) GetValidatorNameByPubkey(pubkey []byte) string

func (*ValidatorNames) GetValidatorNamesCount 

func (vn *ValidatorNames) GetValidatorNamesCount() uint64

func (*ValidatorNames) LoadValidatorNames 

func (vn *ValidatorNames) LoadValidatorNames() chan bool

func (*ValidatorNames) StartUpdater 

func (vn *ValidatorNames) StartUpdater(indexer *indexer.Indexer)

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.