(userID string)
| 303 | } |
| 304 | |
| 305 | func (r *DefaultMultiTenantManager) removeNotifier(userID string) { |
| 306 | r.notifiersMtx.Lock() |
| 307 | defer r.notifiersMtx.Unlock() |
| 308 | |
| 309 | if n, ok := r.notifiers[userID]; ok { |
| 310 | n.stop() |
| 311 | } |
| 312 | |
| 313 | delete(r.notifiers, userID) |
| 314 | } |
| 315 | |
| 316 | func (r *DefaultMultiTenantManager) getOrCreateNotifier(userID string, userManagerRegistry prometheus.Registerer) (*notifier.Manager, error) { |
| 317 | r.notifiersMtx.Lock() |