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 ObserveExecutionClientInsertingBlocks(startTime time.Time)
• func ObserveExecutionClientValidateChain(startTime time.Time)
• func ObserveFrozenBlobs(count int)
• func ObserveFrozenBlocks(count int)
• func ObserveFullBlockProcessingTime(startTime time.Time)
• func ObserveGossipTopicSeen(topic string, l int)
• func ObserveNewPayloadTime(startTime time.Time)
• func ObserveNumberOfAggregateSignatures(signatures int)
• func ObserveTotalInBytes(count int64)
• func ObserveTotalOutBytes(count int64)
• type TimeMeasure
  • func ObserveElaspedTime(m metrics.Gauge) TimeMeasure
  • func (m TimeMeasure) End()

Variables

var (

	// Epoch processing metrics
	EpochProcessingTime                     = metrics.GetOrCreateGauge("epoch_processing_time")
	ProcessJustificationBitsAndFinalityTime = metrics.GetOrCreateGauge("process_justification_bits_and_finality_time")
	ProcessInactivityScoresTime             = metrics.GetOrCreateGauge("process_inactivity_ccores_time")
	ProcessRewardsAndPenaltiesTime          = metrics.GetOrCreateGauge("process_rewards_and_penalties_time")
	ProcessRegistryUpdatesTime              = metrics.GetOrCreateGauge("process_registry_updates_time")
	ProcessSlashingsTime                    = metrics.GetOrCreateGauge("process_slashings_time")
	ProcessEffectiveBalanceUpdatesTime      = metrics.GetOrCreateGauge("process_effective_balance_updates_time")
	ProcessHistoricalRootsUpdateTime        = metrics.GetOrCreateGauge("process_historical_roots_update_time")
	ProcessParticipationFlagUpdatesTime     = metrics.GetOrCreateGauge("process_participation_flag_updates_time")
	ProcessSyncCommitteeUpdateTime          = metrics.GetOrCreateGauge("process_sync_committee_update_time")
	ProcessPendingDepositsTime              = metrics.GetOrCreateGauge("process_pending_deposits_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 ObserveExecutionClientInsertingBlocks

func ObserveExecutionClientInsertingBlocks(startTime time.Time)

func ObserveExecutionClientValidateChain

func ObserveExecutionClientValidateChain(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 ObserveNewPayloadTime

func ObserveNewPayloadTime(startTime time.Time)

func ObserveNumberOfAggregateSignatures

func ObserveNumberOfAggregateSignatures(signatures int)

ObserveNumberOfAggregateSignatures sets the average processing time for each attestation in aggregate

func ObserveTotalInBytes

func ObserveTotalInBytes(count int64)

func ObserveTotalOutBytes

func ObserveTotalOutBytes(count int64)

Types

type TimeMeasure

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

func ObserveElaspedTime

func ObserveElaspedTime(m metrics.Gauge) TimeMeasure

func (TimeMeasure) End

func (m TimeMeasure) End()