Function pushTracesToInstance

modules/livestore/instance_search_test.go:665–690

(t *testing.T, i *instance, numTraces int)

}

func pushTracesToInstance(t *testing.T, i *instance, numTraces int) ([]*tempopb.Trace, [][]byte) {
	var ids [][]byte
	var traces []*tempopb.Trace

	for j := 0; j < numTraces; j++ {
		id := make([]byte, 16)
		_, err := crand.Read(id)
		require.NoError(t, err)

		testTrace := test.MakeTrace(10, id)
		trace.SortTrace(testTrace)
		traceBytes, err := testTrace.Marshal()
		require.NoError(t, err)

		// Create a push request for livestore
		req := &tempopb.PushBytesRequest{
			Traces: []tempopb.PreallocBytes{{Slice: traceBytes}},
			Ids:    [][]byte{id},
		}
		i.pushBytes(t.Context(), time.Now(), req)

		ids = append(ids, id)
		traces = append(traces, testTrace)
	}
	return traces, ids
}

// writes traces to the given instance along with search data. returns
// ids expected to be returned from a tag search and strings expected to