(res *parquetquery.IteratorResult)
| 3615 | } |
| 3616 | |
| 3617 | func (c *serviceStatsCollector) KeepGroup(res *parquetquery.IteratorResult) bool { |
| 3618 | var key string |
| 3619 | var stats traceql.ServiceStats |
| 3620 | |
| 3621 | for _, e := range res.Entries { |
| 3622 | switch e.Key { |
| 3623 | case columnPathServiceStatsServiceName: |
| 3624 | key = e.Value.String() |
| 3625 | case columnPathServiceStatsSpanCount: |
| 3626 | stats.SpanCount = e.Value.Uint32() |
| 3627 | case columnPathServiceStatsErrorCount: |
| 3628 | stats.ErrorCount = e.Value.Uint32() |
| 3629 | } |
| 3630 | } |
| 3631 | |
| 3632 | res.Entries = res.Entries[:0] |
| 3633 | res.OtherEntries = res.OtherEntries[:0] |
| 3634 | res.AppendOtherValue(key, stats) |
| 3635 | |
| 3636 | return true |
| 3637 | } |
| 3638 | |
| 3639 | // attributeCollector receives rows from the individual key/string/int/etc |
| 3640 | // columns and joins them together into map[key]value entries with the |
nothing calls this directly
no test coverage detected