(userID string)
| 3523 | } |
| 3524 | |
| 3525 | func (i *Ingester) deleteUserMetadata(userID string) { |
| 3526 | i.usersMetadataMtx.Lock() |
| 3527 | um := i.usersMetadata[userID] |
| 3528 | delete(i.usersMetadata, userID) |
| 3529 | i.usersMetadataMtx.Unlock() |
| 3530 | |
| 3531 | if um != nil { |
| 3532 | // We need call purge to update i.metrics.memMetadata correctly (it counts number of metrics with metadata in memory). |
| 3533 | // Passing zero time means purge everything. |
| 3534 | um.purge(time.Time{}) |
| 3535 | } |
| 3536 | } |
| 3537 | |
| 3538 | func (i *Ingester) getUsersWithMetadata() []string { |
| 3539 | i.usersMetadataMtx.RLock() |
no test coverage detected