diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2019-09-28 19:13:03 +0200 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2019-09-28 19:27:03 +0200 |
commit | 1091542c58fd3d8a0b19a8925e15bb4752fb5fcb (patch) | |
tree | c9159f189baf760100fda0ef9f6c2c02c528e2cc /controller-server/src/test/java/com/yahoo/vespa/hosted/controller/maintenance/RoutingPoliciesTest.java | |
parent | 0e85eb225ee4e48d89db5b6c638356bd8f0dc696 (diff) |
Put Instances in Application, and replace ALL THE THINGS!!!
Diffstat (limited to 'controller-server/src/test/java/com/yahoo/vespa/hosted/controller/maintenance/RoutingPoliciesTest.java')
-rw-r--r-- | controller-server/src/test/java/com/yahoo/vespa/hosted/controller/maintenance/RoutingPoliciesTest.java | 38 |
1 files changed, 19 insertions, 19 deletions
diff --git a/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/maintenance/RoutingPoliciesTest.java b/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/maintenance/RoutingPoliciesTest.java index c1e1f0d0607..78a9be9f1d3 100644 --- a/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/maintenance/RoutingPoliciesTest.java +++ b/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/maintenance/RoutingPoliciesTest.java @@ -41,8 +41,8 @@ public class RoutingPoliciesTest { private final Application app1 = tester.createApplication("app1", "tenant1", 1, 1L); private final Application app2 = tester.createApplication("app2", "tenant1", 1, 1L); - private final Instance instance1 = tester.instance(app1.id()); - private final Instance instance2 = tester.instance(app2.id()); + private final Instance instance1 = tester.defaultInstance(app1.id()); + private final Instance instance2 = tester.defaultInstance(app2.id()); private final ZoneId zone1 = ZoneId.from("prod", "us-west-1"); private final ZoneId zone2 = ZoneId.from("prod", "us-central-1"); @@ -65,7 +65,7 @@ public class RoutingPoliciesTest { .endpoint("r1", "c0", "us-west-1") .endpoint("r2", "c1") .build(); - provisionLoadBalancers(clustersPerZone, app1.id(), zone1, zone2); + provisionLoadBalancers(clustersPerZone, instance1.id(), zone1, zone2); // Creates alias records tester.deployCompletely(app1, applicationPackage, ++buildNumber); @@ -86,7 +86,7 @@ public class RoutingPoliciesTest { aliasDataOf(endpoint3)); assertEquals("Routing policy count is equal to cluster count", numberOfDeployments * clustersPerZone, - tester.controller().applications().routingPolicies().get(app1.id()).size()); + tester.controller().applications().routingPolicies().get(instance1.id()).size()); // Applications gains a new deployment ApplicationPackage applicationPackage2 = new ApplicationPackageBuilder() @@ -98,7 +98,7 @@ public class RoutingPoliciesTest { .endpoint("r2", "c1") .build(); numberOfDeployments++; - provisionLoadBalancers(clustersPerZone, app1.id(), zone3); + provisionLoadBalancers(clustersPerZone, instance1.id(), zone3); tester.deployCompletely(app1, applicationPackage2, ++buildNumber); // Endpoint is updated to contain cluster in new deployment @@ -110,7 +110,7 @@ public class RoutingPoliciesTest { // Another application is deployed with a single cluster and global endpoint var endpoint4 = "r0.app2.tenant1.global.vespa.oath.cloud"; - provisionLoadBalancers(1, app2.id(), zone1, zone2); + provisionLoadBalancers(1, instance2.id(), zone1, zone2); var applicationPackage3 = new ApplicationPackageBuilder() .region(zone1.region()) .region(zone2.region()) @@ -132,7 +132,7 @@ public class RoutingPoliciesTest { assertEquals("DNS records are removed", List.of(), aliasDataOf(endpoint1)); assertEquals("DNS records are removed", List.of(), aliasDataOf(endpoint2)); assertEquals("DNS records are removed", List.of(), aliasDataOf(endpoint3)); - Set<RoutingPolicy> policies = tester.controller().curator().readRoutingPolicies(app1.id()); + Set<RoutingPolicy> policies = tester.controller().curator().readRoutingPolicies(instance1.id()); assertEquals(clustersPerZone * numberOfDeployments, policies.size()); assertTrue("Rotation membership is removed from all policies", policies.stream().allMatch(policy -> policy.endpoints().isEmpty())); @@ -144,7 +144,7 @@ public class RoutingPoliciesTest { // Deploy application int clustersPerZone = 2; int buildNumber = 42; - provisionLoadBalancers(clustersPerZone, app1.id(), zone1, zone2); + provisionLoadBalancers(clustersPerZone, instance1.id(), zone1, zone2); tester.deployCompletely(app1, applicationPackage, ++buildNumber); // Deployment creates records and policies for all clusters in all zones @@ -163,7 +163,7 @@ public class RoutingPoliciesTest { assertEquals(4, policies(instance1).size()); // Add 1 cluster in each zone and deploy - provisionLoadBalancers(clustersPerZone + 1, app1.id(), zone1, zone2); + provisionLoadBalancers(clustersPerZone + 1, instance1.id(), zone1, zone2); tester.deployCompletely(app1, applicationPackage, ++buildNumber); expectedRecords = Set.of( "c0.app1.tenant1.us-west-1.vespa.oath.cloud", @@ -177,7 +177,7 @@ public class RoutingPoliciesTest { assertEquals(6, policies(instance1).size()); // Deploy another application - provisionLoadBalancers(clustersPerZone, app2.id(), zone1, zone2); + provisionLoadBalancers(clustersPerZone, instance2.id(), zone1, zone2); tester.deployCompletely(app2, applicationPackage, ++buildNumber); expectedRecords = Set.of( "c0.app1.tenant1.us-west-1.vespa.oath.cloud", @@ -195,7 +195,7 @@ public class RoutingPoliciesTest { assertEquals(4, policies(instance2).size()); // Deploy removes cluster from app1 - provisionLoadBalancers(clustersPerZone, app1.id(), zone1, zone2); + provisionLoadBalancers(clustersPerZone, instance1.id(), zone1, zone2); tester.deployCompletely(app1, applicationPackage, ++buildNumber); expectedRecords = Set.of( "c0.app1.tenant1.us-west-1.vespa.oath.cloud", @@ -210,10 +210,10 @@ public class RoutingPoliciesTest { assertEquals(expectedRecords, recordNames()); // Remove app2 completely - tester.controller().applications().require(app2.id()).deployments().keySet() + tester.controller().applications().requireInstance(instance2.id()).deployments().keySet() .forEach(zone -> { - tester.configServer().removeLoadBalancers(app2.id(), zone); - tester.controller().applications().deactivate(app2.id(), zone); + tester.configServer().removeLoadBalancers(instance2.id(), zone); + tester.controller().applications().deactivate(instance2.id(), zone); }); tester.flushDnsRequests(); expectedRecords = Set.of( @@ -223,22 +223,22 @@ public class RoutingPoliciesTest { "c1.app1.tenant1.us-central-1.vespa.oath.cloud" ); assertEquals(expectedRecords, recordNames()); - assertTrue("Removes stale routing policies " + app2, tester.controller().applications().routingPolicies().get(app2.id()).isEmpty()); - assertEquals("Keeps routing policies for " + app1, 4, tester.controller().applications().routingPolicies().get(app1.id()).size()); + assertTrue("Removes stale routing policies " + app2, tester.controller().applications().routingPolicies().get(instance2.id()).isEmpty()); + assertEquals("Keeps routing policies for " + app1, 4, tester.controller().applications().routingPolicies().get(instance1.id()).size()); } @Test public void cluster_endpoints_resolve_from_policies() { - provisionLoadBalancers(3, app1.id(), zone1); + provisionLoadBalancers(3, instance1.id(), zone1); tester.deployCompletely(app1, applicationPackage); - tester.controllerTester().serviceRegistry().routingGeneratorMock().putEndpoints(new DeploymentId(app1.id(), zone1), Collections.emptyList()); + tester.controllerTester().serviceRegistry().routingGeneratorMock().putEndpoints(new DeploymentId(instance1.id(), zone1), Collections.emptyList()); assertEquals(Map.of(ClusterSpec.Id.from("c0"), URI.create("https://c0.app1.tenant1.us-west-1.vespa.oath.cloud/"), ClusterSpec.Id.from("c1"), URI.create("https://c1.app1.tenant1.us-west-1.vespa.oath.cloud/"), ClusterSpec.Id.from("c2"), URI.create("https://c2.app1.tenant1.us-west-1.vespa.oath.cloud/")), - tester.controller().applications().clusterEndpoints(new DeploymentId(app1.id(), zone1))); + tester.controller().applications().clusterEndpoints(new DeploymentId(instance1.id(), zone1))); } private Set<RoutingPolicy> policies(Instance instance) { |