Repository: stratos Updated Branches: refs/heads/master 3c880b65e -> fa139b0d4
Fixing public ip addresses used in kubernetes service creation Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/fa139b0d Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/fa139b0d Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/fa139b0d Branch: refs/heads/master Commit: fa139b0d4b18fdb2607922905769e712cb17a8e0 Parents: 3c880b6 Author: Imesh Gunaratne <[email protected]> Authored: Thu May 14 19:59:22 2015 +0530 Committer: Imesh Gunaratne <[email protected]> Committed: Thu May 14 19:59:42 2015 +0530 ---------------------------------------------------------------------- .../cloud/controller/iaases/kubernetes/KubernetesIaas.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/fa139b0d/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/iaases/kubernetes/KubernetesIaas.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/iaases/kubernetes/KubernetesIaas.java b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/iaases/kubernetes/KubernetesIaas.java index fe4f1ba..b756121 100644 --- a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/iaases/kubernetes/KubernetesIaas.java +++ b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/iaases/kubernetes/KubernetesIaas.java @@ -438,7 +438,7 @@ public class KubernetesIaas extends Iaas { } // Prepare minion public IP addresses - List<String> minionPublicIPs = new ArrayList<String>(); + List<String> minionPrivateIPList = new ArrayList<String>(); KubernetesHost[] kubernetesHosts = kubernetesCluster.getKubernetesHosts(); if ((kubernetesHosts == null) || (kubernetesHosts.length == 0) || (kubernetesHosts[0] == null)) { throw new RuntimeException("Hosts not found in kubernetes cluster: [cluster] " @@ -446,11 +446,11 @@ public class KubernetesIaas extends Iaas { } for (KubernetesHost host : kubernetesHosts) { if (host != null) { - minionPublicIPs.add(host.getPublicIPAddress()); + minionPrivateIPList.add(host.getPrivateIPAddress()); } } if (log.isDebugEnabled()) { - log.debug(String.format("Minion public IPs: %s", minionPublicIPs)); + log.debug(String.format("Minion private IPs: %s", minionPrivateIPList)); } if (cartridge.getPortMappings() != null) { @@ -481,7 +481,7 @@ public class KubernetesIaas extends Iaas { try { kubernetesApi.createService(serviceId, serviceLabel, servicePort, containerPortName, - minionPublicIPs.toArray(new String[minionPublicIPs.size()])); + minionPrivateIPList.toArray(new String[minionPrivateIPList.size()])); } finally { // Persist kubernetes service sequence no CloudControllerContext.getInstance().persist();
