aboutsummaryrefslogtreecommitdiffstats
path: root/config-model/src/test/java/com/yahoo/vespa/model/content
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-11-21 17:56:57 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2022-11-21 17:56:57 +0100
commit3e955a564d65de056c87b706432a4a12ff8d1d10 (patch)
tree5f4346c521fb07e3c2dc17b9747ffc30400274c9 /config-model/src/test/java/com/yahoo/vespa/model/content
parentaaaa5efdde6562a44e3fa4e6168783029d0d5a98 (diff)
Splitt nodes static and dynamic config in DispatchConfig to prepare for seamless cluster changes.
Diffstat (limited to 'config-model/src/test/java/com/yahoo/vespa/model/content')
-rw-r--r--config-model/src/test/java/com/yahoo/vespa/model/content/cluster/ClusterTest.java39
1 files changed, 22 insertions, 17 deletions
diff --git a/config-model/src/test/java/com/yahoo/vespa/model/content/cluster/ClusterTest.java b/config-model/src/test/java/com/yahoo/vespa/model/content/cluster/ClusterTest.java
index 6b6a61823ab..a6ea6cb8132 100644
--- a/config-model/src/test/java/com/yahoo/vespa/model/content/cluster/ClusterTest.java
+++ b/config-model/src/test/java/com/yahoo/vespa/model/content/cluster/ClusterTest.java
@@ -5,6 +5,7 @@ import com.yahoo.config.application.api.ApplicationPackage;
import com.yahoo.config.model.test.MockApplicationPackage;
import com.yahoo.config.model.test.TestDriver;
import com.yahoo.vespa.config.search.DispatchConfig;
+import com.yahoo.vespa.config.search.DispatchNodesConfig;
import com.yahoo.vespa.config.search.core.ProtonConfig;
import com.yahoo.vespa.model.content.Content;
import com.yahoo.vespa.model.search.IndexedSearchCluster;
@@ -90,8 +91,11 @@ public class ClusterTest {
ContentCluster cluster = newContentCluster(joinLines("<search>", "</search>"),
joinLines("<tuning>", "</tuning>"));
DispatchConfig.Builder builder = new DispatchConfig.Builder();
+ DispatchNodesConfig.Builder nodesBuilder = new DispatchNodesConfig.Builder();
cluster.getSearch().getConfig(builder);
- DispatchConfig config = new DispatchConfig(builder);
+ cluster.getSearch().getConfig(nodesBuilder);
+ DispatchConfig config = builder.build();
+ DispatchNodesConfig nodesConfig = nodesBuilder.build();
assertEquals(3, config.redundancy());
assertEquals(DispatchConfig.DistributionPolicy.ADAPTIVE, config.distributionPolicy());
assertEquals(1.0, config.maxWaitAfterCoverageFactor(), DELTA);
@@ -101,22 +105,23 @@ public class ClusterTest {
assertEquals(100.0, config.minSearchCoverage(), DELTA);
assertEquals(97.0, config.minActivedocsPercentage(), DELTA);
assertEquals(0.9999, config.topKProbability(), DELTA);
- assertEquals(3, config.node().size());
- assertEquals(0, config.node(0).key());
- assertEquals(1, config.node(1).key());
- assertEquals(2, config.node(2).key());
-
- assertEquals(19106, config.node(0).port());
- assertEquals(19118, config.node(1).port());
- assertEquals(19130, config.node(2).port());
-
- assertEquals(0, config.node(0).group());
- assertEquals(0, config.node(1).group());
- assertEquals(0, config.node(2).group());
-
- assertEquals("localhost", config.node(0).host());
- assertEquals("localhost", config.node(1).host());
- assertEquals("localhost", config.node(2).host());
+
+ assertEquals(3, nodesConfig.node().size());
+ assertEquals(0, nodesConfig.node(0).key());
+ assertEquals(1, nodesConfig.node(1).key());
+ assertEquals(2, nodesConfig.node(2).key());
+
+ assertEquals(19106, nodesConfig.node(0).port());
+ assertEquals(19118, nodesConfig.node(1).port());
+ assertEquals(19130, nodesConfig.node(2).port());
+
+ assertEquals(0, nodesConfig.node(0).group());
+ assertEquals(0, nodesConfig.node(1).group());
+ assertEquals(0, nodesConfig.node(2).group());
+
+ assertEquals("localhost", nodesConfig.node(0).host());
+ assertEquals("localhost", nodesConfig.node(1).host());
+ assertEquals("localhost", nodesConfig.node(2).host());
}
private static ContentCluster newContentCluster(String contentSearchXml, String searchNodeTuningXml) {