(res *parquetquery.IteratorResult)
| 3524 | } |
| 3525 | |
| 3526 | func (c *serviceStatsCollector) KeepGroup(res *parquetquery.IteratorResult) bool { |
| 3527 | var key string |
| 3528 | var stats traceql.ServiceStats |
| 3529 | |
| 3530 | for _, e := range res.Entries { |
| 3531 | switch e.Key { |
| 3532 | case columnPathServiceStatsServiceName: |
| 3533 | key = e.Value.String() |
| 3534 | case columnPathServiceStatsSpanCount: |
| 3535 | stats.SpanCount = e.Value.Uint32() |
| 3536 | case columnPathServiceStatsErrorCount: |
| 3537 | stats.ErrorCount = e.Value.Uint32() |
| 3538 | } |
| 3539 | } |
| 3540 | |
| 3541 | res.Entries = res.Entries[:0] |
| 3542 | res.OtherEntries = res.OtherEntries[:0] |
| 3543 | res.AppendOtherValue(key, stats) |
| 3544 | |
| 3545 | return true |
| 3546 | } |
| 3547 | |
| 3548 | // attributeCollector receives rows from the individual key/string/int/etc |
| 3549 | // columns and joins them together into map[key]value entries with the |
nothing calls this directly
no test coverage detected