Implement multi-port Services

cluster/addons/cluster-monitoring/v1beta3/grafana-service.yaml

@@ -6,8 +6,9 @@ metadata:
     kubernetes.io/cluster-service: "true"
   name: monitoring-grafana
 spec: 
-  targetPort: 80
-  port: 80
+  ports:
+    - port: 80
+      targetPort: 80
   selector: 
     name: influxGrafana
     kubernetes.io/cluster-service: "true"

cluster/addons/cluster-monitoring/v1beta3/heapster-service.yaml

@@ -6,8 +6,9 @@ metadata:
     kubernetes.io/cluster-service: "true"
   name: monitoring-heapster
 spec: 
-  targetPort: 8082
-  port: 80
+  ports:
+    - port: 80
+      targetPort: 8082
   selector: 
     name: heapster
     kubernetes.io/cluster-service: "true"

cluster/addons/cluster-monitoring/v1beta3/influxdb-service.yaml

@@ -5,8 +5,9 @@ metadata:
     name: influxGrafana
   name: monitoring-influxdb
 spec: 
-  targetPort: 8086
-  port: 80
+  ports:
+    - port: 80
+      targetPort: 8086
   selector: 
     name: influxGrafana
 

cluster/addons/cluster-monitoring/v1beta3/influxdb-ui-service.yaml

@@ -5,8 +5,9 @@ metadata:
     name: influxGrafana
   name: monitoring-influxdb-ui
 spec: 
-  targetPort: 8083
-  port: 80
+  ports:
+    - port: 80
+      targetPort: 8083
   selector: 
     name: influxGrafana
 

cluster/addons/dns/kube2sky/kube2sky.go

@@ -57,22 +57,27 @@ func addDNS(record string, service *kapi.Service, etcdClient *etcd.Client) error
 		return nil
 	}
 
-	svc := skymsg.Service{
-		Host:     service.Spec.PortalIP,
-		Port:     service.Spec.Port,
-		Priority: 10,
-		Weight:   10,
-		Ttl:      30,
-	}
-	b, err := json.Marshal(svc)
-	if err != nil {
-		return err
-	}
-	// Set with no TTL, and hope that kubernetes events are accurate.
+	for i := range service.Spec.Ports {
+		svc := skymsg.Service{
+			Host:     service.Spec.PortalIP,
+			Port:     service.Spec.Ports[i].Port,
+			Priority: 10,
+			Weight:   10,
+			Ttl:      30,
+		}
+		b, err := json.Marshal(svc)
+		if err != nil {
+			return err
+		}
+		// Set with no TTL, and hope that kubernetes events are accurate.
 
-	log.Printf("Setting dns record: %v -> %s:%d\n", record, service.Spec.PortalIP, service.Spec.Port)
-	_, err = etcdClient.Set(skymsg.Path(record), string(b), uint64(0))
-	return err
+		log.Printf("Setting DNS record: %v -> %s:%d\n", record, service.Spec.PortalIP, service.Spec.Ports[i].Port)
+		_, err = etcdClient.Set(skymsg.Path(record), string(b), uint64(0))
+		if err != nil {
+			return err
+		}
+	}
+	return nil
 }
 
 // Implements retry logic for arbitrary mutator. Crashes after retrying for

cmd/integration/integration.go

@@ -465,12 +465,14 @@ func runSelfLinkTestOnNamespace(c *client.Client, namespace string) {
 			},
 		},
 		Spec: api.ServiceSpec{
-			Port: 12345,
 			// This is here because validation requires it.
 			Selector: map[string]string{
 				"foo": "bar",
 			},
-			Protocol:        "TCP",
+			Ports: []api.ServicePort{{
+				Port:     12345,
+				Protocol: "TCP",
+			}},
 			SessionAffinity: "None",
 		},
 	}
@@ -527,12 +529,14 @@ func runAtomicPutTest(c *client.Client) {
 			},
 		},
 		Spec: api.ServiceSpec{
-			Port: 12345,
 			// This is here because validation requires it.
 			Selector: map[string]string{
 				"foo": "bar",
 			},
-			Protocol:        "TCP",
+			Ports: []api.ServicePort{{
+				Port:     12345,
+				Protocol: "TCP",
+			}},
 			SessionAffinity: "None",
 		},
 	}
@@ -606,12 +610,14 @@ func runPatchTest(c *client.Client) {
 			},
 		},
 		Spec: api.ServiceSpec{
-			Port: 12345,
 			// This is here because validation requires it.
 			Selector: map[string]string{
 				"foo": "bar",
 			},
-			Protocol:        "TCP",
+			Ports: []api.ServicePort{{
+				Port:     12345,
+				Protocol: "TCP",
+			}},
 			SessionAffinity: "None",
 		},
 	}
@@ -747,8 +753,10 @@ func runServiceTest(client *client.Client) {
 			Selector: map[string]string{
 				"name": "thisisalonglabel",
 			},
-			Port:            8080,
-			Protocol:        "TCP",
+			Ports: []api.ServicePort{{
+				Port:     8080,
+				Protocol: "TCP",
+			}},
 			SessionAffinity: "None",
 		},
 	}
@@ -764,8 +772,10 @@ func runServiceTest(client *client.Client) {
 			Selector: map[string]string{
 				"name": "thisisalonglabel",
 			},
-			Port:            8080,
-			Protocol:        "TCP",
+			Ports: []api.ServicePort{{
+				Port:     8080,
+				Protocol: "TCP",
+			}},
 			SessionAffinity: "None",
 		},
 	}
@@ -784,8 +794,10 @@ func runServiceTest(client *client.Client) {
 			Selector: map[string]string{
 				"name": "thisisalonglabel",
 			},
-			Port:            8080,
-			Protocol:        "TCP",
+			Ports: []api.ServicePort{{
+				Port:     8080,
+				Protocol: "TCP",
+			}},
 			SessionAffinity: "None",
 		},
 	}

contrib/for-tests/network-tester/service.json

@@ -8,11 +8,15 @@
     }
   },
   "spec": {
-    "port": 8080,
-    "protocol": "TCP",
+    "ports": [
+      {
+        "port": 8080,
+        "protocol": "TCP",
+        "targetPort": 8080
+      }
+    ],
     "selector": {
       "name": "nettest"
-    },
-    "targetPort": 8080,
+    }
   }
 }

examples/cassandra/v1beta3/cassandra-service.yaml

@@ -5,7 +5,8 @@ metadata:
     name: cassandra
   name: cassandra
 spec: 
-  targetPort: 9042
-  port: 9042
+  ports:
+    - port: 9042
+      targetPort: 9042
   selector: 
     name: cassandra

examples/guestbook-go/v1beta3/guestbook-service.json

@@ -8,9 +8,13 @@
       }
    },
    "spec":{
-      "port":3000,
-      "containerPort":"http-server",
-      "protocol":"TCP",
+      "ports": [
+         {
+           "port":3000,
+           "targetPort":"http-server",
+           "protocol":"TCP"
+         }
+      ],
       "selector":{
          "name":"guestbook"
       }

examples/guestbook-go/v1beta3/redis-master-service.json

@@ -9,9 +9,13 @@
       }
    },
    "spec":{
-      "port":6379,
-      "containerPort":"redis-server",
-      "protocol":"TCP",
+      "ports": [
+        {
+          "port":6379,
+          "targetPort":"redis-server",
+          "protocol":"TCP"
+        }
+      ],
       "selector":{
          "name":"redis",
          "role":"master"

examples/guestbook-go/v1beta3/redis-slave-service.json

@@ -9,9 +9,13 @@
       }
    },
    "spec":{
-      "port":6379,
-      "containerPort":"redis-server",
-      "protocol":"TCP",
+      "ports": [
+        {
+          "port":6379,
+          "targetPort":"redis-server",
+          "protocol":"TCP"
+        }
+      ],
       "selector":{
          "name":"redis",
          "role":"slave"

examples/guestbook/v1beta3/frontend-service.json

@@ -8,9 +8,13 @@
       }
    },
    "spec":{
-      "port":80,
-      "containerPort":80,
-      "protocol":"TCP",
+      "ports": [
+        {
+          "port":80,
+          "targetPort":80,
+          "protocol":"TCP"
+        }
+      ],
       "selector":{
          "name":"frontend"
       }

examples/guestbook/v1beta3/redis-master-service.json

@@ -8,9 +8,13 @@
       }
    },
    "spec":{
-      "port":6379,
-      "containerPort":6379,
-      "protocol":"TCP",
+      "ports": [
+        {
+          "port":6379,
+          "targetPort":6379,
+          "protocol":"TCP"
+        }
+      ],
       "selector":{
          "name":"redis-master"
       }

examples/guestbook/v1beta3/redis-slave-service.json

@@ -8,9 +8,13 @@
       }
    },
    "spec":{
-      "port":6379,
-      "containerPort":6379,
-      "protocol":"TCP",
+      "ports": [
+        {
+          "port":6379,
+          "targetPort":6379,
+          "protocol":"TCP"
+        }
+      ],
       "selector":{
          "name":"redis-slave"
       }

examples/hazelcast/v1beta3/hazelcast-service.yaml

@@ -5,7 +5,8 @@ metadata:
     name: hazelcast
   name: hazelcast
 spec: 
-  targetPort: 5701
-  port: 5701
+  ports:
+    - port: 5701
+      targetPort: 5701
   selector: 
     name: hazelcast

examples/mysql-wordpress-pd/v1beta3/mysql-service.yaml

@@ -5,8 +5,9 @@ metadata:
     name: mysql
   name: mysql
 spec: 
-  targetPort: 3306
-  port: 3306
+  ports:
+    - port: 3306
+      targetPort: 3306
   selector: 
     name: mysql
 

examples/mysql-wordpress-pd/v1beta3/wordpress-service.yaml

@@ -5,8 +5,9 @@ metadata:
     name: wpfrontend
   name: wpfrontend
 spec: 
-  targetPort: 80
-  port: 80
+  ports:
+    - port: 80
+      targetPort: 80
   selector: 
     name: wpfrontend
 

examples/redis/v1beta3/redis-sentinel-service.yaml

@@ -6,7 +6,8 @@ metadata:
     role: service
   name: redis-sentinel
 spec:
-  targetPort: 26379
-  port: 26379
+  ports:
+    - port: 26379
+      targetPort: 26379
   selector:
     redis-sentinel: "true"

examples/rethinkdb/v1beta3/admin-service.yaml

@@ -6,8 +6,9 @@ metadata:
   name: rethinkdb-admin
   namespace: rethinkdb
 spec:
-  targetPort: 8080
-  port: 8080
+  ports:
+   - port: 8080
+     targetPort: 8080
   selector:
     db: rethinkdb
     role: admin

examples/rethinkdb/v1beta3/driver-service.yaml

@@ -6,7 +6,8 @@ metadata:
   name: rethinkdb-driver
   namespace: rethinkdb
 spec:
-  targetPort: 28015
-  port: 28015
+  ports:
+    - port: 28015
+      targetPort: 28015
   selector:
     db: rethinkdb