@Test public void testListCollections() throws Exception { NamedList<Object> namedList = new NamedList<>(); namedList.add("collections", Arrays.asList("collection1", "collection2")); expect(mockedSolrClient.request(anyObject(CollectionAdminRequest.class), anyString())).andReturn(namedList); replay(mockedSolrClient); List<String> result = underTest.listCollections(); assertTrue(result.contains("collection1")); assertTrue(result.contains("collection2")); assertEquals(2, result.size()); }
public List<String> listCollections() throws Exception { return new ListCollectionCommand(getRetryTimes(), getInterval()).run(this); }
AmbariSolrCloudClient { public List<String> listCollections() throws Exception { return new ListCollectionCommand(getRetryTimes(), getInterval()).run(this); } }
AmbariSolrCloudClient { public List<String> listCollections() throws Exception { return new ListCollectionCommand(getRetryTimes(), getInterval()).run(this); } AmbariSolrCloudClient(AmbariSolrCloudClientBuilder builder); }
AmbariSolrCloudClient { public List<String> listCollections() throws Exception { return new ListCollectionCommand(getRetryTimes(), getInterval()).run(this); } AmbariSolrCloudClient(AmbariSolrCloudClientBuilder builder); List<String> listCollections(); String createCollection(); void setClusterProp(); void createZnode(); boolean isZnodeExists(String znode); void setupKerberosPlugin(); void secureSolrZnode(); void secureZnode(); String uploadConfiguration(); String downloadConfiguration(); boolean configurationExists(); Collection<String> createShard(String shard); Collection<String> getShardNames(); Collection<String> getSolrHosts(); String getZkConnectString(); String getCollection(); String getConfigSet(); String getConfigDir(); int getShards(); int getReplication(); int getRetryTimes(); int getInterval(); CloudSolrClient getSolrCloudClient(); SolrZkClient getSolrZkClient(); int getMaxShardsPerNode(); String getRouterName(); String getRouterField(); boolean isSplitting(); String getJaasFile(); String getSaslUsers(); String getZnode(); String getPropName(); String getPropValue(); boolean isSecure(); String getSecurityJsonLocation(); }
AmbariSolrCloudClient { public List<String> listCollections() throws Exception { return new ListCollectionCommand(getRetryTimes(), getInterval()).run(this); } AmbariSolrCloudClient(AmbariSolrCloudClientBuilder builder); List<String> listCollections(); String createCollection(); void setClusterProp(); void createZnode(); boolean isZnodeExists(String znode); void setupKerberosPlugin(); void secureSolrZnode(); void secureZnode(); String uploadConfiguration(); String downloadConfiguration(); boolean configurationExists(); Collection<String> createShard(String shard); Collection<String> getShardNames(); Collection<String> getSolrHosts(); String getZkConnectString(); String getCollection(); String getConfigSet(); String getConfigDir(); int getShards(); int getReplication(); int getRetryTimes(); int getInterval(); CloudSolrClient getSolrCloudClient(); SolrZkClient getSolrZkClient(); int getMaxShardsPerNode(); String getRouterName(); String getRouterField(); boolean isSplitting(); String getJaasFile(); String getSaslUsers(); String getZnode(); String getPropName(); String getPropValue(); boolean isSecure(); String getSecurityJsonLocation();  }