@Test public void testDestroy() throws UnknownIaasProviderException { clusterService.destroyCluster(); }
protected boolean destroyCluster() { logger.info("Destroying cluster {}..", clusterId); unloadProxyWorker(); try { terminateInstances(); } catch (Exception e) { logger.error("error while stopping cluster service : " + clusterId, e); return false; } deleteClusterTopologyConfig(); return true; }
ClusterService extends AbstractClusterService { protected boolean destroyCluster() { logger.info("Destroying cluster {}..", clusterId); unloadProxyWorker(); try { terminateInstances(); } catch (Exception e) { logger.error("error while stopping cluster service : " + clusterId, e); return false; } deleteClusterTopologyConfig(); return true; } }
ClusterService extends AbstractClusterService { protected boolean destroyCluster() { logger.info("Destroying cluster {}..", clusterId); unloadProxyWorker(); try { terminateInstances(); } catch (Exception e) { logger.error("error while stopping cluster service : " + clusterId, e); return false; } deleteClusterTopologyConfig(); return true; } ClusterService(String clusterId, Environment environment, Settings settings); }
ClusterService extends AbstractClusterService { protected boolean destroyCluster() { logger.info("Destroying cluster {}..", clusterId); unloadProxyWorker(); try { terminateInstances(); } catch (Exception e) { logger.error("error while stopping cluster service : " + clusterId, e); return false; } deleteClusterTopologyConfig(); return true; } 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 { protected boolean destroyCluster() { logger.info("Destroying cluster {}..", clusterId); unloadProxyWorker(); try { terminateInstances(); } catch (Exception e) { logger.error("error while stopping cluster service : " + clusterId, e); return false; } deleteClusterTopologyConfig(); return true; } 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();  }