Merge pull request #7822 from thockin/dns

DNS: expose 53/TCP

cluster/addons/dns/skydns-rc.yaml.in

@@ -1,11 +1,11 @@
 apiVersion: v1beta3
 kind: ReplicationController
 metadata:
+  name: kube-dns
+  namespace: default
   labels:
     k8s-app: kube-dns
     kubernetes.io/cluster-service: "true"
-  name: kube-dns
-  namespace: default
 spec:
   replicas: {{ pillar['dns_replicas'] }}
   selector:
@@ -15,7 +15,6 @@ spec:
       labels:
         k8s-app: kube-dns
         kubernetes.io/cluster-service: "true"
-        name: kube-dns
     spec:
       containers:
       - name: etcd
@@ -31,7 +30,7 @@ spec:
       - name: kube2sky
         image: gcr.io/google_containers/kube2sky:1.4
         args:
-        # entrypoint = "/kube2sky"
+        # command = "/kube2sky"
         - -domain={{ pillar['dns_domain'] }}
         - -kubecfg_file=/etc/dns_token/kubeconfig
         volumeMounts:
@@ -41,7 +40,7 @@ spec:
       - name: skydns
         image: gcr.io/google_containers/skydns:2015-03-11-001
         args:
-        # entrypoint = "/skydns"
+        # command = "/skydns"
         - -machines=http://localhost:4001
         - -addr=0.0.0.0:53
         - -domain={{ pillar['dns_domain'] }}.
@@ -49,6 +48,9 @@ spec:
         - containerPort: 53
           name: dns
           protocol: UDP
+        - containerPort: 53
+          name: dns-tcp
+          protocol: TCP
         livenessProbe:
           exec:
             command:

cluster/addons/dns/skydns-svc.yaml.in

@@ -1,14 +1,19 @@
+apiVersion: v1beta3
 kind: Service
-apiVersion: v1beta1
+metadata:
-id: kube-dns
-namespace: default
-protocol: UDP
-port: 53
-portalIP: {{ pillar['dns_server'] }}
-containerPort: 53
-labels:
-  k8s-app: kube-dns
   name: kube-dns
-  kubernetes.io/cluster-service: "true"
+  namespace: default
-selector:
+  labels:
-  k8s-app: kube-dns
+    k8s-app: kube-dns
+    kubernetes.io/cluster-service: "true"
+spec:
+  selector:
+    k8s-app: kube-dns
+  portalIP:  {{ pillar['dns_server'] }}
+  ports:
+  - name: dns
+    port: 53
+    protocol: UDP
+  - name: dns-tcp
+    port: 53
+    protocol: TCP

contrib/for-tests/dnsutils/Dockerfile

@@ -0,0 +1,6 @@
+FROM debian:wheezy
+MAINTAINER Tim Hockin "thockin@google.com"
+
+RUN apt-get -q update && \
+    apt-get install -y dnsutils && \
+    apt-get clean

contrib/for-tests/dnsutils/Makefile

@@ -0,0 +1,8 @@
+all:
+	@echo "try 'make image' or 'make push'"
+
+image:
+	docker build -t gcr.io/google_containers/dnsutils .
+
+push:
+	gcloud preview docker push gcr.io/google_containers/dnsutils

test/e2e/service.go

@@ -67,7 +67,9 @@ var _ = Describe("Services", func() {
 
 		probeCmd := "for i in `seq 1 600`; do "
 		for _, name := range namesToResolve {
-			probeCmd += fmt.Sprintf("wget -O /dev/null %s && echo OK > /results/%s;", name, name)
+			// Resolve by TCP and UDP DNS.
+			probeCmd += fmt.Sprintf(`test -n "$(dig +notcp +noall +answer +search %s)" && echo OK > /results/udp@%s;`, name, name)
+			probeCmd += fmt.Sprintf(`test -n "$(dig +tcp +noall +answer +search %s)" && echo OK > /results/tcp@%s;`, name, name)
 		}
 		probeCmd += "sleep 1; done"
 
@@ -102,8 +104,8 @@ var _ = Describe("Services", func() {
 						},
 					},
 					{
-						Name:    "pinger",
+						Name:    "querier",
-						Image:   "gcr.io/google_containers/busybox",
+						Image:   "gcr.io/google_containers/dnsutils",
 						Command: []string{"sh", "-c", probeCmd},
 						VolumeMounts: []api.VolumeMount{
 							{
@@ -141,16 +143,18 @@ var _ = Describe("Services", func() {
 		expectNoError(wait.Poll(time.Second*2, time.Second*60, func() (bool, error) {
 			failed = []string{}
 			for _, name := range namesToResolve {
-				_, err := c.Get().
+				for _, proto := range []string{"udp", "tcp"} {
-					Prefix("proxy").
+					testCase := fmt.Sprintf("%s@%s", proto, name)
-					Resource("pods").
+					_, err := c.Get().
-					Namespace(api.NamespaceDefault).
+						Prefix("proxy").
-					Name(pod.Name).
+						Resource("pods").
-					Suffix("results", name).
+						Namespace(api.NamespaceDefault).
-					Do().Raw()
+						Name(pod.Name).
-				if err != nil {
+						Suffix("results", testCase).
-					failed = append(failed, name)
+						Do().Raw()
-					Logf("Lookup using %s for %s failed: %v\n", pod.Name, name, err)
+					if err != nil {
+						failed = append(failed, testCase)
+					}
 				}
 			}
 			if len(failed) == 0 {