populating member lists after restarting
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/d6022955 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/d6022955 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/d6022955 Branch: refs/heads/master Commit: d6022955b22c9309507a114402c717d1b6d0a136 Parents: 60b4697 Author: R-Rajkumar <[email protected]> Authored: Thu Sep 25 21:08:19 2014 +0530 Committer: R-Rajkumar <[email protected]> Committed: Thu Sep 25 21:08:19 2014 +0530 ---------------------------------------------------------------------- .../autoscaler/monitor/ClusterMonitorFactory.java | 15 +++++++++++++++ 1 file changed, 15 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/d6022955/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/ClusterMonitorFactory.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/ClusterMonitorFactory.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/ClusterMonitorFactory.java index 39494dc..156b6d2 100644 --- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/ClusterMonitorFactory.java +++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/ClusterMonitorFactory.java @@ -318,6 +318,21 @@ public class ClusterMonitorFactory { dockerClusterMonitor.setStatus(ClusterStatus.Created); + for (Member member : cluster.getMembers()) { + String memberId = member.getMemberId(); + String clusterId = member.getClusterId(); + MemberContext memberContext = new MemberContext(); + memberContext.setMemberId(memberId); + memberContext.setClusterId(clusterId); + + if (MemberStatus.Activated.equals(member.getStatus())) { + dockerClusterMonitor.getKubernetesClusterCtxt().addActiveMember(memberContext); + } else if (MemberStatus.Created.equals(member.getStatus()) + || MemberStatus.Starting.equals(member.getStatus())) { + dockerClusterMonitor.getKubernetesClusterCtxt().addPendingMember(memberContext); + } + } + // find lb reference type if(props.containsKey(Constants.LOAD_BALANCER_REF)) { String value = props.getProperty(Constants.LOAD_BALANCER_REF);
