diff options
author | jonmv <venstad@gmail.com> | 2022-11-16 12:18:51 +0100 |
---|---|---|
committer | jonmv <venstad@gmail.com> | 2022-11-16 12:18:51 +0100 |
commit | 7f2f6aff04c8aafc038c55a3aa288b57eeb47d2d (patch) | |
tree | c57563a8cc8ad7fa5e6dbfaacd56c8b4e44f498c | |
parent | 8c988214f3d35a50ffc750e236a742411ac92b97 (diff) |
Address review
5 files changed, 19 insertions, 24 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/RoutingController.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/RoutingController.java index 0520987485e..84aa26b93f3 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/RoutingController.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/RoutingController.java @@ -235,7 +235,7 @@ public class RoutingController { .on(Port.tls()) .in(controller.system()); endpointDnsNames.add(endpoint.dnsName()); - if (endpoint.scope() == Scope.application) endpointDnsNames.add(endpoint.legacyRegionalDsnName()); + if (endpoint.scope() == Scope.application) endpointDnsNames.add(endpoint.legacyRegionalDnsName()); } return Collections.unmodifiableList(endpointDnsNames); } @@ -314,7 +314,7 @@ public class RoutingController { new Record(Record.Type.CNAME, RecordName.from(endpoint.dnsName()), RecordData.fqdn(vipHostname)), Priority.normal); controller.nameServiceForwarder().createRecord( - new Record(Record.Type.CNAME, RecordName.from(endpoint.legacyRegionalDsnName()), RecordData.fqdn(vipHostname)), + new Record(Record.Type.CNAME, RecordName.from(endpoint.legacyRegionalDnsName()), RecordData.fqdn(vipHostname)), Priority.normal); } Map<ClusterSpec.Id, EndpointList> applicationEndpointsByCluster = applicationEndpoints.groupingBy(Endpoint::cluster); @@ -328,7 +328,7 @@ public class RoutingController { if (matchingTarget.isEmpty()) throw new IllegalStateException("No target found routing to " + deployment + " in " + endpoint); containerEndpoints.add(new ContainerEndpoint(clusterId.value(), asString(Endpoint.Scope.application), - List.of(endpoint.dnsName(), endpoint.legacyRegionalDsnName()), + List.of(endpoint.dnsName(), endpoint.legacyRegionalDnsName()), OptionalInt.of(matchingTarget.get().weight()), endpoint.routingMethod())); } diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/application/Endpoint.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/application/Endpoint.java index b559353ca25..cbac700a9a0 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/application/Endpoint.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/application/Endpoint.java @@ -2,7 +2,6 @@ package com.yahoo.vespa.hosted.controller.application; import com.yahoo.config.provision.ApplicationId; -import com.yahoo.config.provision.CloudName; import com.yahoo.config.provision.ClusterSpec; import com.yahoo.config.provision.InstanceName; import com.yahoo.config.provision.RegionName; @@ -11,22 +10,17 @@ import com.yahoo.config.provision.zone.RoutingMethod; import com.yahoo.config.provision.zone.ZoneId; import com.yahoo.text.Text; import com.yahoo.vespa.hosted.controller.api.identifiers.DeploymentId; -import com.yahoo.vespa.hosted.controller.api.integration.zone.ZoneRegistry; import java.net.URI; import java.util.List; import java.util.Map; import java.util.Objects; import java.util.Optional; -import java.util.Set; -import java.util.function.Function; import java.util.function.Predicate; import java.util.stream.Collectors; import java.util.stream.Stream; import static java.util.Comparator.comparing; -import static java.util.Comparator.naturalOrder; -import static java.util.stream.Collectors.toSet; /** * Represents an application or instance endpoint in hosted Vespa. @@ -107,7 +101,7 @@ public class Endpoint { } /** Returns the legacy DNS name with region, for application endpoints */ - public String legacyRegionalDsnName() { + public String legacyRegionalDnsName() { if (scope != Scope.application) throw new IllegalStateException("legacy regional URL is only for application scope endpoints, not " + this); return legacyRegionalUrl.getAuthority().replaceAll(":.*", ""); } diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/routing/RoutingPolicies.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/routing/RoutingPolicies.java index 5c995e83fd4..b0d16126600 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/routing/RoutingPolicies.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/routing/RoutingPolicies.java @@ -304,13 +304,13 @@ public class RoutingPolicies { nameServiceForwarderIn(targetZone).createAlias( RecordName.from(applicationEndpoint.dnsName()), aliasTargets, Priority.normal); nameServiceForwarderIn(targetZone).createAlias( - RecordName.from(applicationEndpoint.legacyRegionalDsnName()), aliasTargets, Priority.normal); + RecordName.from(applicationEndpoint.legacyRegionalDnsName()), aliasTargets, Priority.normal); } if ( ! directTargets.isEmpty()) { nameServiceForwarderIn(targetZone).createDirect( RecordName.from(applicationEndpoint.dnsName()), directTargets, Priority.normal); nameServiceForwarderIn(targetZone).createDirect( - RecordName.from(applicationEndpoint.legacyRegionalDsnName()), directTargets, Priority.normal); + RecordName.from(applicationEndpoint.legacyRegionalDnsName()), directTargets, Priority.normal); } }); inactiveTargetsByEndpoint.forEach((applicationEndpoint, targets) -> { @@ -322,7 +322,7 @@ public class RoutingPolicies { target.data(), Priority.normal); nameServiceForwarderIn(targetZone).removeRecords(target.type(), - RecordName.from(applicationEndpoint.legacyRegionalDsnName()), + RecordName.from(applicationEndpoint.legacyRegionalDnsName()), target.data(), Priority.normal); }); @@ -426,11 +426,11 @@ public class RoutingPolicies { for (Endpoint endpoint : endpoints) { if (policy.canonicalName().isPresent()) { forwarder.removeRecords(Record.Type.ALIAS, - RecordName.from(endpoint.dnsName()), - RecordData.fqdn(policy.canonicalName().get().value()), - Priority.normal); + RecordName.from(endpoint.dnsName()), + RecordData.fqdn(policy.canonicalName().get().value()), + Priority.normal); forwarder.removeRecords(Record.Type.ALIAS, - RecordName.from(endpoint.legacyRegionalDsnName()), + RecordName.from(endpoint.legacyRegionalDnsName()), RecordData.fqdn(policy.canonicalName().get().value()), Priority.normal); } else { @@ -439,9 +439,9 @@ public class RoutingPolicies { RecordData.from(policy.ipAddress().get()), Priority.normal); forwarder.removeRecords(Record.Type.DIRECT, - RecordName.from(endpoint.legacyRegionalDsnName()), - RecordData.from(policy.ipAddress().get()), - Priority.normal); + RecordName.from(endpoint.legacyRegionalDnsName()), + RecordData.from(policy.ipAddress().get()), + Priority.normal); } } } diff --git a/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/application/EndpointTest.java b/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/application/EndpointTest.java index 16d449fe89b..a76d2eca521 100644 --- a/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/application/EndpointTest.java +++ b/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/application/EndpointTest.java @@ -308,7 +308,7 @@ public class EndpointTest { .on(Port.tls()) .in(SystemName.cd) ); - tests.forEach((expected, endpoint) -> assertEquals(expected, endpoint.legacyRegionalDsnName())); + tests.forEach((expected, endpoint) -> assertEquals(expected, endpoint.legacyRegionalDnsName())); } @Test diff --git a/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/certificate/EndpointCertificatesTest.java b/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/certificate/EndpointCertificatesTest.java index 0f7c7fe900a..d79a81c7746 100644 --- a/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/certificate/EndpointCertificatesTest.java +++ b/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/certificate/EndpointCertificatesTest.java @@ -42,6 +42,7 @@ import java.util.Map; import java.util.Optional; import java.util.Set; import java.util.TreeSet; +import java.util.stream.Stream; import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertNotEquals; @@ -265,7 +266,7 @@ public class EndpointCertificatesTest { .build(); EndpointCertificateValidatorImpl endpointCertificateValidator = new EndpointCertificateValidatorImpl(secretStore, clock); EndpointCertificates endpointCertificates = new EndpointCertificates(tester.controller(), endpointCertificateMock, endpointCertificateValidator); - Set<String> expectedSans = new TreeSet<>(List.of( + List<String> expectedSans = Stream.of( "vlfms2wpoa4nyrka2s5lktucypjtxkqhv.internal.vespa-app.cloud", "a1.t1.g.vespa-app.cloud", "*.a1.t1.g.vespa-app.cloud", @@ -281,13 +282,13 @@ public class EndpointCertificatesTest { "*.a1.t1.us-east-1.test.z.vespa-app.cloud", "a1.t1.us-east-3.staging.z.vespa-app.cloud", "*.a1.t1.us-east-3.staging.z.vespa-app.cloud" - )); + ).sorted().toList(); Optional<EndpointCertificateMetadata> endpointCertificateMetadata = endpointCertificates.getMetadata(instance, zone1, applicationPackage.deploymentSpec()); assertTrue(endpointCertificateMetadata.isPresent()); assertTrue(endpointCertificateMetadata.get().keyName().matches("vespa.tls.t1.a1.*-key")); assertTrue(endpointCertificateMetadata.get().certName().matches("vespa.tls.t1.a1.*-cert")); assertEquals(0, endpointCertificateMetadata.get().version()); - assertEquals(expectedSans, new TreeSet<>(endpointCertificateMetadata.get().requestedDnsSans())); + assertEquals(expectedSans, endpointCertificateMetadata.get().requestedDnsSans().stream().sorted().toList()); } } |