github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-05 10:19:50 +00:00
Code Issues Projects Releases Wiki Activity

Use non-fed client for subclusters in federated namespace e2e test

Browse Source
This commit is contained in:
Marcin Wielgus 2016-08-25 10:26:08 +02:00
parent c5e7e5124a
commit 99cb1d7702
1 changed files with 22 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
test/e2e/federated-namespace.go
View File

@ -22,10 +22,10 @@ import (
"time" "time"
"k8s.io/kubernetes/federation/client/clientset_generated/federation_release_1_4" "k8s.io/kubernetes/federation/client/clientset_generated/federation_release_1_4"
"k8s.io/kubernetes/federation/pkg/federation-controller/util"
"k8s.io/kubernetes/pkg/api" "k8s.io/kubernetes/pkg/api"
"k8s.io/kubernetes/pkg/api/errors" "k8s.io/kubernetes/pkg/api/errors"
api_v1 "k8s.io/kubernetes/pkg/api/v1" api_v1 "k8s.io/kubernetes/pkg/api/v1"
"k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3"
"k8s.io/kubernetes/pkg/util/wait" "k8s.io/kubernetes/pkg/util/wait"
"k8s.io/kubernetes/test/e2e/framework" "k8s.io/kubernetes/test/e2e/framework"
@ -39,7 +39,7 @@ const (
// Create/delete ingress api objects // Create/delete ingress api objects
var _ = framework.KubeDescribe("Federation namespace [Feature:Federation]", func() { var _ = framework.KubeDescribe("Federation namespace [Feature:Federation]", func() {
f := framework.NewDefaultFederatedFramework("federation-namespace") f := framework.NewDefaultFederatedFramework("federation-namespace")
clusterClientSet := make(map[string]*federation_release_1_4.Clientset) clusterClientSet := make(map[string]*release_1_3.Clientset)
Describe("Namespace objects", func() { Describe("Namespace objects", func() {
BeforeEach(func() { BeforeEach(func() {
@ -47,10 +47,7 @@ var _ = framework.KubeDescribe("Federation namespace [Feature:Federation]", func
clusters := buildClustersOrFail_14(f) clusters := buildClustersOrFail_14(f)
for _, cluster := range clusters { for _, cluster := range clusters {
if _, found := clusterClientSet[cluster.Name]; !found { if _, found := clusterClientSet[cluster.Name]; !found {
clientset, err := util.GetClientsetForCluster(cluster) clientset := createClientsetForCluster(*cluster, 1, "e2e-test")
if err != nil {
framework.Failf("Failed to create client for %s: %v", cluster.Name, err)
}
clusterClientSet[cluster.Name] = clientset clusterClientSet[cluster.Name] = clientset
} }
} }
@ -58,9 +55,9 @@ var _ = framework.KubeDescribe("Federation namespace [Feature:Federation]", func
AfterEach(func() { AfterEach(func() {
framework.SkipUnlessFederated(f.Client) framework.SkipUnlessFederated(f.Client)
deleteAllTestNamespaces(f.FederationClientset_1_4) deleteAllTestNamespacesFed14(f.FederationClientset_1_4)
for _, clientset := range clusterClientSet { for _, clientset := range clusterClientSet {
deleteAllTestNamespaces(clientset) deleteAllTestNamespaces13(clientset)
} }
}) })
@ -97,7 +94,23 @@ var _ = framework.KubeDescribe("Federation namespace [Feature:Federation]", func
}) })
}) })
func deleteAllTestNamespaces(clientset *federation_release_1_4.Clientset) { func deleteAllTestNamespacesFed14(clientset *federation_release_1_4.Clientset) {
list, err := clientset.Core().Namespaces().List(api.ListOptions{})
if err != nil {
framework.Failf("Failed to get all namespaes: %v", err)
return
}
for _, namespace := range list.Items {
if strings.HasPrefix(namespace.Name, namespacePrefix) {
err := clientset.Core().Namespaces().Delete(namespace.Name, &api.DeleteOptions{})
if err != nil {
framework.Failf("Failed to delete %s: %v", namespace.Name, err)
}
}
}
}
func deleteAllTestNamespaces13(clientset *release_1_3.Clientset) {
list, err := clientset.Core().Namespaces().List(api.ListOptions{}) list, err := clientset.Core().Namespaces().List(api.ListOptions{})
if err != nil { if err != nil {
framework.Failf("Failed to get all namespaes: %v", err) framework.Failf("Failed to get all namespaes: %v", err)