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

dns test uses framework

Browse Source
This commit is contained in:
Daniel Smith
2015-05-22 13:03:01 -07:00
parent 0387283143
commit 11087d13b4
1 changed files with 8 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
test/e2e/dns.go
View File

@@ -22,7 +22,6 @@ import (
"github.com/GoogleCloudPlatform/kubernetes/pkg/api" "github.com/GoogleCloudPlatform/kubernetes/pkg/api"
"github.com/GoogleCloudPlatform/kubernetes/pkg/api/latest" "github.com/GoogleCloudPlatform/kubernetes/pkg/api/latest"
"github.com/GoogleCloudPlatform/kubernetes/pkg/client"
"github.com/GoogleCloudPlatform/kubernetes/pkg/fields" "github.com/GoogleCloudPlatform/kubernetes/pkg/fields"
"github.com/GoogleCloudPlatform/kubernetes/pkg/labels" "github.com/GoogleCloudPlatform/kubernetes/pkg/labels"
"github.com/GoogleCloudPlatform/kubernetes/pkg/util" "github.com/GoogleCloudPlatform/kubernetes/pkg/util"
@@ -38,25 +37,15 @@ var dnsServiceLableSelector = labels.Set{
}.AsSelector() }.AsSelector()
var _ = Describe("DNS", func() { var _ = Describe("DNS", func() {
var c *client.Client f := NewFramework("dns")
// Use this in tests. They're unique for each test to prevent name collisions.
var testNamespace string
BeforeEach(func() {
var err error
c, err = loadClient()
Expect(err).NotTo(HaveOccurred())
ns, err := createTestingNS("dns", c)
Expect(err).NotTo(HaveOccurred())
testNamespace = ns.Name
})
It("should provide DNS for the cluster", func() { It("should provide DNS for the cluster", func() {
if providerIs("vagrant") { if providerIs("vagrant") {
By("Skipping test which is broken for vagrant (See https://github.com/GoogleCloudPlatform/kubernetes/issues/3580)") By("Skipping test which is broken for vagrant (See https://github.com/GoogleCloudPlatform/kubernetes/issues/3580)")
return return
} }
podClient := c.Pods(api.NamespaceDefault) podClient := f.Client.Pods(api.NamespaceDefault)
By("Waiting for DNS Service to be Running") By("Waiting for DNS Service to be Running")
dnsPods, err := podClient.List(dnsServiceLableSelector, fields.Everything()) dnsPods, err := podClient.List(dnsServiceLableSelector, fields.Everything())
@@ -66,7 +55,7 @@ var _ = Describe("DNS", func() {
if len(dnsPods.Items) != 1 { if len(dnsPods.Items) != 1 {
Failf("Unexpected number of pods (%d) matches the label selector %v", len(dnsPods.Items), dnsServiceLableSelector.String()) Failf("Unexpected number of pods (%d) matches the label selector %v", len(dnsPods.Items), dnsServiceLableSelector.String())
} }
expectNoError(waitForPodRunning(c, dnsPods.Items[0].Name)) expectNoError(waitForPodRunning(f.Client, dnsPods.Items[0].Name))
// All the names we need to be able to resolve. // All the names we need to be able to resolve.
// TODO: Spin up a separate test service and test that dns works for that service. // TODO: Spin up a separate test service and test that dns works for that service.
@@ -99,7 +88,7 @@ var _ = Describe("DNS", func() {
}, },
ObjectMeta: api.ObjectMeta{ ObjectMeta: api.ObjectMeta{
Name: "dns-test-" + string(util.NewUUID()), Name: "dns-test-" + string(util.NewUUID()),
Namespace: testNamespace, Namespace: f.Namespace.Name,
}, },
Spec: api.PodSpec{ Spec: api.PodSpec{
Volumes: []api.Volume{ Volumes: []api.Volume{
@@ -138,7 +127,7 @@ var _ = Describe("DNS", func() {
} }
By("submitting the pod to kubernetes") By("submitting the pod to kubernetes")
podClient = c.Pods(testNamespace) podClient = f.Client.Pods(f.Namespace.Name)
defer func() { defer func() {
By("deleting the pod") By("deleting the pod")
defer GinkgoRecover() defer GinkgoRecover()
@@ -148,7 +137,7 @@ var _ = Describe("DNS", func() {
Failf("Failed to create %s pod: %v", pod.Name, err) Failf("Failed to create %s pod: %v", pod.Name, err)
} }
expectNoError(waitForPodRunningInNamespace(c, pod.Name, testNamespace)) expectNoError(f.WaitForPodRunning(pod.Name))
By("retrieving the pod") By("retrieving the pod")
pod, err = podClient.Get(pod.Name) pod, err = podClient.Get(pod.Name)
@@ -165,10 +154,10 @@ var _ = Describe("DNS", func() {
for _, name := range namesToResolve { for _, name := range namesToResolve {
for _, proto := range []string{"udp", "tcp"} { for _, proto := range []string{"udp", "tcp"} {
testCase := fmt.Sprintf("%s@%s", proto, name) testCase := fmt.Sprintf("%s@%s", proto, name)
_, err := c.Get(). _, err := f.Client.Get().
Prefix("proxy"). Prefix("proxy").
Resource("pods"). Resource("pods").
Namespace(testNamespace). Namespace(f.Namespace.Name).
Name(pod.Name). Name(pod.Name).
Suffix("results", testCase). Suffix("results", testCase).
Do().Raw() Do().Raw()