diff options
author | Jon Marius Venstad <jvenstad@yahoo-inc.com> | 2017-12-15 09:17:47 +0100 |
---|---|---|
committer | Jon Marius Venstad <jvenstad@yahoo-inc.com> | 2017-12-15 09:17:47 +0100 |
commit | 8d82aa33667c4b401e693624bd40bf2061b64238 (patch) | |
tree | 075707a6a6dca23aabb2d333c5192b777459df4c /controller-server | |
parent | a3fc6158428e18169ee379f405ee35181e71c443 (diff) |
Changes to Zones, a MockZones and some usages
Diffstat (limited to 'controller-server')
5 files changed, 14 insertions, 14 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 eab6ca25520..751fe25b897 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 @@ -83,9 +83,9 @@ public class ConfigServerRestExecutorImpl implements ConfigServerRestExecutor { DiscoveryResponseStructure responseStructure = new DiscoveryResponseStructure(); String environmentName = proxyRequest.getEnvironment(); - Zones.List zones = environmentName.isEmpty() - ? zoneRegistry.zones().all() - : zoneRegistry.zones().in(Environment.from(environmentName)); + Zones.List zones = zoneRegistry.zones().all(); + if ( ! environmentName.isEmpty()) + zones = zones.in(Environment.from(environmentName)); for (ZoneId zoneId : zones.ids()) { responseStructure.uris.add(proxyRequest.getScheme() + "://" + proxyRequest.getControllerPrefix() + diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/restapi/zone/v1/ZoneApiHandler.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/restapi/zone/v1/ZoneApiHandler.java index cd447019de7..282dd79b317 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/restapi/zone/v1/ZoneApiHandler.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/restapi/zone/v1/ZoneApiHandler.java @@ -69,7 +69,7 @@ public class ZoneApiHandler extends LoggingRequestHandler { } private HttpResponse root(HttpRequest request) { - List<Environment> environments = zoneRegistry.zones().stream() + List<Environment> environments = zoneRegistry.zones().all().ids().stream() .map(ZoneId::environment) .distinct() .sorted(Comparator.comparing(Environment::value)) @@ -89,9 +89,7 @@ public class ZoneApiHandler extends LoggingRequestHandler { } private HttpResponse environment(HttpRequest request, Environment environment) { - List<ZoneId> zones = zoneRegistry.zones().stream() - .filter(zone -> zone.environment() == environment) - .collect(Collectors.toList()); + List<ZoneId> zones = zoneRegistry.zones().all().in(environment).ids(); Slime slime = new Slime(); Cursor root = slime.setArray(); zones.forEach(zone -> { diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/restapi/zone/v2/ZoneApiHandler.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/restapi/zone/v2/ZoneApiHandler.java index 84322cc1b1d..07d5370f3da 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/restapi/zone/v2/ZoneApiHandler.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/restapi/zone/v2/ZoneApiHandler.java @@ -91,13 +91,13 @@ public class ZoneApiHandler extends LoggingRequestHandler { Slime slime = new Slime(); Cursor root = slime.setObject(); Cursor uris = root.setArray("uris"); - zoneRegistry.zones().forEach(zone -> uris.addString(request.getUri() + zoneRegistry.zones().all().ids().forEach(zone -> uris.addString(request.getUri() .resolve("/zone/v2/") .resolve(zone.environment().value() + "/") .resolve(zone.region().value()) .toString())); Cursor zones = root.setArray("zones"); - zoneRegistry.zones().forEach(zone -> { + zoneRegistry.zones().all().ids().forEach(zone -> { Cursor object = zones.addObject(); object.setString("environment", zone.environment().value()); object.setString("region", zone.region().value()); diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/versions/VersionStatus.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/versions/VersionStatus.java index 876bd5fe029..f32155de4ea 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/versions/VersionStatus.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/versions/VersionStatus.java @@ -119,9 +119,9 @@ public class VersionStatus { } private static ListMap<Version, String> findConfigServerVersions(Controller controller) { - List<URI> configServers = controller.zoneRegistry().zones().stream() - // TODO: Filter properly. - .filter(zone -> ! zone.region().equals(RegionName.from("us-east-2a"))) + List<URI> configServers = controller.zoneRegistry().zones() + .controllerManaged() + .ids().stream() .flatMap(zone -> controller.getConfigServerUris(zone).stream()) .collect(Collectors.toList()); diff --git a/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/ZoneRegistryMock.java b/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/ZoneRegistryMock.java index af81f97002d..092e21fec14 100644 --- a/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/ZoneRegistryMock.java +++ b/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/ZoneRegistryMock.java @@ -9,6 +9,8 @@ import com.yahoo.config.provision.SystemName; import com.yahoo.vespa.hosted.controller.api.integration.zone.ZoneId; import com.yahoo.vespa.hosted.controller.api.identifiers.DeploymentId; import com.yahoo.vespa.hosted.controller.api.integration.zone.ZoneRegistry; +import com.yahoo.vespa.hosted.controller.api.integration.zone.Zones; +import com.yahoo.vespa.hosted.controller.api.integration.zone.ZonesMock; import java.net.URI; import java.time.Duration; @@ -62,8 +64,8 @@ public class ZoneRegistryMock extends AbstractComponent implements ZoneRegistry } @Override - public List<ZoneId> zones() { - return Collections.unmodifiableList(zones); + public Zones zones() { + return ZonesMock.from(Collections.unmodifiableList(zones)); } @Override |