()
| 3536 | } |
| 3537 | |
| 3538 | func (i *Ingester) getUsersWithMetadata() []string { |
| 3539 | i.usersMetadataMtx.RLock() |
| 3540 | defer i.usersMetadataMtx.RUnlock() |
| 3541 | |
| 3542 | userIDs := make([]string, 0, len(i.usersMetadata)) |
| 3543 | for userID := range i.usersMetadata { |
| 3544 | userIDs = append(userIDs, userID) |
| 3545 | } |
| 3546 | |
| 3547 | return userIDs |
| 3548 | } |
| 3549 | |
| 3550 | func (i *Ingester) purgeUserMetricsMetadata() { |
| 3551 | deadline := time.Now().Add(-i.cfg.MetadataRetainPeriod) |
no outgoing calls
no test coverage detected