@Test public void require_that_server_count_is_correct() { ConfigserverConfig.Builder builder = new ConfigserverConfig.Builder(); builder.zookeeperserver(createZKBuilder(localhost, port1)); try (Curator curator = createCurator(new ConfigserverConfig(builder))) { assertEquals(1, curator.zooKeeperEnsembleCount()); } }
public int zooKeeperEnsembleCount() { return zooKeeperEnsembleCount; }
Curator implements AutoCloseable { public int zooKeeperEnsembleCount() { return zooKeeperEnsembleCount; } }
Curator implements AutoCloseable { public int zooKeeperEnsembleCount() { return zooKeeperEnsembleCount; } @Inject  Curator(ConfigserverConfig configserverConfig, VespaZooKeeperServer server);   Curator(ConfigserverConfig configserverConfig, Optional<File> clientConfigFile); private  Curator(String connectionSpec, String zooKeeperEnsembleConnectionSpec, Optional<File> clientConfigFile); protected  Curator(String connectionSpec,
                      String zooKeeperEnsembleConnectionSpec,
                      Function<RetryPolicy, CuratorFramework> curatorFactory); private  Curator(String connectionSpec,
                    String zooKeeperEnsembleConnectionSpec,
                    Function<RetryPolicy, CuratorFramework> curatorFactory,
                    RetryPolicy retryPolicy); }
Curator implements AutoCloseable { public int zooKeeperEnsembleCount() { return zooKeeperEnsembleCount; } @Inject  Curator(ConfigserverConfig configserverConfig, VespaZooKeeperServer server);   Curator(ConfigserverConfig configserverConfig, Optional<File> clientConfigFile); private  Curator(String connectionSpec, String zooKeeperEnsembleConnectionSpec, Optional<File> clientConfigFile); protected  Curator(String connectionSpec,
                      String zooKeeperEnsembleConnectionSpec,
                      Function<RetryPolicy, CuratorFramework> curatorFactory); private  Curator(String connectionSpec,
                    String zooKeeperEnsembleConnectionSpec,
                    Function<RetryPolicy, CuratorFramework> curatorFactory,
                    RetryPolicy retryPolicy); static Curator create(String connectionSpec); static Curator create(String connectionSpec, Optional<File> clientConfigFile); String connectionSpec(); DistributedAtomicLong createAtomicCounter(String path); InterProcessLock createMutex(String lockPath); CompletionWaiter getCompletionWaiter(Path waiterPath, int numMembers, String id); CompletionWaiter createCompletionWaiter(Path parentPath, String waiterNode, int numMembers, String id); DirectoryCache createDirectoryCache(String path, boolean cacheData, boolean dataIsCompressed, ExecutorService executorService); FileCache createFileCache(String path, boolean dataIsCompressed); boolean exists(Path path); void set(Path path, byte[] data); boolean create(Path path); void createAtomically(Path... paths); void delete(Path path); List<String> getChildren(Path path); Optional<byte[]> getData(Path path); Optional<Stat> getStat(Path path); Lock lock(Path path, Duration timeout); CuratorFramework framework(); @Override void close(); String zooKeeperEnsembleConnectionSpec(); int zooKeeperEnsembleCount(); }
Curator implements AutoCloseable { public int zooKeeperEnsembleCount() { return zooKeeperEnsembleCount; } @Inject  Curator(ConfigserverConfig configserverConfig, VespaZooKeeperServer server);   Curator(ConfigserverConfig configserverConfig, Optional<File> clientConfigFile); private  Curator(String connectionSpec, String zooKeeperEnsembleConnectionSpec, Optional<File> clientConfigFile); protected  Curator(String connectionSpec,
                      String zooKeeperEnsembleConnectionSpec,
                      Function<RetryPolicy, CuratorFramework> curatorFactory); private  Curator(String connectionSpec,
                    String zooKeeperEnsembleConnectionSpec,
                    Function<RetryPolicy, CuratorFramework> curatorFactory,
                    RetryPolicy retryPolicy); static Curator create(String connectionSpec); static Curator create(String connectionSpec, Optional<File> clientConfigFile); String connectionSpec(); DistributedAtomicLong createAtomicCounter(String path); InterProcessLock createMutex(String lockPath); CompletionWaiter getCompletionWaiter(Path waiterPath, int numMembers, String id); CompletionWaiter createCompletionWaiter(Path parentPath, String waiterNode, int numMembers, String id); DirectoryCache createDirectoryCache(String path, boolean cacheData, boolean dataIsCompressed, ExecutorService executorService); FileCache createFileCache(String path, boolean dataIsCompressed); boolean exists(Path path); void set(Path path, byte[] data); boolean create(Path path); void createAtomically(Path... paths); void delete(Path path); List<String> getChildren(Path path); Optional<byte[]> getData(Path path); Optional<Stat> getStat(Path path); Lock lock(Path path, Duration timeout); CuratorFramework framework(); @Override void close(); String zooKeeperEnsembleConnectionSpec(); int zooKeeperEnsembleCount();  }