(l *Limiter, m *ingesterMetrics, v *validation.ValidateMetrics, userID string, skipMetadataLimits bool)
| 31 | } |
| 32 | |
| 33 | func newMetadataMap(l *Limiter, m *ingesterMetrics, v *validation.ValidateMetrics, userID string, skipMetadataLimits bool) *userMetricsMetadata { |
| 34 | return &userMetricsMetadata{ |
| 35 | metricToMetadata: map[string]metricMetadataSet{}, |
| 36 | limiter: l, |
| 37 | metrics: m, |
| 38 | validateMetrics: v, |
| 39 | userID: userID, |
| 40 | skipMetadataLimits: skipMetadataLimits, |
| 41 | } |
| 42 | } |
| 43 | |
| 44 | func (mm *userMetricsMetadata) add(metric string, metadata *cortexpb.MetricMetadata) error { |
| 45 | mm.mtx.Lock() |
no outgoing calls