(b *testing.B)
| 932 | var benchmarkTrace *Trace |
| 933 | |
| 934 | func BenchmarkTraceToParquet(b *testing.B) { |
| 935 | var ( |
| 936 | traceID = test.ValidTraceID(nil) |
| 937 | traces = make([]*tempopb.Trace, 0, 1_000) |
| 938 | parquetTraces = make([]*Trace, 11) |
| 939 | ) |
| 940 | |
| 941 | for range 1_000 { |
| 942 | nb := 20 + rand.Intn(5) |
| 943 | id := test.ValidTraceID(nil) |
| 944 | traces = append(traces, test.AddDedicatedAttributes(test.MakeTrace(nb, test.ValidTraceID(id)))) |
| 945 | } |
| 946 | |
| 947 | b.ResetTimer() |
| 948 | b.ReportAllocs() |
| 949 | |
| 950 | for i := range b.N { |
| 951 | t := traces[i%len(traces)] |
| 952 | pt := parquetTraces[i%len(parquetTraces)] |
| 953 | |
| 954 | traceToParquet(&backend.BlockMeta{}, traceID, t, pt) |
| 955 | benchmarkTrace = pt // prevent the compiler from optimizing out the above call |
| 956 | } |
| 957 | } |
| 958 | |
| 959 | func tempopbTraceEqual(t *testing.T, expected, actual *tempopb.Trace) { |
| 960 | sortAttributesTempopb(expected) |
nothing calls this directly
no test coverage detected