| 559 | } |
| 560 | |
| 561 | func MakePushBytesRequest(t testing.TB, requests int, traceID []byte, startTime, endTime uint64) *tempopb.PushBytesRequest { |
| 562 | traceID = ValidTraceID(traceID) |
| 563 | trace := MakeTraceWithTimeRange(requests, traceID, startTime, endTime) |
| 564 | b, err := proto.Marshal(trace) |
| 565 | require.NoError(t, err) |
| 566 | |
| 567 | req := &tempopb.PushBytesRequest{ |
| 568 | Traces: make([]tempopb.PreallocBytes, 0), |
| 569 | Ids: make([][]byte, 0), |
| 570 | } |
| 571 | req.Traces = append(req.Traces, tempopb.PreallocBytes{Slice: b}) |
| 572 | req.Ids = append(req.Ids, traceID) |
| 573 | |
| 574 | return req |
| 575 | } |