@Test public void isClusterHealthy() throws Exception { boolean isHealthy = clusterManager.isClusterHealthy(); assertTrue(isHealthy); }
public boolean isClusterHealthy() throws DockerException, InterruptedException { long numberOfNodes = getNumberOfNodes(); if(numberOfNodes >= expectedNumberOfNodes) { return true; } LOGGER.debug("Cluster is not healthy ({}/{})",numberOfNodes, expectedNumberOfNodes); return false; }
ClusterManagerImpl implements ClusterManager { public boolean isClusterHealthy() throws DockerException, InterruptedException { long numberOfNodes = getNumberOfNodes(); if(numberOfNodes >= expectedNumberOfNodes) { return true; } LOGGER.debug("Cluster is not healthy ({}/{})",numberOfNodes, expectedNumberOfNodes); return false; } }
ClusterManagerImpl implements ClusterManager { public boolean isClusterHealthy() throws DockerException, InterruptedException { long numberOfNodes = getNumberOfNodes(); if(numberOfNodes >= expectedNumberOfNodes) { return true; } LOGGER.debug("Cluster is not healthy ({}/{})",numberOfNodes, expectedNumberOfNodes); return false; } ClusterManagerImpl(); }
ClusterManagerImpl implements ClusterManager { public boolean isClusterHealthy() throws DockerException, InterruptedException { long numberOfNodes = getNumberOfNodes(); if(numberOfNodes >= expectedNumberOfNodes) { return true; } LOGGER.debug("Cluster is not healthy ({}/{})",numberOfNodes, expectedNumberOfNodes); return false; } ClusterManagerImpl(); Info getClusterInfo(); long getNumberOfNodes(); long getNumberOfNodes(String label); boolean isClusterHealthy(); long getExpectedNumberOfNodes(); void setTaskHistoryLimit(Integer taskHistoryLimit); int getTaskHistoryLimit(); }
ClusterManagerImpl implements ClusterManager { public boolean isClusterHealthy() throws DockerException, InterruptedException { long numberOfNodes = getNumberOfNodes(); if(numberOfNodes >= expectedNumberOfNodes) { return true; } LOGGER.debug("Cluster is not healthy ({}/{})",numberOfNodes, expectedNumberOfNodes); return false; } ClusterManagerImpl(); Info getClusterInfo(); long getNumberOfNodes(); long getNumberOfNodes(String label); boolean isClusterHealthy(); long getExpectedNumberOfNodes(); void setTaskHistoryLimit(Integer taskHistoryLimit); int getTaskHistoryLimit();  }