beacon

Dec 2, 2024

Changes in this version

type Node

+ GetZeroLogLevel func() zerolog.Level

Oct 9, 2024

Changes in this version

+ type FirstTimeHealthyEvent struct

type Node

+ OnFirstTimeHealthy func(ctx context.Context, ...)

Oct 1, 2024

Changes in this version

type Node

+ FetchNodeIdentity func(ctx context.Context) (*types.Identity, error)

Sep 19, 2024

Changes in this version

type Node

+ FetchBeaconBlockHeader func(ctx context.Context, opts *eapi.BeaconBlockHeaderOpts) (*v1.BeaconBlockHeader, error)

Jul 30, 2024

Changes in this version

type Node

+ FetchBlockRoot func(ctx context.Context, stateID string) (*phase0.Root, error)

Jun 7, 2024

Changes in this version

type Node

+ Service func() eth2client.Service

May 12, 2024

Changes in this version

type Node

+ FetchRawSpec func(ctx context.Context) (map[string]any, error)

Mar 27, 2024

Changes in this version

type Node

+ FetchRawBlock func(ctx context.Context, stateID string, contentType string) ([]byte, error)

Jan 31, 2024

Changes in this version

type Node

+ FetchBeaconStateRoot func(ctx context.Context, stateID string) (phase0.Root, error)

Jan 18, 2024

Changes in this version

type BeaconMetrics

+ BlobKZGCommitments prometheus.GaugeVec

Oct 10, 2023

Changes in this version

type Node

+ FetchBeaconBlockBlobs func(ctx context.Context, blockID string) ([]*deneb.BlobSidecar, error)

Oct 5, 2023

Changes in this version

type Node

+ OnBlobSidecar func(ctx context.Context, ...)

Aug 21, 2023

Changes in this version

type Node

+ FetchAttestationData func(ctx context.Context, slot phase0.Slot, committeeIndex phase0.CommitteeIndex) (*phase0.AttestationData, error)

Jul 14, 2023

Changes in this version

type Node

+ FetchBeaconCommittees func(ctx context.Context, state string, epoch phase0.Epoch) ([]*v1.BeaconCommittee, error)

Jun 19, 2023

Changes in this version

type Config

+ Headers map[string]string

May 25, 2023

Changes in this version

type Node

+ FetchDepositSnapshot func(ctx context.Context) (*types.DepositSnapshot, error)

Mar 23, 2023

Changes in this version

type Node

+ FetchForkChoice func(ctx context.Context) (*v1.ForkChoice, error)

Dec 16, 2022

Changes in this version

+ func GetDepositCountsFromBeaconBlock(block *spec.VersionedSignedBeaconBlock) int

+ func GetTransactionsCountFromBeaconBlock(block *spec.VersionedSignedBeaconBlock) int

+ func GetVoluntaryExitsFromBeaconBlock(block *spec.VersionedSignedBeaconBlock) int

+ type BeaconMetrics struct

+ Attestations prometheus.GaugeVec

+ Deposits prometheus.GaugeVec

+ EmptySlots prometheus.Counter

+ FinalityCheckpoints prometheus.GaugeVec

+ ProposerDelay prometheus.Histogram

+ ReOrgDepth prometheus.Counter

+ ReOrgs prometheus.Counter

+ Slashings prometheus.GaugeVec

+ Slot prometheus.GaugeVec

+ Transactions prometheus.GaugeVec

+ VoluntaryExits prometheus.GaugeVec

+ Withdrawals prometheus.GaugeVec

+ WithdrawalsAmount prometheus.GaugeVec

+ WithdrawalsIndexMax prometheus.GaugeVec

+ WithdrawalsIndexMin prometheus.GaugeVec

+ func NewBeaconMetrics(beac Node, log logrus.FieldLogger, namespace string, ...) *BeaconMetrics

+ func (b *BeaconMetrics) GetSignedBeaconBlock(ctx context.Context, blockID string) error

+ func (b *BeaconMetrics) Name() string

+ func (b *BeaconMetrics) Start(ctx context.Context) error

+ func (b *BeaconMetrics) Stop() error

+ type BeaconSubscriptionOptions struct

+ Enabled bool

+ Topics EventTopics

+ func DefaultDisabledBeaconSubscriptionOptions() BeaconSubscriptionOptions

+ func DefaultEnabledBeaconSubscriptionOptions() BeaconSubscriptionOptions

+ func (b *BeaconSubscriptionOptions) Disable() *BeaconSubscriptionOptions

+ func (b *BeaconSubscriptionOptions) Enable() *BeaconSubscriptionOptions

+ type Config struct

+ Addr string

+ Name string

+ type EmptySlotEvent struct

+ Slot phase0.Slot

+ type EventMetrics struct

+ Count prometheus.CounterVec

+ LastEventTime time.Time

+ TimeSinceLastEvent prometheus.Gauge

+ func NewEventJob(bc Node, log logrus.FieldLogger, namespace string, ...) *EventMetrics

+ func (e *EventMetrics) HandleEvent(ctx context.Context, event *v1.Event) error

+ func (e *EventMetrics) Name() string

+ func (e *EventMetrics) Start(ctx context.Context) error

+ func (e *EventMetrics) Stop() error

+ type EventTopics []string

+ func (e EventTopics) Exists(topic string) bool

+ type FinalityCheckpointUpdated struct

+ Finality *v1.Finality

+ type ForkMetrics struct

+ Activated prometheus.GaugeVec

+ Current prometheus.GaugeVec

+ Epochs prometheus.GaugeVec

+ func NewForksJob(beac Node, log logrus.FieldLogger, namespace string, ...) *ForkMetrics

+ func (f *ForkMetrics) Name() string

+ func (f *ForkMetrics) Start(ctx context.Context) error

+ func (f *ForkMetrics) Stop() error

+ type GeneralMetrics struct

+ ClientName prometheus.GaugeVec

+ NodeVersion prometheus.GaugeVec

+ Peers prometheus.GaugeVec

+ func NewGeneralJob(beac Node, log logrus.FieldLogger, namespace string, ...) *GeneralMetrics

+ func (g *GeneralMetrics) Name() string

+ func (g *GeneralMetrics) Start(ctx context.Context) error

+ func (g *GeneralMetrics) Stop() error

+ type Health struct

+ func NewHealth(successThreshold, failThreshold int) *Health

+ func (n *Health) RecordFail(err error)

+ func (n *Health) RecordSuccess()

+ func (n Health) FailedTotal() uint64

+ func (n Health) Healthy() bool

+ func (n Health) SuccessTotal() uint64

+ type HealthCheckFailedEvent struct

+ Duration time.Duration

+ type HealthCheckOptions struct

+ FailedResponses int

+ Interval human.Duration

+ SuccessfulResponses int

+ func DefaultHealthCheckOptions() HealthCheckOptions

+ type HealthCheckSucceededEvent struct

+ Duration time.Duration

+ type HealthMetrics struct

+ CheckResultsTotal *prometheus.CounterVec

+ Up prometheus.Gauge

+ func NewHealthMetrics(beac Node, log logrus.FieldLogger, namespace string, ...) *HealthMetrics

+ func (h *HealthMetrics) Name() string

+ func (h *HealthMetrics) Start(ctx context.Context) error

+ func (h *HealthMetrics) Stop() error

+ type Metrics struct

+ func NewMetrics(log logrus.FieldLogger, namespace, nodeName string, beacon Node) *Metrics

+ func (m *Metrics) Beacon() *BeaconMetrics

+ func (m *Metrics) Events() *EventMetrics

+ func (m *Metrics) Forks() *ForkMetrics

+ func (m *Metrics) General() *GeneralMetrics

+ func (m *Metrics) Health() *HealthMetrics

+ func (m *Metrics) Spec() *SpecMetrics

+ func (m *Metrics) Start(ctx context.Context) error

+ func (m *Metrics) Stop() error

+ func (m *Metrics) Sync() *SyncMetrics

+ type MetricsJob interface

+ Name func() string

+ Start func(ctx context.Context) error

+ Stop func() error

+ type Node interface

+ FetchBeaconState func(ctx context.Context, stateID string) (*spec.VersionedBeaconState, error)

+ FetchBlock func(ctx context.Context, stateID string) (*spec.VersionedSignedBeaconBlock, error)

+ FetchFinality func(ctx context.Context, stateID string) (*v1.Finality, error)

+ FetchGenesis func(ctx context.Context) (*v1.Genesis, error)

+ FetchNodeVersion func(ctx context.Context) (string, error)

+ FetchPeers func(ctx context.Context) (*types.Peers, error)

+ FetchProposerDuties func(ctx context.Context, epoch phase0.Epoch) ([]*v1.ProposerDuty, error)

+ FetchRawBeaconState func(ctx context.Context, stateID string, contentType string) ([]byte, error)

+ FetchSpec func(ctx context.Context) (*state.Spec, error)

+ FetchSyncStatus func(ctx context.Context) (*v1.SyncState, error)

+ Finality func() (*v1.Finality, error)

+ Genesis func() (*v1.Genesis, error)

+ Healthy func() bool

+ NodeVersion func() (string, error)

+ OnAttestation func(ctx context.Context, ...)

+ OnBlock func(ctx context.Context, ...)

+ OnChainReOrg func(ctx context.Context, ...)

+ OnContributionAndProof func(ctx context.Context, ...)

+ OnEmptySlot func(ctx context.Context, ...)

+ OnEvent func(ctx context.Context, handler func(ctx context.Context, ev *v1.Event) error)

+ OnFinalityCheckpointUpdated func(ctx context.Context, ...)

+ OnFinalizedCheckpoint func(ctx context.Context, ...)

+ OnHead func(ctx context.Context, handler func(ctx context.Context, ev *v1.HeadEvent) error)

+ OnHealthCheckFailed func(ctx context.Context, ...)

+ OnHealthCheckSucceeded func(ctx context.Context, ...)

+ OnNodeVersionUpdated func(ctx context.Context, ...)

+ OnPeersUpdated func(ctx context.Context, ...)

+ OnReady func(ctx context.Context, ...)

+ OnSpecUpdated func(ctx context.Context, ...)

+ OnSyncStatus func(ctx context.Context, ...)

+ OnVoluntaryExit func(ctx context.Context, ...)

+ Options func() *Options

+ Spec func() (*state.Spec, error)

+ Start func(ctx context.Context) error

+ StartAsync func(ctx context.Context)

+ Status func() *Status

+ Stop func(ctx context.Context) error

+ SyncState func() (*v1.SyncState, error)

+ Wallclock func() *ethwallclock.EthereumBeaconChain

+ func NewNode(log logrus.FieldLogger, config *Config, namespace string, options Options) Node

+ type NodeVersionUpdatedEvent struct

+ Version string

+ type Options struct

+ BeaconSubscription BeaconSubscriptionOptions

+ DetectEmptySlots bool

+ HealthCheck HealthCheckOptions

+ PrometheusMetrics bool

+ func DefaultOptions() *Options

+ func (o *Options) DisableEmptySlotDetection() *Options

+ func (o *Options) DisablePrometheusMetrics() *Options

+ func (o *Options) EnableDefaultBeaconSubscription() *Options

+ func (o *Options) EnableEmptySlotDetection() *Options

+ func (o *Options) EnablePrometheusMetrics() *Options

+ type PeersUpdatedEvent struct

+ Peers types.Peers

+ type ReadyEvent struct

+ type SpecMetrics struct

+ BaseRewardFactor prometheus.Gauge

+ ConfigName prometheus.GaugeVec

+ DepositChainID prometheus.Gauge

+ EffectiveBalanceIncrement prometheus.Gauge

+ EpochsPerSyncCommitteePeriod prometheus.Gauge

+ Eth1FollowDistance prometheus.Gauge

+ GenesisDelay prometheus.Gauge

+ MaxAttestations prometheus.Gauge

+ MaxDeposits prometheus.Gauge

+ MaxEffectiveBalance prometheus.Gauge

+ MaxValidatorsPerCommittee prometheus.Gauge

+ MinDepositAmount prometheus.Gauge

+ MinGenesisActiveValidatorCount prometheus.Gauge

+ MinSyncCommitteeParticipants prometheus.Gauge

+ PresetBase prometheus.GaugeVec

+ SafeSlotsToUpdateJustified prometheus.Gauge

+ SecondsPerEth1Block prometheus.Gauge

+ SecondsPerSlot prometheus.Gauge

+ SlotsPerEpoch prometheus.Gauge

+ SyncCommitteeSize prometheus.Gauge

+ TargetCommitteeSize prometheus.Gauge

+ TerminalBlockHashActivationEpoch prometheus.Gauge

+ TerminalTotalDifficulty prometheus.Gauge

+ TerminalTotalDifficultyTrillions prometheus.Gauge

+ func NewSpecJob(bc Node, log logrus.FieldLogger, namespace string, ...) *SpecMetrics

+ func (s *SpecMetrics) Name() string

+ func (s *SpecMetrics) Start(ctx context.Context) error

+ func (s *SpecMetrics) Stop() error

+ type SpecUpdatedEvent struct

+ Spec *state.Spec

+ type Status struct

+ func NewStatus(successThreshold, failThreshold int) *Status

+ func (s *Status) Health() *Health

+ func (s *Status) Healthy() bool

+ func (s *Status) NetworkID() uint64

+ func (s *Status) SyncState() *v1.SyncState

+ func (s *Status) Syncing() bool

+ func (s *Status) UpdateNetworkID(networkID uint64)

+ func (s *Status) UpdateSyncState(state *v1.SyncState)

+ type SyncMetrics struct

+ Distance prometheus.Gauge

+ EstimatedHighestSlot prometheus.Gauge

+ HeadSlot prometheus.Gauge

+ IsSyncing prometheus.Gauge

+ Percentage prometheus.Gauge

+ func NewSyncMetrics(beac Node, log logrus.FieldLogger, namespace string, ...) *SyncMetrics

+ func (s *SyncMetrics) Name() string

+ func (s *SyncMetrics) Start(ctx context.Context) error

+ func (s *SyncMetrics) Stop() error

+ type SyncStatusEvent struct

+ State *v1.SyncState