summaryrefslogtreecommitdiffstats
path: root/orchestrator
diff options
context:
space:
mode:
authorJon Marius Venstad <jonmv@users.noreply.github.com>2022-04-29 18:29:21 +0200
committerGitHub <noreply@github.com>2022-04-29 18:29:21 +0200
commit1c30bf82ddc67d532d0efc9fff05a5c6096408f2 (patch)
tree81b1ab5659d1fc057f08084044a9a52fc05d99f5 /orchestrator
parent2c36f7c97ed9747101945c7958c7ec4be6763f6e (diff)
parent12d0c8aa162ad2ca497469e6371eebc45206d63b (diff)
Merge pull request #22373 from vespa-engine/jonmv/remove-last-controller-jersey-client
Jonmv/remove last controller jersey client
Diffstat (limited to 'orchestrator')
-rw-r--r--orchestrator/src/main/java/com/yahoo/vespa/orchestrator/controller/ClusterControllerClientImpl.java6
-rw-r--r--orchestrator/src/test/java/com/yahoo/vespa/orchestrator/controller/ClusterControllerClientImplTest.java8
2 files changed, 7 insertions, 7 deletions
diff --git a/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/controller/ClusterControllerClientImpl.java b/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/controller/ClusterControllerClientImpl.java
index 7c7dca3b03e..37a690bd2bd 100644
--- a/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/controller/ClusterControllerClientImpl.java
+++ b/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/controller/ClusterControllerClientImpl.java
@@ -142,9 +142,9 @@ public class ClusterControllerClientImpl implements ClusterControllerClient {
static byte[] stateChangeRequestBytes(ClusterControllerNodeState wantedState, Condition condition, boolean isProbe) {
Cursor root = new Slime().setObject();
- Cursor stateObject = root.setObject("user");
- stateObject.setString("reason", REQUEST_REASON);
- stateObject.setString("state", wantedState.getWireName());
+ Cursor userObject = root.setObject("state").setObject("user");
+ userObject.setString("reason", REQUEST_REASON);
+ userObject.setString("state", wantedState.getWireName());
root.setString("condition", condition.name());
if (isProbe) root.setBool("probe", true);
return Exceptions.uncheck(() -> SlimeUtils.toJsonBytes(root));
diff --git a/orchestrator/src/test/java/com/yahoo/vespa/orchestrator/controller/ClusterControllerClientImplTest.java b/orchestrator/src/test/java/com/yahoo/vespa/orchestrator/controller/ClusterControllerClientImplTest.java
index 2570a8035bb..b8e078c60d4 100644
--- a/orchestrator/src/test/java/com/yahoo/vespa/orchestrator/controller/ClusterControllerClientImplTest.java
+++ b/orchestrator/src/test/java/com/yahoo/vespa/orchestrator/controller/ClusterControllerClientImplTest.java
@@ -61,7 +61,7 @@ public class ClusterControllerClientImplTest {
wire.expect((url, body) -> {
assertEquals("http://host1:19050/cluster/v2/cc/storage/2?timeout=9.6",
url.asURI().toString());
- assertEquals("{\"user\":{\"reason\":\"Orchestrator\",\"state\":\"down\"},\"condition\":\"SAFE\"}",
+ assertEquals("{\"state\":{\"user\":{\"reason\":\"Orchestrator\",\"state\":\"down\"}},\"condition\":\"SAFE\"}",
body);
return "{ \"wasModified\": true }";
},
@@ -72,7 +72,7 @@ public class ClusterControllerClientImplTest {
wire.expect((url, body) -> {
assertEquals("http://host1:19050/cluster/v2/cc/storage/1?timeout=0.6",
url.asURI().toString());
- assertEquals("{\"user\":{\"reason\":\"Orchestrator\",\"state\":\"down\"},\"condition\":\"SAFE\"}",
+ assertEquals("{\"state\":{\"user\":{\"reason\":\"Orchestrator\",\"state\":\"down\"}},\"condition\":\"SAFE\"}",
body);
return "{ \"wasModified\": false, \"reason\": \"because\" }";
},
@@ -88,7 +88,7 @@ public class ClusterControllerClientImplTest {
wire.expect((url, body) -> {
assertEquals("http://host1:19050/cluster/v2/cc/storage/2?timeout=59.6",
url.asURI().toString());
- assertEquals("{\"user\":{\"reason\":\"Orchestrator\",\"state\":\"maintenance\"},\"condition\":\"SAFE\",\"probe\":true}",
+ assertEquals("{\"state\":{\"user\":{\"reason\":\"Orchestrator\",\"state\":\"maintenance\"}},\"condition\":\"SAFE\",\"probe\":true}",
body);
return "{ \"wasModified\": false, \"reason\": \"no reason\" }";
},
@@ -101,7 +101,7 @@ public class ClusterControllerClientImplTest {
wire.expect((url, body) -> {
assertEquals("http://host1:19050/cluster/v2/cc?timeout=299.6",
url.asURI().toString());
- assertEquals("{\"user\":{\"reason\":\"Orchestrator\",\"state\":\"up\"},\"condition\":\"FORCE\"}",
+ assertEquals("{\"state\":{\"user\":{\"reason\":\"Orchestrator\",\"state\":\"up\"}},\"condition\":\"FORCE\"}",
body);
return "{ \"message\": \":<\" }";
},