commit 2cc2b631f3a9ca71f14f4b87cba77de3450efb70
author Jian Li <pyguni@gmail.com> Mon Feb 18 00:56:40 2019 +0900
committer Jian Li <pyguni@gmail.com> Wed Mar 06 05:28:38 2019 +0000
tree 5eb00ff7609ae3a41d9f91f204c8d0770ea14c8e
parent 3d1111e2a8999a1c876a3eb8488b1cf9c22b2c68

Initial implementation of  svc IP to pod IP translation using DNAT

Change-Id: I6e2f6936636e929ad60150cc67aa6316eef32911

apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/cli/K8sServiceListCommand.java

diff --git a/apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/cli/K8sServiceListCommand.java b/apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/cli/K8sServiceListCommand.java
index 800a1ab..ade0b01 100644
--- a/apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/cli/K8sServiceListCommand.java
+++ b/apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/cli/K8sServiceListCommand.java
@@ -33,6 +33,7 @@
 public class K8sServiceListCommand extends AbstractShellCommand {
 
     private static final String FORMAT = "%-50s%-30s%-30s";
+    private static final String PORT_PROTOCOL_SEPARATOR = "/";
 
     @Override
     protected void doExecute() {
@@ -45,14 +46,16 @@
 
         for (io.fabric8.kubernetes.api.model.Service svc : services) {
 
-            List<Integer> ports = Lists.newArrayList();
+            List<String> portWithProtocol = Lists.newArrayList();
 
-            svc.getSpec().getPorts().forEach(p -> ports.add(p.getPort()));
+            svc.getSpec().getPorts().forEach(p ->
+                    portWithProtocol.add(p.getPort() +
+                    PORT_PROTOCOL_SEPARATOR + p.getProtocol()));
 
             print(FORMAT,
                     svc.getMetadata().getName(),
                     svc.getSpec().getClusterIP(),
-                    ports.isEmpty() ? "" : ports);
+                    portWithProtocol.isEmpty() ? "" : portWithProtocol);
         }
     }
 }