From 6c4cf61b3feef1fbce1ba48b326e91f219e0cde4 Mon Sep 17 00:00:00 2001 From: Harald Musum Date: Tue, 16 Nov 2021 11:48:19 +0100 Subject: Revert "Add clusterid" --- .../model/api/ApplicationClusterEndpoint.java | 26 ++++++---------------- .../container/ApplicationContainerCluster.java | 3 --- configdefinitions/src/vespa/lb-services.def | 1 - .../config/server/model/LbServicesProducer.java | 3 +-- .../server/model/LbServicesProducerTest.java | 20 +++-------------- 5 files changed, 11 insertions(+), 42 deletions(-) diff --git a/config-model-api/src/main/java/com/yahoo/config/model/api/ApplicationClusterEndpoint.java b/config-model-api/src/main/java/com/yahoo/config/model/api/ApplicationClusterEndpoint.java index 1c45e4ba5dd..a91f95d71b1 100644 --- a/config-model-api/src/main/java/com/yahoo/config/model/api/ApplicationClusterEndpoint.java +++ b/config-model-api/src/main/java/com/yahoo/config/model/api/ApplicationClusterEndpoint.java @@ -26,15 +26,13 @@ public class ApplicationClusterEndpoint { private final RoutingMethod routingMethod; private final int weight; private final List hostNames; - private final String clusterId; - private ApplicationClusterEndpoint(DnsName dnsName, Scope scope, RoutingMethod routingMethod, int weight, List hostNames, String clusterId) { - this.dnsName = Objects.requireNonNull(dnsName); - this.scope = Objects.requireNonNull(scope); - this.routingMethod = Objects.requireNonNull(routingMethod); + public ApplicationClusterEndpoint(DnsName dnsName, Scope scope, RoutingMethod routingMethod, int weight, List hostNames) { + this.dnsName = dnsName; + this.scope = scope; + this.routingMethod = routingMethod; this.weight = weight; - this.hostNames = List.copyOf(Objects.requireNonNull(hostNames)); - this.clusterId = Objects.requireNonNull(clusterId); + this.hostNames = List.copyOf(hostNames); } public DnsName dnsName() { @@ -57,10 +55,6 @@ public class ApplicationClusterEndpoint { return hostNames; } - public String clusterId() { - return clusterId; - } - public static Builder builder() { return new Builder(); } @@ -70,9 +64,8 @@ public class ApplicationClusterEndpoint { private DnsName dnsName; private Scope scope; private RoutingMethod routingMethod; - private int weigth = 1; + private int weigth = 0; private List hosts; - private String clusterId; public Builder dnsName(DnsName name) { this.dnsName = name; @@ -109,13 +102,8 @@ public class ApplicationClusterEndpoint { return this; } - public Builder clusterId(String clusterId) { - this.clusterId = clusterId; - return this; - } - public ApplicationClusterEndpoint build() { - return new ApplicationClusterEndpoint(dnsName, scope, routingMethod, weigth, hosts, clusterId); + return new ApplicationClusterEndpoint(dnsName, scope, routingMethod, weigth, hosts); } } diff --git a/config-model/src/main/java/com/yahoo/vespa/model/container/ApplicationContainerCluster.java b/config-model/src/main/java/com/yahoo/vespa/model/container/ApplicationContainerCluster.java index f7e8afc2d94..a5dc26e19e3 100644 --- a/config-model/src/main/java/com/yahoo/vespa/model/container/ApplicationContainerCluster.java +++ b/config-model/src/main/java/com/yahoo/vespa/model/container/ApplicationContainerCluster.java @@ -218,7 +218,6 @@ public final class ApplicationContainerCluster extends ContainerCluster e.routingMethod() == sharedLayer4) .map(Endpoints::dnsName).collect(Collectors.toList()), containsInAnyOrder("mydisc.foo.foo.endpoint1.suffix", "mydisc.foo.foo.endpoint2.suffix")); - assertContainsEndpoint(zoneEndpoints, "mydisc.foo.foo.endpoint1.suffix", "mydisc", zone, sharedLayer4, 1, List.of("foo.foo.yahoo.com")); - assertContainsEndpoint(zoneEndpoints, "mydisc.foo.foo.endpoint2.suffix", "mydisc", zone, sharedLayer4, 1, List.of("foo.foo.yahoo.com")); List globalEndpoints = endpointList.stream().filter(e -> e.scope() == global).collect(Collectors.toList()); assertEquals(2, globalEndpoints.size()); assertThat(globalEndpoints.stream().map(Endpoints::dnsName).collect(Collectors.toList()), containsInAnyOrder("rotation-1", "rotation-2")); - assertContainsEndpoint(globalEndpoints, "rotation-1", "mydisc", global, sharedLayer4, 1, List.of("foo.foo.yahoo.com")); - assertContainsEndpoint(globalEndpoints, "rotation-2", "mydisc", global, sharedLayer4, 1, List.of("foo.foo.yahoo.com")); List applicationEndpoints = endpointList.stream().filter(e -> e.scope() == application).collect(Collectors.toList()); assertEquals(1, applicationEndpoints.size()); assertThat(applicationEndpoints.stream().map(Endpoints::dnsName).collect(Collectors.toList()), containsInAnyOrder("app-endpoint")); - assertContainsEndpoint(applicationEndpoints, "app-endpoint", "mydisc", application, sharedLayer4, 1, List.of("foo.foo.yahoo.com")); + } @@ -208,17 +205,6 @@ public class LbServicesProducerTest { .applications("baz:prod:default:custom-t")); } - private void assertContainsEndpoint(List endpoints, String dnsName, String clusterId, Endpoints.Scope.Enum scope, Endpoints.RoutingMethod.Enum routingMethod, int weight, List hosts) { - assertThat(endpoints, hasItem(new Endpoints.Builder() - .dnsName(dnsName) - .clusterId(clusterId) - .scope(scope) - .routingMethod(routingMethod) - .weight(weight) - .hosts(hosts) - .build())); - } - private Map> randomizeApplications(Map> testModel, int seed) { Map> randomizedApplications = new LinkedHashMap<>(); List keys = new ArrayList<>(testModel.keySet()); -- cgit v1.2.3