diff options
author | Martin Polden <mpolden@mpolden.no> | 2022-02-11 13:14:38 +0100 |
---|---|---|
committer | Martin Polden <mpolden@mpolden.no> | 2022-02-16 08:44:02 +0100 |
commit | 361a48b3b924e07e9157db1d0bc80ec2cc841215 (patch) | |
tree | 0cf1fae86f69a185f72f7347df476b9ad7b5d0b7 /routing-generator/src/main | |
parent | 80bf8df285a1ecf1f5f253eeb4e49f600fcbad9a (diff) |
Switch to /routing/v2/status in RoutingStatusClient
Diffstat (limited to 'routing-generator/src/main')
-rw-r--r-- | routing-generator/src/main/java/com/yahoo/vespa/hosted/routing/status/RoutingStatusClient.java | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/routing-generator/src/main/java/com/yahoo/vespa/hosted/routing/status/RoutingStatusClient.java b/routing-generator/src/main/java/com/yahoo/vespa/hosted/routing/status/RoutingStatusClient.java index a4a37277f5a..0f2368d944d 100644 --- a/routing-generator/src/main/java/com/yahoo/vespa/hosted/routing/status/RoutingStatusClient.java +++ b/routing-generator/src/main/java/com/yahoo/vespa/hosted/routing/status/RoutingStatusClient.java @@ -5,7 +5,7 @@ import com.google.inject.Inject; import com.yahoo.component.AbstractComponent; import com.yahoo.lang.CachedSupplier; import com.yahoo.routing.config.ZoneConfig; -import com.yahoo.slime.Inspector; +import com.yahoo.slime.Cursor; import com.yahoo.slime.Slime; import com.yahoo.slime.SlimeUtils; import com.yahoo.vespa.athenz.api.AthenzService; @@ -91,11 +91,12 @@ public class RoutingStatusClient extends AbstractComponent implements RoutingSta } private Status status() { - Set<String> inactiveDeployments = SlimeUtils.entriesStream(get("/routing/v1/status").get()) - .map(Inspector::asString) + Slime slime = get("/routing/v2/status"); + Cursor root = slime.get(); + Set<String> inactiveDeployments = SlimeUtils.entriesStream(root.field("inactiveDeployments")) + .map(inspector -> inspector.field("upstreamName").asString()) .collect(Collectors.toUnmodifiableSet()); - boolean zoneActive = get("/routing/v1/status/zone").get().field("status").asString() - .equalsIgnoreCase("in"); + boolean zoneActive = root.field("zoneActive").asBool(); return new Status(zoneActive, inactiveDeployments); } |