(in []*tempopb.TimeSeries)
| 1542 | } |
| 1543 | |
| 1544 | func (m *MetricsFrontendEvaluator) ObserveSeries(in []*tempopb.TimeSeries) { |
| 1545 | m.mtx.Lock() |
| 1546 | defer m.mtx.Unlock() |
| 1547 | |
| 1548 | m.metricsPipeline.observeSeries(in) |
| 1549 | } |
| 1550 | |
| 1551 | func (m *MetricsFrontendEvaluator) Results() SeriesSet { |
| 1552 | m.mtx.Lock() |