(userID string, m *cortexpb.MetricMetadata)
| 3486 | } |
| 3487 | |
| 3488 | func (i *Ingester) appendMetadata(userID string, m *cortexpb.MetricMetadata) error { |
| 3489 | i.stoppedMtx.RLock() |
| 3490 | if i.stopped { |
| 3491 | i.stoppedMtx.RUnlock() |
| 3492 | return errIngesterStopping |
| 3493 | } |
| 3494 | i.stoppedMtx.RUnlock() |
| 3495 | |
| 3496 | userMetadata := i.getOrCreateUserMetadata(userID) |
| 3497 | |
| 3498 | return userMetadata.add(m.GetMetricFamilyName(), m) |
| 3499 | } |
| 3500 | |
| 3501 | func (i *Ingester) getOrCreateUserMetadata(userID string) *userMetricsMetadata { |
| 3502 | userMetadata := i.getUserMetadata(userID) |
no test coverage detected