updateProcessorMetrics updates the active processor metrics. Must be called under a read lock.
()
| 370 | |
| 371 | // updateProcessorMetrics updates the active processor metrics. Must be called under a read lock. |
| 372 | func (i *instance) updateProcessorMetrics() { |
| 373 | for _, processorName := range validation.SupportedProcessors { |
| 374 | isPresent := 0.0 |
| 375 | if _, ok := i.processors[processorName]; ok { |
| 376 | isPresent = 1.0 |
| 377 | } |
| 378 | metricActiveProcessors.WithLabelValues(i.instanceID, processorName).Set(isPresent) |
| 379 | } |
| 380 | } |
| 381 | |
| 382 | func (i *instance) pushSpans(ctx context.Context, req *tempopb.PushSpansRequest) { |
| 383 | i.preprocessSpans(req) |