Function TestOriginalFixtures

tempodb/backend/test/backend_test.go:87–154

(t *testing.T)

}

func TestOriginalFixtures(t *testing.T) {
	var (
		tenant = "3" // A sample index
		ctx    = context.Background()
	)

	rr, rw, _, err := local.New(&local.Config{
		Path: "./test-data",
	})
	require.NoError(t, err)

	var (
		_ = backend.NewWriter(rw)
		r = backend.NewReader(rr)
	)

	expectedDedicatedColumns := backend.DedicatedColumns{
		backend.DedicatedColumn{Scope: "span", Name: "db.statement", Type: "string"},
		backend.DedicatedColumn{Scope: "span", Name: "component", Type: "string"},
		backend.DedicatedColumn{Scope: "span", Name: "http.user_agent", Type: "string"},
		backend.DedicatedColumn{Scope: "span", Name: "otel.library.name", Type: "string"},
		backend.DedicatedColumn{Scope: "span", Name: "db.connection_string", Type: "string"},
		backend.DedicatedColumn{Scope: "span", Name: "organization", Type: "string"},
		backend.DedicatedColumn{Scope: "span", Name: "peer.address", Type: "string"},
		backend.DedicatedColumn{Scope: "span", Name: "net.peer.name", Type: "string"},
		backend.DedicatedColumn{Scope: "span", Name: "blockID", Type: "string"},
		backend.DedicatedColumn{Scope: "span", Name: "db.name", Type: "string"},
		backend.DedicatedColumn{Scope: "resource", Name: "host.name", Type: "string"},
		backend.DedicatedColumn{Scope: "resource", Name: "opencensus.exporterversion", Type: "string"},
		backend.DedicatedColumn{Scope: "resource", Name: "client-uuid", Type: "string"},
		backend.DedicatedColumn{Scope: "resource", Name: "ip", Type: "string"},
		backend.DedicatedColumn{Scope: "resource", Name: "database", Type: "string"},
		backend.DedicatedColumn{Scope: "resource", Name: "os.description", Type: "string"},
		backend.DedicatedColumn{Scope: "resource", Name: "process.runtime.description", Type: "string"},
		backend.DedicatedColumn{Scope: "resource", Name: "container.id", Type: "string"},
		backend.DedicatedColumn{Scope: "resource", Name: "slug", Type: "string"},
		backend.DedicatedColumn{Scope: "resource", Name: "module.path", Type: "string"},
	}

	i, err := r.TenantIndex(ctx, tenant)
	assert.NoError(t, err)
	assert.NotNil(t, i)
	assert.NotZero(t, i.CreatedAt)

	assert.Equal(t, 22435, len(i.Meta))
	assert.Equal(t, 3264, len(i.CompactedMeta))

	nonZeroMeta(t, i.Meta)
	for _, v := range i.Meta {
		assert.Equal(t, tenant, v.TenantID)
		assert.Equal(t, "vParquet4", v.Version)
		assert.NotZero(t, v.StartTime)
		assert.NotZero(t, v.EndTime)
		assert.Equal(t, 20, len(v.DedicatedColumns))
		assert.Equal(t, expectedDedicatedColumns, v.DedicatedColumns)
	}

	nonZeroCompactedMeta(t, i.CompactedMeta)