(t testing.TB, batches []*v1.ResourceSpans)
| 197 | } |
| 198 | |
| 199 | func marshalBatches(t testing.TB, batches []*v1.ResourceSpans) []byte { |
| 200 | t.Helper() |
| 201 | |
| 202 | trace := tempopb.Trace{ResourceSpans: batches} |
| 203 | |
| 204 | m, err := trace.Marshal() |
| 205 | require.NoError(t, err) |
| 206 | |
| 207 | return m |
| 208 | } |
| 209 | |
| 210 | func BenchmarkGeneratorDecoderPushBytes(b *testing.B) { |
| 211 | stream := generateRequest(1000, 200) |
no test coverage detected