Function runEventLinkInstrumentationSearchTest

tempodb/tempodb_search_test.go:1978–2093

(t *testing.T, blockVersion string)

}

func runEventLinkInstrumentationSearchTest(t *testing.T, blockVersion string) {
	// only run this test for vparquet4
	if blockVersion != vparquet4.VersionString && blockVersion != vparquet5.VersionString {
		return
	}

	tempDir := t.TempDir()

	dc := backend.DedicatedColumns{
		{Scope: "resource", Name: "res-dedicated.01", Type: "string"},
		{Scope: "resource", Name: "res-dedicated.02", Type: "string"},
		{Scope: "span", Name: "span-dedicated.01", Type: "string"},
		{Scope: "span", Name: "span-dedicated.02", Type: "string"},
		{Scope: "event", Name: "event-dedicated.01", Type: "string"},
	}

	r, w, c, err := New(testingConfig(tempDir, blockVersion, dc), nil, log.NewNopLogger())
	require.NoError(t, err)

	err = c.EnableCompaction(context.Background(), testingCompactorConfig, &mockSharder{}, &mockOverrides{})
	require.NoError(t, err)

	ctx := context.Background()
	r.EnablePolling(ctx, &mockJobSharder{}, false)
	rw := r.(*readerWriter)

	wantID, wantTr, start, end, wantMeta := makeExpectedTrace(nil)
	wantIDText := util.TraceIDToHexString(wantID)

	searchesThatMatch := []*tempopb.SearchRequest{
		{
			// Event generic attribute
			Query: "{ event.exception.message = `random error` }",
		},
		{
			// Dedicated column
			Query: "{ event.event-dedicated.01 = `event-1a` }",
		},
		{
			Query: "{ event:name = `event name` }",
		},
		{
			Query: "{ event:timeSinceStart > 10ms }",
		},
		{
			Query: "{ link.relation = `child-of` }",
		},
		{
			Query: "{ link:traceID = `" + wantIDText + "` }",
		},
		{
			Query: "{ instrumentation:name = `scope-1` }",
		},
		{
			Query: "{ instrumentation:version = `version-1` }",
		},
		{
			Query: "{ instrumentation.scope-attr-str = `scope-attr-1` }",