(t *testing.T)
| 1028 | } |
| 1029 | |
| 1030 | func createValidPushRequest(t *testing.T) []byte { |
| 1031 | id := test.ValidTraceID(nil) |
| 1032 | expectedTrace := test.MakeTrace(5, id) |
| 1033 | traceBytes, err := proto.Marshal(expectedTrace) |
| 1034 | require.NoError(t, err) |
| 1035 | |
| 1036 | req := &tempopb.PushBytesRequest{ |
| 1037 | Traces: []tempopb.PreallocBytes{{Slice: traceBytes}}, |
| 1038 | Ids: [][]byte{id}, |
| 1039 | } |
| 1040 | |
| 1041 | records, err := ingest.Encode(0, testTenantID, req, 1_000_000) |
| 1042 | require.NoError(t, err) |
| 1043 | |
| 1044 | return records[0].Value |
| 1045 | } |
| 1046 | |
| 1047 | func createValidPushRequestStartEnd(t *testing.T, start, end time.Time) []byte { |
| 1048 | id := test.ValidTraceID(nil) |
no test coverage detected