Function testSearch

tempodb/wal/wal_test.go:221–248

(t *testing.T, e encoding.VersionedEncoding)

}

func testSearch(t *testing.T, e encoding.VersionedEncoding) {
	runWALTest(t, e.Version(), func(ids [][]byte, objs []*tempopb.Trace, block common.WALBlock) {
		ctx := context.Background()

		for i, o := range objs {
			k, v := findFirstAttribute(o)
			require.NotEmpty(t, k)
			require.NotEmpty(t, v)

			resp, err := block.Search(ctx, &tempopb.SearchRequest{
				Tags: map[string]string{
					k: v,
				},
				Limit: 10,
			}, common.DefaultSearchOptions())
			if errors.Is(err, util.ErrUnsupported) {
				return
			}
			require.NoError(t, err)
			require.NotNil(t, resp.Metrics.InspectedBytes)
			require.NotZero(t, resp.Metrics.InspectedBytes)
			require.LessOrEqual(t, resp.Metrics.InspectedBytes, block.DataLength())

			require.Equal(t, 1, len(resp.Traces))
			require.Equal(t, util.TraceIDToHexString(ids[i]), resp.Traces[0].TraceID)
		}
	})
}

func TestFetch(t *testing.T) {
	for _, e := range encoding.AllEncodingsForWrites() {