diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2019-11-04 13:08:33 +0100 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2019-11-04 14:42:54 +0100 |
commit | 50eee084e0b73d6eadd50ac675bb24f1e39c51ac (patch) | |
tree | 20827194697d1be0c81ae9f4ee4d85131feafa5a /controller-server/src/main/java | |
parent | 4eef577d86c364830bdac60324a6981aaf02daf0 (diff) |
Let rotations be active in DeploymentContext
Diffstat (limited to 'controller-server/src/main/java')
-rw-r--r-- | controller-server/src/main/java/com/yahoo/vespa/hosted/controller/restapi/application/ApplicationApiHandler.java | 19 |
1 files changed, 9 insertions, 10 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/restapi/application/ApplicationApiHandler.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/restapi/application/ApplicationApiHandler.java index e55b08d0b4a..48e72f8ad2c 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/restapi/application/ApplicationApiHandler.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/restapi/application/ApplicationApiHandler.java @@ -1116,16 +1116,15 @@ public class ApplicationApiHandler extends LoggingRequestHandler { Slime slime = new Slime(); Cursor array = slime.setObject().setArray("globalrotationoverride"); - Map<RoutingEndpoint, EndpointStatus> status = controller.applications().globalRotationStatus(deploymentId); - for (RoutingEndpoint endpoint : status.keySet()) { - EndpointStatus currentStatus = status.get(endpoint); - array.addString(endpoint.upstreamName()); - Cursor statusObject = array.addObject(); - statusObject.setString("status", currentStatus.getStatus().name()); - statusObject.setString("reason", currentStatus.getReason() == null ? "" : currentStatus.getReason()); - statusObject.setString("agent", currentStatus.getAgent() == null ? "" : currentStatus.getAgent()); - statusObject.setLong("timestamp", currentStatus.getEpoch()); - } + controller.applications().globalRotationStatus(deploymentId) + .forEach((endpoint, status) -> { + array.addString(endpoint.upstreamName()); + Cursor statusObject = array.addObject(); + statusObject.setString("status", status.getStatus().name()); + statusObject.setString("reason", status.getReason() == null ? "" : status.getReason()); + statusObject.setString("agent", status.getAgent() == null ? "" : status.getAgent()); + statusObject.setLong("timestamp", status.getEpoch()); + }); return new SlimeJsonResponse(slime); } |