aboutsummaryrefslogtreecommitdiffstats
path: root/node-repository/src
diff options
context:
space:
mode:
authorMartin Polden <mpolden@mpolden.no>2018-08-10 10:02:02 +0200
committerMartin Polden <mpolden@mpolden.no>2018-08-10 11:25:42 +0200
commit24c7657b8b6e55ad1d0616073f44c5a0498c4c44 (patch)
treeb17626f4bd291dd0eab0be08bfa46b038da92ac8 /node-repository/src
parenta6f9ea782e9921498c6a890697824d7d16065f24 (diff)
Extract hostnamesAsString method
Diffstat (limited to 'node-repository/src')
-rw-r--r--node-repository/src/main/java/com/yahoo/vespa/hosted/provision/restapi/v2/NodesApiHandler.java20
1 files changed, 11 insertions, 9 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/restapi/v2/NodesApiHandler.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/restapi/v2/NodesApiHandler.java
index 54202a15971..1802a5d5b65 100644
--- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/restapi/v2/NodesApiHandler.java
+++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/restapi/v2/NodesApiHandler.java
@@ -114,18 +114,15 @@ public class NodesApiHandler extends LoggingRequestHandler {
}
else if (path.startsWith("/nodes/v2/state/failed/")) {
List<Node> failedNodes = nodeRepository.failRecursively(lastElement(path), Agent.operator, "Failed through the nodes/v2 API");
- String failedHostnames = failedNodes.stream().map(Node::hostname).sorted().collect(Collectors.joining(", "));
- return new MessageResponse("Moved " + failedHostnames + " to failed");
+ return new MessageResponse("Moved " + hostnamesAsString(failedNodes) + " to failed");
}
else if (path.startsWith("/nodes/v2/state/parked/")) {
List<Node> parkedNodes = nodeRepository.parkRecursively(lastElement(path), Agent.operator, "Parked through the nodes/v2 API");
- String parkedHostnames = parkedNodes.stream().map(Node::hostname).sorted().collect(Collectors.joining(", "));
- return new MessageResponse("Moved " + parkedHostnames + " to parked");
+ return new MessageResponse("Moved " + hostnamesAsString(parkedNodes) + " to parked");
}
else if (path.startsWith("/nodes/v2/state/dirty/")) {
List<Node> dirtiedNodes = nodeRepository.dirtyRecursively(lastElement(path), Agent.operator, "Dirtied through the nodes/v2 API");
- String dirtiedHostnames = dirtiedNodes.stream().map(Node::hostname).sorted().collect(Collectors.joining(", "));
- return new MessageResponse("Moved " + dirtiedHostnames + " to dirty");
+ return new MessageResponse("Moved " + hostnamesAsString(dirtiedNodes) + " to dirty");
}
else if (path.startsWith("/nodes/v2/state/active/")) {
nodeRepository.reactivate(lastElement(path), Agent.operator, "Reactivated through nodes/v2 API");
@@ -230,7 +227,7 @@ public class NodesApiHandler extends LoggingRequestHandler {
nodeTypeFromSlime(inspector.field(nodeTypeKey)));
}
- private NodeType nodeTypeFromSlime(Inspector object) {
+ private static NodeType nodeTypeFromSlime(Inspector object) {
if (! object.valid()) return NodeType.tenant; // default
switch (object.asString()) {
case "tenant" : return NodeType.tenant;
@@ -255,7 +252,7 @@ public class NodesApiHandler extends LoggingRequestHandler {
return filter;
}
- private String lastElement(String path) {
+ private static String lastElement(String path) {
if (path.endsWith("/"))
path = path.substring(0, path.length()-1);
int lastSlash = path.lastIndexOf("/");
@@ -263,7 +260,7 @@ public class NodesApiHandler extends LoggingRequestHandler {
return path.substring(lastSlash + 1, path.length());
}
- private boolean isPatchOverride(HttpRequest request) {
+ private static boolean isPatchOverride(HttpRequest request) {
// Since Jersey's HttpUrlConnector does not support PATCH we support this by override this on POST requests.
String override = request.getHeader("X-HTTP-Method-Override");
if (override != null) {
@@ -298,4 +295,9 @@ public class NodesApiHandler extends LoggingRequestHandler {
return new MessageResponse("Set version for " + nodeType + " to " + version.toFullString());
}
+
+ private static String hostnamesAsString(List<Node> nodes) {
+ return nodes.stream().map(Node::hostname).sorted().collect(Collectors.joining(", "));
+ }
+
}