monitor

Documentation

Index

• Variables
• func ObserveActiveValidatorsCount(count int)
• func ObserveAggregateAttestation(startTime time.Time)
• func ObserveAggregateQuality(participationCount int, totalCount int)
• func ObserveAttestationBlockProcessingTime(startTime time.Time)
• func ObserveBatchVerificationThroughput(d time.Duration, totalSigs int)
• func ObserveBlobVerificationTime(startTime time.Time)
• func ObserveBlockImportingLatency(latency time.Time)
• func ObserveCommitteeSize(size float64)
• func ObserveCurrentEpoch(epoch uint64)
• func ObserveCurrentSlot(slot uint64)
• func ObserveEpochProcessingTime(startTime time.Time)
• func ObserveExecutionTime(startTime time.Time)
• func ObserveFrozenBlobs(count int)
• func ObserveFrozenBlocks(count int)
• func ObserveFullBlockProcessingTime(startTime time.Time)
• func ObserveGossipTopicSeen(topic string, l int)
• func ObserveNumberOfAggregateSignatures(signatures int)
• func ObserveProcessEffectiveBalanceUpdatesTime(startTime time.Time)
• func ObserveProcessHistoricalRootsUpdateTime(startTime time.Time)
• func ObserveProcessInactivityScoresTime(startTime time.Time)
• func ObserveProcessJustificationBitsAndFinalityTime(startTime time.Time)
• func ObserveProcessParticipationFlagUpdatesTime(startTime time.Time)
• func ObserveProcessRegistryUpdatesTime(startTime time.Time)
• func ObserveProcessRewardsAndPenaltiesTime(startTime time.Time)
• func ObserveProcessSlashingsTime(startTime time.Time)
• func ObserveProcessSyncCommitteeUpdateTime(startTime time.Time)
• func ObserveTotalInBytes(count int64)
• func ObserveTotalOutBytes(count int64)
• type ValidatorMonitor
  • func NewValidatorMonitor(enableMonitor bool, ethClock eth_clock.EthereumClock, ...) ValidatorMonitor

Variables

var (
	ProcessInactivityScoresTime = metrics.GetOrCreateGauge("process_inactivity_ccores_time")
)

Functions

func ObserveActiveValidatorsCount

func ObserveActiveValidatorsCount(count int)

func ObserveAggregateAttestation

func ObserveAggregateAttestation(startTime time.Time)

ObserveAggregateAttestation sets the time it took add new attestation to aggregateAndProof

func ObserveAggregateQuality

func ObserveAggregateQuality(participationCount int, totalCount int)

func ObserveAttestationBlockProcessingTime

func ObserveAttestationBlockProcessingTime(startTime time.Time)

ObserveAttestHit increments the attestation hit metric

func ObserveBatchVerificationThroughput

func ObserveBatchVerificationThroughput(d time.Duration, totalSigs int)

ObserveBatchVerificationThroughput increments the batch verification throughput metric

func ObserveBlobVerificationTime

func ObserveBlobVerificationTime(startTime time.Time)

func ObserveBlockImportingLatency

func ObserveBlockImportingLatency(latency time.Time)

func ObserveCommitteeSize

func ObserveCommitteeSize(size float64)

func ObserveCurrentEpoch

func ObserveCurrentEpoch(epoch uint64)

func ObserveCurrentSlot

func ObserveCurrentSlot(slot uint64)

func ObserveEpochProcessingTime

func ObserveEpochProcessingTime(startTime time.Time)

ObserveEpochProcessingTime sets last epoch processing time

func ObserveExecutionTime

func ObserveExecutionTime(startTime time.Time)

func ObserveFrozenBlobs

func ObserveFrozenBlobs(count int)

func ObserveFrozenBlocks

func ObserveFrozenBlocks(count int)

func ObserveFullBlockProcessingTime

func ObserveFullBlockProcessingTime(startTime time.Time)

ObserveFullBlockProcessingTime increments the full block processing time metric

func ObserveGossipTopicSeen

func ObserveGossipTopicSeen(topic string, l int)

ObserveGossipTopicSeen increments the gossip topic seen metric

func ObserveNumberOfAggregateSignatures

func ObserveNumberOfAggregateSignatures(signatures int)

ObserveNumberOfAggregateSignatures sets the average processing time for each attestation in aggregate

func ObserveProcessEffectiveBalanceUpdatesTime

func ObserveProcessEffectiveBalanceUpdatesTime(startTime time.Time)

ObserveProcessEffectiveBalanceUpdatesTime sets ProcessEffectiveBalanceUpdates time

func ObserveProcessHistoricalRootsUpdateTime

func ObserveProcessHistoricalRootsUpdateTime(startTime time.Time)

ObserveProcessHistoricalRootsUpdateTime sets ProcessHistoricalRootsUpdate time

func ObserveProcessInactivityScoresTime

func ObserveProcessInactivityScoresTime(startTime time.Time)

ObserveProcessInactivityScoresTime sets ProcessJustificationBitsAndFinality time

func ObserveProcessJustificationBitsAndFinalityTime

func ObserveProcessJustificationBitsAndFinalityTime(startTime time.Time)

ObserveProcessJustificationBitsAndFinalityTime sets ProcessJustificationBitsAndFinality time

func ObserveProcessParticipationFlagUpdatesTime

func ObserveProcessParticipationFlagUpdatesTime(startTime time.Time)

ObserveProcessParticipationFlagUpdatesTime sets ProcessParticipationFlagUpdates time

func ObserveProcessRegistryUpdatesTime

func ObserveProcessRegistryUpdatesTime(startTime time.Time)

ObserveProcessRegistryUpdatesTime sets ProcessRegistryUpdates time

func ObserveProcessRewardsAndPenaltiesTime

func ObserveProcessRewardsAndPenaltiesTime(startTime time.Time)

ObserveProcessRewardsAndPenaltiesTime sets ProcessRewardsAndPenalties time

func ObserveProcessSlashingsTime

func ObserveProcessSlashingsTime(startTime time.Time)

ObserveProcessSlashingsTime sets ProcessSlashings time

func ObserveProcessSyncCommitteeUpdateTime

func ObserveProcessSyncCommitteeUpdateTime(startTime time.Time)

ObserveProcessSyncCommitteeUpdateTime sets ProcessSyncCommitteeUpdate time

func ObserveTotalInBytes

func ObserveTotalInBytes(count int64)

func ObserveTotalOutBytes

func ObserveTotalOutBytes(count int64)

Types

type ValidatorMonitor

type ValidatorMonitor interface {
	ObserveValidator(vid uint64)
	RemoveValidator(vid uint64)
	OnNewBlock(state *state.CachingBeaconState, block *cltypes.BeaconBlock) error
}

func NewValidatorMonitor

func NewValidatorMonitor(
	enableMonitor bool,
	ethClock eth_clock.EthereumClock,
	beaconConfig *clparams.BeaconChainConfig,
	syncedData *synced_data.SyncedDataManager,
) ValidatorMonitor