Method UpdateTelemetry

controller/block.go:657–677

UpdateTelemetry() updates the prometheus metrics after 'committing' a block

(qc *lib.QuorumCertificate, block *lib.Block, blockProcessingTime time.Duration)

// UpdateTelemetry() updates the prometheus metrics after 'committing' a block
func (c *Controller) UpdateTelemetry(qc *lib.QuorumCertificate, block *lib.Block, blockProcessingTime time.Duration) {
	// create convenience variables
	address, vdfIterations := crypto.NewAddressFromBytes(c.Address), uint64(0)
	// attempt to get VDF iterations
	if block.BlockHeader.Vdf != nil {
		vdfIterations = block.BlockHeader.Vdf.Iterations
	}
	// update node metrics
	c.Metrics.UpdateNodeMetrics(c.isSyncing.Load())
	// update the block metrics
	c.Metrics.UpdateBlockMetrics(block.BlockHeader.ProposerAddress, uint64(len(qc.Block)), block.BlockHeader.NumTxs, vdfIterations, blockProcessingTime)
	// update validator metric
	if v, _ := c.FSM.GetValidator(address); v != nil && v.StakedAmount != 0 {
		isProducer, nonSigners, doubleSigners := c.getValidatorBehaviorMetrics(address, qc)
		c.Metrics.UpdateValidator(address.String(), v.StakedAmount, v.UnstakingHeight != 0, v.MaxPausedHeight != 0, v.Delegate, v.Compound, isProducer, nonSigners, doubleSigners)
	}
	// update account metrics
	if a, _ := c.FSM.GetAccount(address); a.Amount != 0 {
		c.Metrics.UpdateAccount(address.String(), a.Amount)
	}
}

// getValidatorBehaviorMetrics() gets metrics for validator behavior in this block
func (c *Controller) getValidatorBehaviorMetrics(address crypto.AddressI, qc *lib.QuorumCertificate) (isProducer bool, nonSigners map[string]uint64, doubleSigners []crypto.AddressI) {