Method updateRingMetrics

pkg/ring/ring.go:662–728

updateRingMetrics updates ring metrics. Caller must be holding the Write lock!

(compareResult CompareResult)

// updateRingMetrics updates ring metrics. Caller must be holding the Write lock!
func (r *Ring) updateRingMetrics(compareResult CompareResult) {
	if compareResult == Equal {
		return
	}

	numByStateByZone := map[string]map[string]int{}
	oldestTimestampByState := map[string]int64{}

	// Initialized to zero so we emit zero-metrics (instead of not emitting anything)
	for _, s := range []string{unhealthy, ACTIVE.String(), LEAVING.String(), PENDING.String(), JOINING.String(), READONLY.String()} {
		numByStateByZone[s] = map[string]int{}
		// make sure removed zones got zero value
		for _, zone := range r.previousRingZones {
			numByStateByZone[s][zone] = 0
		}
		for _, zone := range r.ringZones {
			numByStateByZone[s][zone] = 0
		}
		oldestTimestampByState[s] = 0
	}

	for _, instance := range r.ringDesc.Ingesters {
		s := instance.State.String()
		if !r.IsHealthy(&instance, Reporting, r.KVClient.LastUpdateTime(r.key)) {
			s = unhealthy
		}
		if _, ok := numByStateByZone[s]; !ok {
			numByStateByZone[s] = map[string]int{}
		}
		numByStateByZone[s][instance.Zone]++
		if oldestTimestampByState[s] == 0 || instance.Timestamp < oldestTimestampByState[s] {
			oldestTimestampByState[s] = instance.Timestamp
		}
	}

	for state, zones := range numByStateByZone {
		for zone, count := range zones {
			r.numMembersGaugeVec.WithLabelValues(state, zone).Set(float64(count))
		}
	}
	for state, timestamp := range oldestTimestampByState {
		r.oldestTimestampGaugeVec.WithLabelValues(state).Set(float64(timestamp))
	}

	if compareResult == EqualButStatesAndTimestamps {
		return
	}

	if r.cfg.DetailedMetricsEnabled {
		prevOwners := r.reportedOwners
		r.reportedOwners = make(map[string]struct{})
		numTokens, ownedRange := r.countTokens()
		for id, totalOwned := range ownedRange {
			r.memberOwnershipGaugeVec.WithLabelValues(id).Set(float64(totalOwned) / float64(math.MaxUint32+1))
			r.numTokensGaugeVec.WithLabelValues(id).Set(float64(numTokens[id]))
			delete(prevOwners, id)
			r.reportedOwners[id] = struct{}{}
		}