| 254 | } |
| 255 | |
| 256 | func (i *instance) filterSupportedProcessors(processors map[string]struct{}) map[string]struct{} { |
| 257 | filtered := make(map[string]struct{}, len(processors)) |
| 258 | |
| 259 | for processorName := range processors { |
| 260 | if _, ok := validation.SupportedProcessorsSet[processorName]; ok { |
| 261 | filtered[processorName] = struct{}{} |
| 262 | continue |
| 263 | } |
| 264 | |
| 265 | level.Warn(i.logger).Log("msg", "ignoring unknown metrics-generator processor", "tenant", i.instanceID, "processor", processorName) |
| 266 | } |
| 267 | |
| 268 | return filtered |
| 269 | } |
| 270 | |
| 271 | // diffProcessors compares the existing processors with the desired processors and config. |
| 272 | // Must be called under a read lock. |