services

Mar 20, 2026

Changes in this version

+ var ErrTooManyPageRequests = fmt.Errorf("too many concurrent page requests")

type ChainService

+ func (bs *ChainService) GetValidatorInclusionDistance(validatorIndex phase0.ValidatorIndex, lookbackEpochs phase0.Epoch) (count uint64, totalDelay uint64)

type FrontendCacheService

+ func (fc *FrontendCacheService) GetPageTypeStats() []*cache.PageTypeStats

+ func (fc *FrontendCacheService) GetStats() *FrontendCacheStats

+ func (fc *FrontendCacheService) GetTieredCacheStats() *cache.TieredCacheStats

+ type FrontendCacheStats struct

+ CachingEnabled bool

+ ConcurrencyLimit int

+ ConcurrencyUsed int

+ PageCallCounter uint64

+ PageTypeSemLimit int

+ PageTypeSemaphores map[string]int

+ ProcessingPageKeys []string

+ ProcessingPages int

Feb 18, 2026

Changes in this version

type ChainService

+ func (bs *ChainService) GetSystemContractAddresses() map[common.Address]string

Jan 7, 2026

Changes in this version

type ChainService

+ func (bs *ChainService) GetTxIndexer() *txindexer.TxIndexer

Oct 7, 2025

Changes in this version

+ type RPCError struct

+ Code int

+ Data interface{}

+ Message string

+ type RPCProxy struct

+ func NewRPCProxy(config *RPCProxyConfig) *RPCProxy

+ func (rp *RPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type RPCProxyConfig struct

+ AllowedMethods []string

+ BurstLimit int

+ LogRequests bool

+ RequestsPerMinute int

+ Timeout time.Duration

+ UpstreamURL string

+ type RPCRequest struct

+ ID interface{}

+ Jsonrpc string

+ Method string

+ Params interface{}

+ type RPCResponse struct

+ Error *RPCError

+ ID interface{}

+ Jsonrpc string

+ Result interface{}

+ type RateLimiter struct

+ func NewRateLimiter(requestsPerMinute, burstLimit int) *RateLimiter

+ func (rl *RateLimiter) Allow(ip string) bool

+ type TokenBucket struct

Sep 16, 2025

Changes in this version

type ChainService

+ func (bs *ChainService) GetConsolidationQueueByFilter(filter *ConsolidationQueueFilter, offset uint64, limit uint64) ([]*ConsolidationQueueEntry, uint64)

+ func (bs *ChainService) GetExecutionChainState() *execution.ChainState

+ func (bs *ChainService) GetSystemContractAddress(systemContract string) common.Address

+ func (bs *ChainService) GetWithdrawalQueueByFilter(filter *WithdrawalQueueFilter, pageOffset uint64, pageSize uint32) ([]*WithdrawalQueueEntry, uint64, phase0.Gwei)

+ type ConsolidationQueueEntry struct

+ QueuePos uint64

+ SrcIndex phase0.ValidatorIndex

+ SrcValidator *v1.Validator

+ SrcValidatorName string

+ TgtIndex phase0.ValidatorIndex

+ TgtValidator *v1.Validator

+ TgtValidatorName string

+ type ConsolidationQueueFilter struct

+ MaxSrcIndex *uint64

+ MaxTgtIndex *uint64

+ MinSrcIndex *uint64

+ MinTgtIndex *uint64

+ PublicKey []byte

+ ReverseOrder bool

+ ValidatorName string

+ type WithdrawalQueueEntry struct

+ Amount phase0.Gwei

+ EstimatedWithdrawalTime phase0.Slot

+ Validator *v1.Validator

+ ValidatorIndex phase0.ValidatorIndex

+ ValidatorName string

+ WithdrawableEpoch phase0.Epoch

+ type WithdrawalQueueFilter struct

+ MaxValidatorIndex *uint64

+ MinValidatorIndex *uint64

+ PublicKey []byte

+ ValidatorName string

Jul 24, 2025

Changes in this version

+ type DasGuardian struct

+ func NewDasGuardian(ctx context.Context, logger logrus.FieldLogger) (*DasGuardian, error)

+ func (d *DasGuardian) Close() error

+ func (d *DasGuardian) ScanNode(ctx context.Context, nodeEnr string, slots []uint64) (*dasguardian.DasGuardianScanResult, error)

+ func (d *DasGuardian) ScanNodeWithCallback(ctx context.Context, nodeEnr string, slotCallback SlotSelectorCallback) (*dasguardian.DasGuardianScanResult, error)

+ type SlotSelectorCallback func(nodeStatus *dasguardian.StatusV2) ([]uint64, error)

Jul 7, 2025

Changes in this version

type ChainService

+ func (bs *ChainService) GetSnooperManager() *snooper.SnooperManager

Apr 7, 2025

Changes in this version

type ChainService

+ func (bs *ChainService) GetDepositOperationsByFilter(filter *dbtypes.DepositFilter, txFilter *dbtypes.DepositTxFilter, ...) ([]*dbtypes.DepositWithTx, uint64)

+ func (bs *ChainService) GetDepositRequestsByFilter(filter *CombinedDepositRequestFilter, pageOffset uint64, pageSize uint32) ([]*CombinedDepositRequest, uint64)

+ func (bs *ChainService) GetFilteredQueuedDeposits(filter *QueuedDepositFilter) []*IndexedDepositQueueEntry

+ func (bs *ChainService) GetIndexedDepositQueue(headBlock *beacon.Block) *IndexedDepositQueue

+ func (bs *ChainService) GetRecentEpochStats(overrideForkId *beacon.ForkKey) (*beacon.EpochStatsValues, phase0.Epoch)

+ type CombinedDepositRequest struct

+ IsQueued bool

+ QueueEntry *IndexedDepositQueueEntry

+ Request *dbtypes.Deposit

+ RequestOrphaned bool

+ Transaction *dbtypes.DepositTx

+ TransactionOrphaned bool

+ func (ccr *CombinedDepositRequest) Amount() uint64

+ func (ccr *CombinedDepositRequest) DepositIndex() uint64

+ func (ccr *CombinedDepositRequest) PublicKey() []byte

+ func (ccr *CombinedDepositRequest) SourceAddress() []byte

+ func (ccr *CombinedDepositRequest) WithdrawalCredentials() []byte

+ type CombinedDepositRequestFilter struct

+ Filter *dbtypes.DepositTxFilter

+ type IndexedDepositQueue struct

+ Queue []*IndexedDepositQueueEntry

+ QueueEstimation phase0.Epoch

+ TotalGwei phase0.Gwei

+ TotalNew uint64

+ type IndexedDepositQueueEntry struct

+ DepositIndex *uint64

+ EpochEstimate phase0.Epoch

+ PendingDeposit *electra.PendingDeposit

+ QueuePos uint64

+ type QueuedDepositFilter struct

+ MaxAmount uint64

+ MaxIndex uint64

+ MinAmount uint64

+ MinIndex uint64

+ NoIndex bool

+ PublicKey []byte

Feb 17, 2025

Changes in this version

type ChainService

+ func (bs *ChainService) GetCanonicalForkKeys() []beacon.ForkKey

+ func (bs *ChainService) GetFilteredValidatorSet(filter *dbtypes.ValidatorFilter, withBalance bool) ([]v1.Validator, uint64)

+ func (bs *ChainService) GetHighestElBlockNumber(overrideForkId *beacon.ForkKey) uint64

+ func (bs *ChainService) GetValidatorStatusMap() map[v1.ValidatorState]uint64

+ func (bs *ChainService) StopService()

+ func (bs *ChainService) StreamActiveValidatorData(activeOnly bool, cb beacon.ValidatorSetStreamer) error

+ type ValidatorWithIndex struct

+ Index phase0.ValidatorIndex

+ Validator *phase0.Validator

Dec 6, 2024

Changes in this version

type ChainService

+ func (bs *ChainService) GetCanonicalForkIds() []uint64

+ func (bs *ChainService) GetConsolidationRequestOperationsByFilter(filter *dbtypes.ConsolidationRequestFilter, pageIdx uint64, pageSize uint32) ([]*dbtypes.ConsolidationRequest, uint64)

+ func (bs *ChainService) GetValidatorByIndex(index phase0.ValidatorIndex, withBalance bool) *v1.Validator

+ func (bs *ChainService) GetValidatorIndexByPubkey(pubkey phase0.BLSPubKey) (phase0.ValidatorIndex, bool)

+ func (bs *ChainService) GetValidatorLiveness(validatorIndex phase0.ValidatorIndex, lookbackEpochs uint64) (votedEpochs uint64)

+ func (bs *ChainService) GetValidatorVotingActivity(validatorIndex phase0.ValidatorIndex) ([]beacon.ValidatorActivity, phase0.Epoch)

+ func (bs *ChainService) GetWithdrawalRequestOperationsByFilter(filter *dbtypes.WithdrawalRequestFilter, pageIdx uint64, pageSize uint32) ([]*dbtypes.WithdrawalRequest, uint64)

+ type CombinedConsolidationRequest struct

+ Request *dbtypes.ConsolidationRequest

+ RequestOrphaned bool

+ Transaction *dbtypes.ConsolidationRequestTx

+ TransactionOrphaned bool

+ func (ccr *CombinedConsolidationRequest) SourceAddress() []byte

+ func (ccr *CombinedConsolidationRequest) SourceIndex() *uint64

+ func (ccr *CombinedConsolidationRequest) SourcePubkey() []byte

+ func (ccr *CombinedConsolidationRequest) TargetIndex() *uint64

+ func (ccr *CombinedConsolidationRequest) TargetPubkey() []byte

+ type CombinedConsolidationRequestFilter struct

+ Filter *dbtypes.ConsolidationRequestFilter

+ Request uint8

+ type CombinedWithdrawalRequest struct

+ Request *dbtypes.WithdrawalRequest

+ RequestOrphaned bool

+ Transaction *dbtypes.WithdrawalRequestTx

+ TransactionOrphaned bool

+ func (cwr *CombinedWithdrawalRequest) Amount() uint64

+ func (cwr *CombinedWithdrawalRequest) SourceAddress() []byte

+ func (cwr *CombinedWithdrawalRequest) ValidatorIndex() *uint64

+ func (cwr *CombinedWithdrawalRequest) ValidatorPubkey() []byte

+ type CombinedWithdrawalRequestFilter struct

+ Filter *dbtypes.WithdrawalRequestFilter

+ Request uint8

Nov 25, 2024

Changes in this version

type ChainService

+ func (bs *ChainService) GetConsolidationIndexer() *execindexer.ConsolidationIndexer

+ func (bs *ChainService) GetParentForkIds(forkId beacon.ForkKey) []beacon.ForkKey

+ func (bs *ChainService) GetWithdrawalIndexer() *execindexer.WithdrawalIndexer

Sep 18, 2024

Changes in this version

type ChainService

+ func (bs *ChainService) GetConsolidationRequestsByFilter(filter *dbtypes.ConsolidationRequestFilter, pageIdx uint64, pageSize uint32) ([]*dbtypes.ConsolidationRequest, uint64)

+ func (bs *ChainService) GetWithdrawalRequestsByFilter(filter *dbtypes.WithdrawalRequestFilter, pageIdx uint64, pageSize uint32) ([]*dbtypes.WithdrawalRequest, uint64)

Aug 19, 2024

Changes in this version

+ func InitChainService(ctx context.Context, logger logrus.FieldLogger)

type ChainService

+ func (bs *ChainService) GetBeaconIndexer() *beacon.Indexer

+ func (bs *ChainService) GetBlockBlob(ctx context.Context, blockroot phase0.Root, commitment deneb.KZGCommitment) (*deneb.BlobSidecar, error)

+ func (bs *ChainService) GetChainState() *consensus.ChainState

+ func (bs *ChainService) GetConsensusClientForks() []*ConsensusClientFork

+ func (cs *ChainService) StartService() error

+ type ConsensusClientFork struct

+ AllClients []*beacon.Client

+ ReadyClients []*beacon.Client

+ Root phase0.Root

+ Slot phase0.Slot

type FrontendCacheProcessingPage

+ CallCtx context.Context

type ValidatorNames

+ func (vn *ValidatorNames) UpdateDb() error

Aug 12, 2024

Changes in this version

type ChainService

+ func (bs *ChainService) GetConsensusClients() []*indexer.ConsensusClient

+ func (bs *ChainService) GetExecutionClients() []*indexer.ExecutionClient

Jun 17, 2024

Changes in this version

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

+ func StartChainService() error

+ func StartFrontendCache() error

+ func StartTxSignaturesService() error

+ type CallRateLimiter struct

+ var GlobalCallRateLimiter *CallRateLimiter

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

+ type ChainService struct

+ var GlobalBeaconService *ChainService

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (bs *ChainService) GetValidatorNamesCount() uint64

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

+ type CombinedBlockResponse struct

+ Block *spec.VersionedSignedBeaconBlock

+ Header *phase0.SignedBeaconBlockHeader

+ Orphaned bool

+ Root []byte

+ type FrontendCachePageError struct

+ func (e FrontendCachePageError) Error() string

+ func (e FrontendCachePageError) Name() string

+ func (e FrontendCachePageError) Stack() string

+ type FrontendCacheProcessingPage struct

+ CacheTimeout time.Duration

+ PageKey string

+ type FrontendCacheService struct

+ var GlobalFrontendCache *FrontendCacheService

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

+ type MevIndexer struct

+ func NewMevIndexer() *MevIndexer

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

+ type PageDataHandlerFn = func(pageCall *FrontendCacheProcessingPage) interface

+ type TxSignaturesLookup struct

+ Bytes types.TxSignatureBytes

+ Name string

+ Signature string

+ Status types.TxSignatureLookupStatus

+ type TxSignaturesService struct

+ var GlobalTxSignaturesService *TxSignaturesService

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

+ type ValidatorNames struct

+ func NewValidatorNames() *ValidatorNames

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

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

+ func (vn *ValidatorNames) GetValidatorNamesCount() uint64

+ func (vn *ValidatorNames) LoadValidatorNames() chan bool

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