diff options
author | Harald Musum <musum@verizonmedia.com> | 2019-10-24 20:09:34 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-10-24 20:09:34 +0200 |
commit | 0e1ac44cc1490e64e1d31514c1df863a8124e0cd (patch) | |
tree | 4fabbbac37bcdb0457ccdd1c457ccd6d68a16f42 /controller-server/src | |
parent | a51c511c0e1043acfcc7e1196cc8ead2829d7245 (diff) |
Revert "Bjorncs/system flags handler"
Diffstat (limited to 'controller-server/src')
2 files changed, 9 insertions, 18 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/proxy/ConfigServerRestExecutorImpl.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/proxy/ConfigServerRestExecutorImpl.java index 72b11f56d9f..a4ca8605f4b 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/proxy/ConfigServerRestExecutorImpl.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/proxy/ConfigServerRestExecutorImpl.java @@ -79,7 +79,13 @@ public class ConfigServerRestExecutorImpl implements ConfigServerRestExecutor { ZoneId zoneId = ZoneId.from(proxyRequest.getEnvironment(), proxyRequest.getRegion()); - List<URI> allServers = getConfigserverEndpoints(zoneId); + // Make a local copy of the list as we want to manipulate it in case of ping problems. + List<URI> allServers = zoneRegistry.getConfigServerVipUri(zoneId) + // TODO: Use config server VIP for all zones that have one + .filter(zone -> zoneId.region().value().startsWith("aws-") || zoneId.region().value().contains("-aws-")) + + .map(Collections::singletonList) + .orElseGet(() -> new ArrayList<>(zoneRegistry.getConfigServerUris(zoneId))); StringBuilder errorBuilder = new StringBuilder(); if (queueFirstServerIfDown(allServers, proxyRequest)) { @@ -96,16 +102,6 @@ public class ConfigServerRestExecutorImpl implements ConfigServerRestExecutor { + errorBuilder.toString())); } - private List<URI> getConfigserverEndpoints(ZoneId zoneId) { - // TODO: Use config server VIP for all zones that have one - // Make a local copy of the list as we want to manipulate it in case of ping problems. - if (zoneId.region().value().startsWith("aws-") || zoneId.region().value().contains("-aws-")) { - return Collections.singletonList(zoneRegistry.getConfigServerVipUri(zoneId)); - } else { - return new ArrayList<>(zoneRegistry.getConfigServerUris(zoneId)); - } - } - private static class DiscoveryResponseStructure { public List<String> uris = new ArrayList<>(); } diff --git a/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/integration/ZoneRegistryMock.java b/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/integration/ZoneRegistryMock.java index 32bbf3ceb9b..7771dd2d1a0 100644 --- a/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/integration/ZoneRegistryMock.java +++ b/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/integration/ZoneRegistryMock.java @@ -165,11 +165,6 @@ public class ZoneRegistryMock extends AbstractComponent implements ZoneRegistry } @Override - public URI apiUrl() { - return URI.create("https://api.tld:4443/"); - } - - @Override public boolean hasZone(ZoneId zoneId) { return zones.stream().anyMatch(zone -> zone.getId().equals(zoneId)); } @@ -180,8 +175,8 @@ public class ZoneRegistryMock extends AbstractComponent implements ZoneRegistry } @Override - public URI getConfigServerVipUri(ZoneId zoneId) { - return URI.create(String.format("https://cfg.%s.test.vip:4443/", zoneId.value())); + public Optional<URI> getConfigServerVipUri(ZoneId zoneId) { + return Optional.of(URI.create(String.format("https://cfg.%s.test.vip:4443/", zoneId.value()))); } @Override |