| 411 | } |
| 412 | |
| 413 | func doSearch(httpClient httpclient.TempoHTTPClient, config vultureConfiguration, info *util.TraceInfo, l *zap.Logger) { |
| 414 | // query a tag we expect the trace to be found within |
| 415 | searchMetrics, err := searchTag(httpClient, info.Timestamp(), config, l) |
| 416 | if err != nil { |
| 417 | metricErrorTotal.Inc() |
| 418 | logger.Error("search tag for metrics failed", |
| 419 | zap.Error(err), |
| 420 | ) |
| 421 | } |
| 422 | pushVultureMetrics(searchMetrics) |
| 423 | |
| 424 | // traceql query |
| 425 | traceqlSearchMetrics, err := searchTraceql(httpClient, info.Timestamp(), config, l) |
| 426 | if err != nil { |
| 427 | metricErrorTotal.Inc() |
| 428 | logger.Error("traceql query for metrics failed", |
| 429 | zap.Error(err), |
| 430 | ) |
| 431 | } |
| 432 | pushVultureMetrics(traceqlSearchMetrics) |
| 433 | } |
| 434 | |
| 435 | func doMetrics(httpClient httpclient.TempoHTTPClient, config vultureConfiguration, info *util.TraceInfo, l *zap.Logger) { |
| 436 | m, err := queryMetrics(httpClient, info.Timestamp(), config, l) |