Function TestFixtures

tempodb/backend/test/backend_test.go:13–85

(t *testing.T)

)

func TestFixtures(t *testing.T) {
	var (
		tenant = "single-tenant"
		ctx    = context.Background()
	)

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

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

	_, err = r.TenantIndex(ctx, tenant)
	assert.NoError(t, err)

	// To regenerate the fixtures, uncomment the write path.
	// metas := []*backend.BlockMeta{
	// 	backend.NewBlockMeta(tenant, uuid.New(), "v1"),
	// 	backend.NewBlockMeta(tenant, uuid.New(), "v2"),
	// 	backend.NewBlockMeta(tenant, uuid.New(), "v3"),
	// 	backend.NewBlockMeta(tenant, uuid.New(), "v4"),
	// }
	//
	// for _, meta := range metas {
	// 	err = w.WriteBlockMeta(ctx, meta)
	// 	require.NoError(t, err)
	// }
	//
	// err = rc.MarkBlockCompacted((uuid.UUID)(metas[0].BlockID), tenant)
	// assert.NoError(t, err)

	listMetas, listCompactedMetas, err := rr.ListBlocks(ctx, tenant)
	require.NoError(t, err)
	require.Len(t, listCompactedMetas, 1)

	blockMetas := make([]*backend.BlockMeta, 0, len(listMetas))
	for _, u := range listMetas {
		m, e := r.BlockMeta(ctx, u, tenant)
		require.NoError(t, e)
		blockMetas = append(blockMetas, m)
		assert.Equal(t, tenant, m.TenantID)
	}

	compactedBlockMetas := make([]*backend.CompactedBlockMeta, 0, len(listCompactedMetas))
	for _, u := range listCompactedMetas {
		m, e := rc.CompactedBlockMeta(u, tenant)
		assert.NoError(t, e)
		compactedBlockMetas = append(compactedBlockMetas, m)
		assert.Equal(t, tenant, m.TenantID)
	}

	nonZeroMeta(t, blockMetas)
	nonZeroCompactedMeta(t, compactedBlockMetas)