summaryrefslogtreecommitdiffstats
path: root/zkfacade/src
diff options
context:
space:
mode:
authorHarald Musum <musum@verizonmedia.com>2019-10-16 23:35:47 +0200
committerHarald Musum <musum@verizonmedia.com>2019-10-16 23:35:47 +0200
commitd9b6c2bae8de6708625a05b4ad6224fb36f8cb7e (patch)
treef0a29d2ee7906d375af55454176005367e1afdae /zkfacade/src
parent0f378f6aeae4ab1afef700ee49257ff2074e4d14 (diff)
Add constructor without ZooKeeperServer argument, for testing
Will be used by code in internal repo, so needs to be public
Diffstat (limited to 'zkfacade/src')
-rw-r--r--zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java5
-rw-r--r--zkfacade/src/test/java/com/yahoo/vespa/curator/CuratorTest.java2
2 files changed, 6 insertions, 1 deletions
diff --git a/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java b/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java
index a543d43abcd..dc51c82b5e6 100644
--- a/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java
+++ b/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java
@@ -64,6 +64,11 @@ public class Curator implements AutoCloseable {
return new Curator(connectionSpec, connectionSpec);
}
+ // For testing
+ public Curator(ConfigserverConfig configserverConfig) {
+ this(configserverConfig, createConnectionSpec(configserverConfig));
+ }
+
// Depend on ZooKeeperServer to make sure it is started first
// TODO: Move zookeeperserver config out of configserverconfig (requires update of controller services.xml as well)
@Inject
diff --git a/zkfacade/src/test/java/com/yahoo/vespa/curator/CuratorTest.java b/zkfacade/src/test/java/com/yahoo/vespa/curator/CuratorTest.java
index 566df91dfb0..a8342dfe5bc 100644
--- a/zkfacade/src/test/java/com/yahoo/vespa/curator/CuratorTest.java
+++ b/zkfacade/src/test/java/com/yahoo/vespa/curator/CuratorTest.java
@@ -99,7 +99,7 @@ public class CuratorTest {
}
private Curator createCurator(ConfigserverConfig configserverConfig) {
- return new Curator(configserverConfig, null);
+ return new Curator(configserverConfig);
}
private static class PortAllocator {