github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-23 11:50:44 +00:00
Code Issues Projects Releases Wiki Activity

test service shard recreation when deleted from federated cluster

Browse Source
This commit is contained in:
shashidharatd 2017-02-08 18:00:45 +05:30
parent a152b9919a
commit 2226625c15
1 changed files with 32 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
test/e2e_federation/service.go
View File

@ -144,6 +144,28 @@ var _ = framework.KubeDescribe("Federated Services [Feature:Federation]", func()
verifyCascadingDeletionForService(f.FederationClientset, clusters, nil, nsName) verifyCascadingDeletionForService(f.FederationClientset, clusters, nil, nsName)
By(fmt.Sprintf("Verified that services were not deleted from underlying clusters")) By(fmt.Sprintf("Verified that services were not deleted from underlying clusters"))
}) })
It("should recreate service shard in underlying clusters when service shard is deleted", func() {
fedframework.SkipUnlessFederated(f.ClientSet)
service = createServiceOrFail(f.FederationClientset, nsName, FederatedServiceName)
defer func() {
// Cleanup
By(fmt.Sprintf("Deleting service %q in namespace %q", service.Name, nsName))
err := f.FederationClientset.Services(nsName).Delete(service.Name, &metav1.DeleteOptions{})
framework.ExpectNoError(err, "Error deleting service %q in namespace %q", service.Name, nsName)
}()
By(fmt.Sprintf("Wait for service shards to be created in all clusters for service \"%s/%s\"", nsName, service.Name))
waitForServiceShardsOrFail(nsName, service, clusters)
framework.Logf("Successfully created and synced service \"%s/%s\" to all clusters", nsName, service.Name)
By(fmt.Sprintf("Deleting a service shard in one underlying cluster"))
primaryClusterName := clusters[0].Name
err := deleteServiceShard(clusters[0], nsName, FederatedServiceName)
framework.ExpectNoError(err, fmt.Sprintf("while deleting service shard %q in cluster %q", FederatedServiceName, primaryClusterName))
waitForServiceShardsOrFail(nsName, service, clusters)
framework.Logf("Successfully recreated service shard \"%s/%s\" in %q cluster", nsName, service.Name, primaryClusterName)
})
}) })
var _ = Describe("DNS", func() { var _ = Describe("DNS", func() {
@ -345,6 +367,16 @@ func updateServiceOrFail(clientset *fedclientset.Clientset, namespace, name stri
return newService return newService
} }
func deleteServiceShard(c *fedframework.Cluster, namespace, service string) error {
err := c.Clientset.Services(namespace).Delete(service, &metav1.DeleteOptions{})
if err != nil && !errors.IsNotFound(err) {
framework.Logf("Failed to delete service %q in namespace %q, in cluster %q", service, namespace, c.Name)
return err
}
By(fmt.Sprintf("Service %q in namespace %q in cluster %q deleted", service, namespace, c.Name))
return nil
}
// equivalent returns true if the two services are equivalent. Fields which are expected to differ between // equivalent returns true if the two services are equivalent. Fields which are expected to differ between
// federated services and the underlying cluster services (e.g. ClusterIP, NodePort) are ignored. // federated services and the underlying cluster services (e.g. ClusterIP, NodePort) are ignored.
func equivalent(federationService, clusterService v1.Service) bool { func equivalent(federationService, clusterService v1.Service) bool {