aboutsummaryrefslogtreecommitdiffstats
path: root/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/DistributionBitCountTest.java
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2022-08-31 15:22:20 +0200
committerHarald Musum <musum@yahooinc.com>2022-08-31 15:22:20 +0200
commit3074e6547443246e950ed6d675a4aec91c333d80 (patch)
tree11e613b0a28f3640b2169ed47fd7cb6b01765278 /clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/DistributionBitCountTest.java
parentf9e08944e87f49ae474c0f55bd64d8c709fb2cf6 (diff)
Make FleetControllerOptions immutable and support builder pattern
Diffstat (limited to 'clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/DistributionBitCountTest.java')
-rw-r--r--clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/DistributionBitCountTest.java28
1 files changed, 15 insertions, 13 deletions
diff --git a/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/DistributionBitCountTest.java b/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/DistributionBitCountTest.java
index d3b0addbb13..bf8bb722e3d 100644
--- a/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/DistributionBitCountTest.java
+++ b/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/DistributionBitCountTest.java
@@ -15,14 +15,14 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class DistributionBitCountTest extends FleetControllerTest {
- private void setUpSystem(String testName) throws Exception {
+ private FleetControllerOptions setUpSystem(String testName) throws Exception {
List<ConfiguredNode> configuredNodes = new ArrayList<>();
for (int i = 0 ; i < 10; i++) {
configuredNodes.add(new ConfiguredNode(i, false));
}
- FleetControllerOptions options = defaultOptions("mycluster", configuredNodes);
- options.distributionBits = 17;
- setUpFleetController(false, options);
+ var builder = defaultOptions("mycluster", configuredNodes);
+ builder.setDistributionBits(17);
+ setUpFleetController(false, builder);
startingTest(testName);
List<DummyVdsNode> nodes = setUpVdsNodes(false, new DummyVdsNodeOptions(), true, configuredNodes);
for (DummyVdsNode node : nodes) {
@@ -30,6 +30,7 @@ public class DistributionBitCountTest extends FleetControllerTest {
node.connect();
}
waitForState("version:\\d+ bits:17 distributor:10 storage:10");
+ return builder.build();
}
/**
@@ -38,14 +39,15 @@ public class DistributionBitCountTest extends FleetControllerTest {
*/
@Test
void testDistributionBitCountConfigIncrease() throws Exception {
- setUpSystem("DistributionBitCountTest::testDistributionBitCountConfigIncrease");
- options.distributionBits = 20;
- fleetController.updateOptions(options);
+ var options = setUpSystem("DistributionBitCountTest::testDistributionBitCountConfigIncrease");
+ var builder = FleetControllerOptions.Builder.copy(options);
+ builder.setDistributionBits(20);
+ fleetController.updateOptions(builder.build());
ClusterState currentState = waitForState("version:\\d+ bits:20 distributor:10 storage:10");
int version = currentState.getVersion();
- options.distributionBits = 23;
- fleetController.updateOptions(options);
+ builder.setDistributionBits(23);
+ fleetController.updateOptions(builder.build());
assertEquals(version, currentState.getVersion());
}
@@ -54,13 +56,13 @@ public class DistributionBitCountTest extends FleetControllerTest {
*/
@Test
void testDistributionBitCountConfigDecrease() throws Exception {
- setUpSystem("DistributionBitCountTest::testDistributionBitCountConfigDecrease");
- options.distributionBits = 12;
- fleetController.updateOptions(options);
+ FleetControllerOptions options = setUpSystem("DistributionBitCountTest::testDistributionBitCountConfigDecrease");
+ var builder = FleetControllerOptions.Builder.copy(options);
+ builder.setDistributionBits(12);
+ fleetController.updateOptions(builder.build());
waitForState("version:\\d+ bits:12 distributor:10 storage:10");
}
-
/**
* Test that when storage node reports higher bit count, but another storage
* node has equally low bitcount, the fleetcontroller does nothing.