diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-11-21 17:56:57 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2022-11-21 17:56:57 +0100 |
commit | 3e955a564d65de056c87b706432a4a12ff8d1d10 (patch) | |
tree | 5f4346c521fb07e3c2dc17b9747ffc30400274c9 /config-model/src/test/java/com/yahoo/vespa/model/content | |
parent | aaaa5efdde6562a44e3fa4e6168783029d0d5a98 (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.java | 39 |
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) { |