diff options
| author | jonmv <venstad@gmail.com> | 2022-04-29 18:23:02 +0200 |
|---|---|---|
| committer | jonmv <venstad@gmail.com> | 2022-04-29 18:23:02 +0200 |
| commit | 12d0c8aa162ad2ca497469e6371eebc45206d63b (patch) | |
| tree | 3126e2e5095525ce3591c82f97ed18c42a63dccb /orchestrator | |
| parent | 5d5f5b5996d5acd10490692e1faa65c2b180008a (diff) | |
Fix serialization of state request
Diffstat (limited to 'orchestrator')
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\": \":<\" }"; }, |