| 1181 | } |
| 1182 | |
| 1183 | func (i *Ingester) updateLabelSetMetrics() { |
| 1184 | activeUserSet := make(map[string]map[uint64]struct{}) |
| 1185 | for _, userID := range i.getTSDBUsers() { |
| 1186 | userDB, err := i.getTSDB(userID) |
| 1187 | if err != nil || userDB == nil { |
| 1188 | continue |
| 1189 | } |
| 1190 | |
| 1191 | limits := i.limits.LimitsPerLabelSet(userID) |
| 1192 | activeUserSet[userID] = make(map[uint64]struct{}, len(limits)) |
| 1193 | for _, l := range limits { |
| 1194 | activeUserSet[userID][l.Hash] = struct{}{} |
| 1195 | } |
| 1196 | } |
| 1197 | |
| 1198 | // Update label set metrics in validate metrics. |
| 1199 | i.validateMetrics.UpdateLabelSet(activeUserSet, i.logger) |
| 1200 | } |
| 1201 | |
| 1202 | func (i *Ingester) RenewTokenHandler(w http.ResponseWriter, r *http.Request) { |
| 1203 | i.lifecycler.RenewTokens(0.1, r.Context()) |