@Test public void testGetClusterList() { LOG.warn("testGetClusterList"); List<String> clusterList = clusterStatus.getClusterList(false); assertEquals(Arrays.asList(DEFAULT), clusterList); }
@Override public List<String> getClusterList(boolean useCache) { if (useCache) { return new ArrayList<String>(_clusters.get()); } long s = System.nanoTime(); try { checkIfOpen(); return _zk.getChildren(ZookeeperPathConstants.getClustersPath(), false); } catch (KeeperException e) { throw new RuntimeException(e); } catch (InterruptedException e) { throw new RuntimeException(e); } finally { long e = System.nanoTime(); LOG.debug("trace getClusterList [" + (e - s) / 1000000.0 + " ms]"); } }
ZookeeperClusterStatus extends ClusterStatus { @Override public List<String> getClusterList(boolean useCache) { if (useCache) { return new ArrayList<String>(_clusters.get()); } long s = System.nanoTime(); try { checkIfOpen(); return _zk.getChildren(ZookeeperPathConstants.getClustersPath(), false); } catch (KeeperException e) { throw new RuntimeException(e); } catch (InterruptedException e) { throw new RuntimeException(e); } finally { long e = System.nanoTime(); LOG.debug("trace getClusterList [" + (e - s) / 1000000.0 + " ms]"); } } }
ZookeeperClusterStatus extends ClusterStatus { @Override public List<String> getClusterList(boolean useCache) { if (useCache) { return new ArrayList<String>(_clusters.get()); } long s = System.nanoTime(); try { checkIfOpen(); return _zk.getChildren(ZookeeperPathConstants.getClustersPath(), false); } catch (KeeperException e) { throw new RuntimeException(e); } catch (InterruptedException e) { throw new RuntimeException(e); } finally { long e = System.nanoTime(); LOG.debug("trace getClusterList [" + (e - s) / 1000000.0 + " ms]"); } } ZookeeperClusterStatus(ZooKeeper zooKeeper);  ZookeeperClusterStatus(String connectionStr); }
ZookeeperClusterStatus extends ClusterStatus { @Override public List<String> getClusterList(boolean useCache) { if (useCache) { return new ArrayList<String>(_clusters.get()); } long s = System.nanoTime(); try { checkIfOpen(); return _zk.getChildren(ZookeeperPathConstants.getClustersPath(), false); } catch (KeeperException e) { throw new RuntimeException(e); } catch (InterruptedException e) { throw new RuntimeException(e); } finally { long e = System.nanoTime(); LOG.debug("trace getClusterList [" + (e - s) / 1000000.0 + " ms]"); } } ZookeeperClusterStatus(ZooKeeper zooKeeper);  ZookeeperClusterStatus(String connectionStr); @Override List<String> getClusterList(boolean useCache); @Override List<String> getControllerServerList(); @Override List<String> getOnlineShardServers(boolean useCache, String cluster); @Override List<String> getShardServerList(String cluster); @Override boolean exists(boolean useCache, String cluster, String table); @Override boolean isEnabled(boolean useCache, String cluster, String table); @Override TableDescriptor getTableDescriptor(boolean useCache, String cluster, String table); @Override List<String> getTableList(boolean useCache, String cluster); void close(); @Override String getCluster(boolean useCache, String table); @Override boolean isInSafeMode(boolean useCache, String cluster); @Override int getShardCount(boolean useCache, String cluster, String table); @Override Set<String> getBlockCacheFileTypes(String cluster, String table); @Override boolean isBlockCacheEnabled(String cluster, String table); @Override boolean isReadOnly(boolean useCache, String cluster, String table); @Override void createTable(TableDescriptor tableDescriptor); @Override void disableTable(String cluster, String table); @Override void enableTable(String cluster, String table); @Override void removeTable(String cluster, String table, boolean deleteIndexFiles); @Override boolean isOpen(); }
ZookeeperClusterStatus extends ClusterStatus { @Override public List<String> getClusterList(boolean useCache) { if (useCache) { return new ArrayList<String>(_clusters.get()); } long s = System.nanoTime(); try { checkIfOpen(); return _zk.getChildren(ZookeeperPathConstants.getClustersPath(), false); } catch (KeeperException e) { throw new RuntimeException(e); } catch (InterruptedException e) { throw new RuntimeException(e); } finally { long e = System.nanoTime(); LOG.debug("trace getClusterList [" + (e - s) / 1000000.0 + " ms]"); } } ZookeeperClusterStatus(ZooKeeper zooKeeper);  ZookeeperClusterStatus(String connectionStr); @Override List<String> getClusterList(boolean useCache); @Override List<String> getControllerServerList(); @Override List<String> getOnlineShardServers(boolean useCache, String cluster); @Override List<String> getShardServerList(String cluster); @Override boolean exists(boolean useCache, String cluster, String table); @Override boolean isEnabled(boolean useCache, String cluster, String table); @Override TableDescriptor getTableDescriptor(boolean useCache, String cluster, String table); @Override List<String> getTableList(boolean useCache, String cluster); void close(); @Override String getCluster(boolean useCache, String table); @Override boolean isInSafeMode(boolean useCache, String cluster); @Override int getShardCount(boolean useCache, String cluster, String table); @Override Set<String> getBlockCacheFileTypes(String cluster, String table); @Override boolean isBlockCacheEnabled(String cluster, String table); @Override boolean isReadOnly(boolean useCache, String cluster, String table); @Override void createTable(TableDescriptor tableDescriptor); @Override void disableTable(String cluster, String table); @Override void enableTable(String cluster, String table); @Override void removeTable(String cluster, String table, boolean deleteIndexFiles); @Override boolean isOpen();  }