ic.createKubeService(t, c)
	ic.createServiceImport(t, mcsapi.ClusterSetIP, serviceImportVIPs)
	ic.checkServiceInstances(t)

	// Update the k8s service and verify that both services are updated.
	ic.updateKubeService(t)
}

func TestHeadlessServiceImported(t *testing.T) {
	// Create and run the controller.
	c, ic := newTestServiceImportCache(t)

	ic.createKubeService(t, c)