@Test public void getNumberOfBenchmarkNodes() throws Exception { long numberOfNodes = clusterManager.getNumberOfNodes("org.hobbit.workergroup=benchmark"); assertEquals(0, numberOfNodes); }
public long getNumberOfNodes() throws DockerException, InterruptedException { return streamReadyNodes().count(); }
ClusterManagerImpl implements ClusterManager { public long getNumberOfNodes() throws DockerException, InterruptedException { return streamReadyNodes().count(); } }
ClusterManagerImpl implements ClusterManager { public long getNumberOfNodes() throws DockerException, InterruptedException { return streamReadyNodes().count(); } ClusterManagerImpl(); }
ClusterManagerImpl implements ClusterManager { public long getNumberOfNodes() throws DockerException, InterruptedException { return streamReadyNodes().count(); } ClusterManagerImpl(); Info getClusterInfo(); long getNumberOfNodes(); long getNumberOfNodes(String label); boolean isClusterHealthy(); long getExpectedNumberOfNodes(); void setTaskHistoryLimit(Integer taskHistoryLimit); int getTaskHistoryLimit(); }
ClusterManagerImpl implements ClusterManager { public long getNumberOfNodes() throws DockerException, InterruptedException { return streamReadyNodes().count(); } ClusterManagerImpl(); Info getClusterInfo(); long getNumberOfNodes(); long getNumberOfNodes(String label); boolean isClusterHealthy(); long getExpectedNumberOfNodes(); void setTaskHistoryLimit(Integer taskHistoryLimit); int getTaskHistoryLimit();  }