diff options
author | Harald Musum <musum@yahooinc.com> | 2022-08-31 15:22:20 +0200 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2022-08-31 15:22:20 +0200 |
commit | 3074e6547443246e950ed6d675a4aec91c333d80 (patch) | |
tree | 11e613b0a28f3640b2169ed47fd7cb6b01765278 /clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/DistributionBitCountTest.java | |
parent | f9e08944e87f49ae474c0f55bd64d8c709fb2cf6 (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.java | 28 |
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. |