summaryrefslogtreecommitdiffstats
path: root/controller-server
diff options
context:
space:
mode:
authorJon Marius Venstad <jvenstad@yahoo-inc.com>2017-12-15 09:17:47 +0100
committerJon Marius Venstad <jvenstad@yahoo-inc.com>2017-12-15 09:17:47 +0100
commit8d82aa33667c4b401e693624bd40bf2061b64238 (patch)
tree075707a6a6dca23aabb2d333c5192b777459df4c /controller-server
parenta3fc6158428e18169ee379f405ee35181e71c443 (diff)
Changes to Zones, a MockZones and some usages
Diffstat (limited to 'controller-server')
-rw-r--r--controller-server/src/main/java/com/yahoo/vespa/hosted/controller/proxy/ConfigServerRestExecutorImpl.java6
-rw-r--r--controller-server/src/main/java/com/yahoo/vespa/hosted/controller/restapi/zone/v1/ZoneApiHandler.java6
-rw-r--r--controller-server/src/main/java/com/yahoo/vespa/hosted/controller/restapi/zone/v2/ZoneApiHandler.java4
-rw-r--r--controller-server/src/main/java/com/yahoo/vespa/hosted/controller/versions/VersionStatus.java6
-rw-r--r--controller-server/src/test/java/com/yahoo/vespa/hosted/controller/ZoneRegistryMock.java6
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