@Test public void testAddIndex() throws Exception { DeployClient deployClient = new DeployClient(_protocol); deployClient.addIndex("i1", "iP", 1); verify(_protocol).addMasterOperation(any(IndexDeployOperation.class)); }
@Override public IIndexDeployFuture addIndex(String indexName, String indexPath, int replicationLevel) { validateIndexData(indexName, replicationLevel); _protocol.addMasterOperation(new IndexDeployOperation(indexName, indexPath, replicationLevel)); return new IndexDeployFuture(_protocol, indexName); }
DeployClient implements IDeployClient { @Override public IIndexDeployFuture addIndex(String indexName, String indexPath, int replicationLevel) { validateIndexData(indexName, replicationLevel); _protocol.addMasterOperation(new IndexDeployOperation(indexName, indexPath, replicationLevel)); return new IndexDeployFuture(_protocol, indexName); } }
DeployClient implements IDeployClient { @Override public IIndexDeployFuture addIndex(String indexName, String indexPath, int replicationLevel) { validateIndexData(indexName, replicationLevel); _protocol.addMasterOperation(new IndexDeployOperation(indexName, indexPath, replicationLevel)); return new IndexDeployFuture(_protocol, indexName); } DeployClient(ZkClient zkClient, ZkConfiguration configuration);  DeployClient(InteractionProtocol interactionProtocol); }
DeployClient implements IDeployClient { @Override public IIndexDeployFuture addIndex(String indexName, String indexPath, int replicationLevel) { validateIndexData(indexName, replicationLevel); _protocol.addMasterOperation(new IndexDeployOperation(indexName, indexPath, replicationLevel)); return new IndexDeployFuture(_protocol, indexName); } DeployClient(ZkClient zkClient, ZkConfiguration configuration);  DeployClient(InteractionProtocol interactionProtocol); @Override IIndexDeployFuture addIndex(String indexName, String indexPath, int replicationLevel); @Override void removeIndex(String indexName); @Override boolean existsIndex(String indexName); @Override IndexMetaData getIndexMetaData(String indexName); @Override List<String> getIndices(); }
DeployClient implements IDeployClient { @Override public IIndexDeployFuture addIndex(String indexName, String indexPath, int replicationLevel) { validateIndexData(indexName, replicationLevel); _protocol.addMasterOperation(new IndexDeployOperation(indexName, indexPath, replicationLevel)); return new IndexDeployFuture(_protocol, indexName); } DeployClient(ZkClient zkClient, ZkConfiguration configuration);  DeployClient(InteractionProtocol interactionProtocol); @Override IIndexDeployFuture addIndex(String indexName, String indexPath, int replicationLevel); @Override void removeIndex(String indexName); @Override boolean existsIndex(String indexName); @Override IndexMetaData getIndexMetaData(String indexName); @Override List<String> getIndices();  }