removeProcessor removes the processor from the processors map and shuts it down. Must be called under a write lock.
(processorName string)
| 356 | // removeProcessor removes the processor from the processors map and shuts it down. Must be called |
| 357 | // under a write lock. |
| 358 | func (i *instance) removeProcessor(processorName string) { |
| 359 | level.Debug(i.logger).Log("msg", "removing processor", "processorName", processorName) |
| 360 | |
| 361 | deletedProcessor, ok := i.processors[processorName] |
| 362 | if !ok { |
| 363 | return |
| 364 | } |
| 365 | |
| 366 | delete(i.processors, processorName) |
| 367 | |
| 368 | deletedProcessor.Shutdown(context.Background()) |
| 369 | } |
| 370 | |
| 371 | // updateProcessorMetrics updates the active processor metrics. Must be called under a read lock. |
| 372 | func (i *instance) updateProcessorMetrics() { |
no test coverage detected