@Test public void testLoad() { ClusterTopology clusterTopology = clusterService.getClusterTopology(); if(clusterTopology == null) { System.out.println(String.format("cluster %s is null", clusterId)); } else { System.out.println(clusterId); System.out.println(clusterTopology.toString()); } }
public ClusterTopology getClusterTopology() { return clusterTopology; }
ClusterService extends AbstractClusterService { public ClusterTopology getClusterTopology() { return clusterTopology; } }
ClusterService extends AbstractClusterService { public ClusterTopology getClusterTopology() { return clusterTopology; } ClusterService(String clusterId, Environment environment, Settings settings); }
ClusterService extends AbstractClusterService { public ClusterTopology getClusterTopology() { return clusterTopology; } ClusterService(String clusterId, Environment environment, Settings settings); String getDomainName(); boolean shutdownCluster(); CloudWatcher getCloudWatcher(); List<CommonInstance> addSlaveNode(int incrementSize); CommonInstance removeSlaveNode(String instanceId); void updateInstances(); void rebootInstances(boolean waitUntilInstanceAvailable); void rebootInstances(String role, boolean waitUntilInstanceAvailable); void rebootInstances(List<CommonInstance> instanceList, boolean waitUntilInstanceAvailable); void loadClusterTopology(); IaasProvider getIaasProvider(); ClusterDefinition getClusterDefinition(); ClusterTopology getClusterTopology(); HAProxyAPI getProxyAPI(); MesosAPI getMesosAPI(); MarathonAPI getMarathonAPI(); DockerAPI getDockerAPI(); }
ClusterService extends AbstractClusterService { public ClusterTopology getClusterTopology() { return clusterTopology; } ClusterService(String clusterId, Environment environment, Settings settings); String getDomainName(); boolean shutdownCluster(); CloudWatcher getCloudWatcher(); List<CommonInstance> addSlaveNode(int incrementSize); CommonInstance removeSlaveNode(String instanceId); void updateInstances(); void rebootInstances(boolean waitUntilInstanceAvailable); void rebootInstances(String role, boolean waitUntilInstanceAvailable); void rebootInstances(List<CommonInstance> instanceList, boolean waitUntilInstanceAvailable); void loadClusterTopology(); IaasProvider getIaasProvider(); ClusterDefinition getClusterDefinition(); ClusterTopology getClusterTopology(); HAProxyAPI getProxyAPI(); MesosAPI getMesosAPI(); MarathonAPI getMarathonAPI(); DockerAPI getDockerAPI();  }