services

package
v1.8.4 Latest Latest
Warning

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

 Go to latest Published: Feb 25, 2024 License: GPL-3.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func StartBeaconService 

func StartBeaconService() error

StartBeaconService is used to start the global beaconchain service

func StartCallRateLimiter added in v1.7.0 

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

StartFrontendCache is used to start the global frontend cache service

func StartFrontendCache 

func StartFrontendCache() error

StartFrontendCache is used to start the global frontend cache service

func StartTxSignaturesService added in v1.8.0 

func StartTxSignaturesService() error

StartTxSignaturesService is used to start the global transaction signatures service

Types

type BeaconService 

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

func (*BeaconService) CheckBlockOrphanedStatus 

func (bs *BeaconService) CheckBlockOrphanedStatus(blockRoot []byte) bool

func (*BeaconService) GetBlobSidecarsByBlockRoot 

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

func (*BeaconService) GetCachedEpochStats 

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

func (*BeaconService) GetCachedValidatorSet 

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

func (*BeaconService) GetClients 

func (bs *BeaconService) GetClients() []*indexer.IndexerClient

func (*BeaconService) GetDbBlocks 

func (bs *BeaconService) GetDbBlocks(firstSlot uint64, limit int32, withOrphaned bool) []*dbtypes.Block

func (*BeaconService) GetDbBlocksByFilter 

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

func (*BeaconService) GetDbBlocksByParentRoot 

func (bs *BeaconService) GetDbBlocksByParentRoot(parentRoot []byte) []*dbtypes.Block

func (*BeaconService) GetDbBlocksForSlots 

func (bs *BeaconService) GetDbBlocksForSlots(firstSlot uint64, slotLimit uint32, withOrphaned bool) []*dbtypes.Block

func (*BeaconService) GetDbEpochs 

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

func (*BeaconService) GetEpochAssignments 

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

func (*BeaconService) GetFinalizedEpoch 

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

func (*BeaconService) GetGenesis 

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

func (*BeaconService) GetHeadForks added in v1.7.0 

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

func (*BeaconService) GetIndexer 

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

func (*BeaconService) GetOrphanedBlock 

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

func (*BeaconService) GetProposerAssignments 

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

func (*BeaconService) GetSlotDetailsByBlockroot 

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

func (*BeaconService) GetSlotDetailsBySlot 

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

func (*BeaconService) GetValidatorActivity 

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

func (*BeaconService) GetValidatorName 

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

func (*BeaconService) GetValidatorNamesCount added in v1.8.4 

func (bs *BeaconService) GetValidatorNamesCount() uint64

type CallRateLimiter added in v1.7.0 

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

func (*CallRateLimiter) CheckCallLimit added in v1.7.0 

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

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 PageDataHandlerFn 

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

type TxSignaturesLookup added in v1.8.0 

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

type TxSignaturesService added in v1.8.0 

type TxSignaturesService struct {
}
var GlobalTxSignaturesService *TxSignaturesService

func (*TxSignaturesService) LookupSignatures added in v1.8.0 

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

type ValidatorNames 

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

func (*ValidatorNames) GetValidatorName 

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

func (*ValidatorNames) GetValidatorNamesCount added in v1.8.4 

func (vn *ValidatorNames) GetValidatorNamesCount() uint64

func (*ValidatorNames) LoadValidatorNames 

func (vn *ValidatorNames) LoadValidatorNames()

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.