host: productpage
  trafficPolicy:
    tls:
      mode: ISTIO_MUTUAL
  subsets:
  - name: %s
    labels:
      version: %s`
		config := fmt.Sprintf(configTemplate, version, version, version)
		err := src.ApplyContent("test", config)
		g.Expect(err).To(BeNil())
		existing := src.Get(gvk.DestinationRule, "productpage", "")
		g.Expect(existing.Labels["version"]).To(Equal(version))
	}

	// Apply v1 config
	applyAndValidate("v1")

	}
	// Gather test files
	src := file.NewKubeSource(collections.All)
	for i, yamlFile := range yamls {
		data, err := os.ReadFile(yamlFile)
		if err != nil {
			return err
		}
		err = src.ApplyContent(fmt.Sprintf("%d", i), string(data))
		if err != nil {
			return err
		}
	}
	sa.AddSourceForCluster(src, cluster.ID(clusterName))
	sa.AddRunningKubeSourceWithRevision(client, clusterName, false)
	return nil