(newMetrics *tempopb.SearchMetrics, resp PipelineResponse)
| 17 | } |
| 18 | |
| 19 | func (mc *SearchMetricsCombiner) Combine(newMetrics *tempopb.SearchMetrics, resp PipelineResponse) { |
| 20 | if newMetrics != nil { |
| 21 | mc.Metrics.CompletedJobs++ |
| 22 | if !IsCacheHit(resp.HTTPResponse()) { |
| 23 | mc.Metrics.InspectedTraces += newMetrics.InspectedTraces |
| 24 | mc.Metrics.InspectedBytes += newMetrics.InspectedBytes |
| 25 | } |
| 26 | } |
| 27 | } |
| 28 | |
| 29 | func (mc *SearchMetricsCombiner) CombineMetadata(newMetrics *tempopb.SearchMetrics, _ PipelineResponse) { |
| 30 | // These "Total" metrics are calculated by the frontend in the sharder. |
no test coverage detected