Function testWalBlock

tempodb/encoding/vparquet3/wal_block_test.go:455–487

(t *testing.T, f func(w *walBlock, ids []common.ID, trs []*tempopb.Trace))

}

func testWalBlock(t *testing.T, f func(w *walBlock, ids []common.ID, trs []*tempopb.Trace)) {
	meta := backend.NewBlockMeta("fake", uuid.New(), VersionString)
	w, err := createWALBlock(meta, t.TempDir(), model.CurrentEncoding, 0)
	require.NoError(t, err)

	decoder := model.MustNewSegmentDecoder(model.CurrentEncoding)

	count := 30
	ids := make([]common.ID, count)
	trs := make([]*tempopb.Trace, count)
	for i := 0; i < count; i++ {
		ids[i] = test.ValidTraceID(nil)
		trs[i] = test.MakeTrace(10, ids[i])
		trace.SortTrace(trs[i])

		b1, err := decoder.PrepareForWrite(trs[i], 0, 0)
		require.NoError(t, err)

		b2, err := decoder.ToObject([][]byte{b1})
		require.NoError(t, err)

		err = w.Append(ids[i], b2, 0, 0, true)
		require.NoError(t, err)

		if i%10 == 0 {
			require.NoError(t, w.Flush())
		}
	}

	require.NoError(t, w.Flush())

	f(w, ids, trs)
}

func TestCreateWALBlockFilterDedicatedColumns(t *testing.T) {
	meta := backend.NewBlockMeta("fake", uuid.New(), VersionString)