(t *testing.T)
| 83 | } |
| 84 | |
| 85 | func TestEncoderDecoderEmptyStream(t *testing.T) { |
| 86 | decoder := NewDecoder() |
| 87 | |
| 88 | req := &tempopb.PushBytesRequest{} |
| 89 | |
| 90 | records, err := Encode(0, "test-tenant", req, 10<<20) |
| 91 | require.NoError(t, err) |
| 92 | require.Len(t, records, 1) |
| 93 | |
| 94 | decodedReq, err := decoder.Decode(records[0].Value) |
| 95 | require.NoError(t, err) |
| 96 | require.Equal(t, req.Traces, decodedReq.Traces) |
| 97 | } |
| 98 | |
| 99 | func BenchmarkEncodeDecode(b *testing.B) { |
| 100 | decoder := NewDecoder() |
nothing calls this directly
no test coverage detected