Function BenchmarkCombine

pkg/model/trace/combine_test.go:166–210

(b *testing.B)

}

func BenchmarkCombine(b *testing.B) {
	parts := []int{2, 3, 4, 8}
	requests := 100 // 100K spans per part
	spansEach := 1000
	id := test.ValidTraceID(nil)

	methods := []struct {
		name   string
		method func(traces []*tempopb.Trace) int
	}{
		{
			"Combiner",
			func(traces []*tempopb.Trace) int {
				c := NewCombiner(0, false)
				for i := range traces {
					_, err := c.ConsumeWithFinal(traces[i], i == len(traces)-1)
					require.NoError(b, err)
				}
				_, spanCount := c.Result()
				return spanCount
			},
		},
	}
	for _, p := range parts {
		b.Run(strconv.Itoa(p), func(b *testing.B) {
			for _, m := range methods {
				b.Run(m.name, func(b *testing.B) {
					for n := 0; n < b.N; n++ {

						// Generate input data. Since combination is destructive
						// this must be done each time.
						b.StopTimer()
						var traces []*tempopb.Trace
						for i := 0; i < p; i++ {
							traces = append(traces, test.MakeTraceWithSpanCount(requests, spansEach, id))
						}
						b.StartTimer()

						m.method(traces)
					}
				})
			}
		})
	}
}