Method updateRingMetrics

ring/ring.go:868–923

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

()

// updateRingMetrics updates ring metrics. Caller must be holding the Write lock!
func (r *Ring) updateRingMetrics() {
	numByState := map[string]int{}
	oldestTimestampByState := map[string]int64{}

	// Will emit nothing if no zones were discovered.
	var numByZoneAndState map[string]map[string]int
	if r.cfg.ZoneAwarenessEnabled {
		numByZoneAndState = map[string]map[string]int{}
		for zone := range r.trackedRingZones {
			numByZoneAndState[zone] = map[string]int{}
		}
	}

	// 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()} {
		numByState[s] = 0
		oldestTimestampByState[s] = 0
		if r.cfg.ZoneAwarenessEnabled {
			for zone := range numByZoneAndState {
				numByZoneAndState[zone][s] = 0
			}
		}
	}

	for _, instance := range r.ringDesc.Ingesters {
		s := instance.State.String()
		if !r.IsHealthy(&instance, Reporting, time.Now()) {
			s = unhealthy
		}
		numByState[s]++
		if oldestTimestampByState[s] == 0 || instance.Timestamp < oldestTimestampByState[s] {
			oldestTimestampByState[s] = instance.Timestamp
		}
		if r.cfg.ZoneAwarenessEnabled {
			if byState, ok := numByZoneAndState[instance.Zone]; ok {
				byState[s]++
			}
		}
	}

	for state, count := range numByState {
		r.numMembersGaugeVec.WithLabelValues(state).Set(float64(count))
	}
	for state, timestamp := range oldestTimestampByState {
		r.oldestTimestampGaugeVec.WithLabelValues(state).Set(float64(timestamp))
	}
	if r.cfg.ZoneAwarenessEnabled {
		for zone, byState := range numByZoneAndState {
			for state, count := range byState {
				r.numZoneMembersGaugeVec.WithLabelValues(zone, state).Set(float64(count))
			}
		}
	}

	r.totalTokensGauge.Set(float64(len(r.ringTokens)))
}

// ShuffleShard returns a subring for the provided identifier (eg. a tenant ID)