diff options
author | Harald Musum <musum@yahooinc.com> | 2022-09-07 19:54:43 +0200 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2022-09-07 19:54:43 +0200 |
commit | 3ccd10630d013821abfa70a3fd8c1067ddb4eb54 (patch) | |
tree | 30453c972c21bb523162050bc7170ed4094c288b /clustercontroller-core/src/main | |
parent | 9ebb7848b51f05209ab735e05d115c55d08ade1a (diff) |
Remove unused and undocumented partition state request support
Diffstat (limited to 'clustercontroller-core/src/main')
3 files changed, 10 insertions, 92 deletions
diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/restapiv2/ClusterControllerStateRestAPI.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/restapiv2/ClusterControllerStateRestAPI.java index 60b60d5fc89..5ca76d40fe1 100644 --- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/restapiv2/ClusterControllerStateRestAPI.java +++ b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/restapiv2/ClusterControllerStateRestAPI.java @@ -2,7 +2,12 @@ package com.yahoo.vespa.clustercontroller.core.restapiv2; import com.yahoo.vespa.clustercontroller.core.RemoteClusterControllerTaskScheduler; -import com.yahoo.vespa.clustercontroller.core.restapiv2.requests.*; +import com.yahoo.vespa.clustercontroller.core.restapiv2.requests.ClusterListRequest; +import com.yahoo.vespa.clustercontroller.core.restapiv2.requests.ClusterStateRequest; +import com.yahoo.vespa.clustercontroller.core.restapiv2.requests.NodeStateRequest; +import com.yahoo.vespa.clustercontroller.core.restapiv2.requests.ServiceStateRequest; +import com.yahoo.vespa.clustercontroller.core.restapiv2.requests.SetNodeStateRequest; +import com.yahoo.vespa.clustercontroller.core.restapiv2.requests.SetNodeStatesForClusterRequest; import com.yahoo.vespa.clustercontroller.utils.staterestapi.StateRestAPI; import com.yahoo.vespa.clustercontroller.utils.staterestapi.errors.InternalFailure; import com.yahoo.vespa.clustercontroller.utils.staterestapi.errors.OtherMasterException; @@ -11,8 +16,6 @@ import com.yahoo.vespa.clustercontroller.utils.staterestapi.requests.SetUnitStat import com.yahoo.vespa.clustercontroller.utils.staterestapi.requests.UnitStateRequest; import com.yahoo.vespa.clustercontroller.utils.staterestapi.response.SetResponse; import com.yahoo.vespa.clustercontroller.utils.staterestapi.response.UnitResponse; - -import java.util.EnumSet; import java.util.Map; import java.util.Objects; import java.util.logging.Logger; @@ -86,10 +89,6 @@ public class ClusterControllerStateRestAPI implements StateRestAPI { public Request<? extends UnitResponse> visitNode(Id.Node id) { return new NodeStateRequest(id); } - @Override - public Request<? extends UnitResponse> visitPartition(Id.Partition id) { - return new PartitionStateRequest(id, EnumSet.of(VerboseReport.STATISTICS)); - } }); if (req instanceof ClusterListRequest) { log.fine("Got cluster list request"); diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/restapiv2/UnitPathResolver.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/restapiv2/UnitPathResolver.java index 9c32d0511bb..11fd5f39fad 100644 --- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/restapiv2/UnitPathResolver.java +++ b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/restapiv2/UnitPathResolver.java @@ -6,8 +6,6 @@ import com.yahoo.vespa.clustercontroller.core.RemoteClusterControllerTaskSchedul import com.yahoo.vespa.clustercontroller.utils.staterestapi.errors.MissingUnitException; import com.yahoo.vespa.clustercontroller.utils.staterestapi.errors.OperationNotSupportedForUnitException; import com.yahoo.vespa.clustercontroller.utils.staterestapi.errors.StateRestApiException; -import com.yahoo.vespa.clustercontroller.utils.staterestapi.response.UnitResponse; - import java.util.HashMap; import java.util.Map; @@ -19,16 +17,15 @@ public class UnitPathResolver<T> { Request<? extends T> visitCluster(Id.Cluster id) throws StateRestApiException; Request<? extends T> visitService(Id.Service id) throws StateRestApiException; Request<? extends T> visitNode(Id.Node id) throws StateRestApiException; - Request<? extends T> visitPartition(Id.Partition id) throws StateRestApiException; } public static abstract class AbstractVisitor<T> implements Visitor<T> { - private final String path[]; + private final String[] path; private final String failureMessage; - public AbstractVisitor(String path[], String failureMessage) { + public AbstractVisitor(String[] path, String failureMessage) { this.path = path; this.failureMessage = failureMessage; } @@ -40,7 +37,6 @@ public class UnitPathResolver<T> { public Request<? extends T> visitCluster(Id.Cluster id) throws StateRestApiException { return fail(); } public Request<? extends T> visitService(Id.Service id) throws StateRestApiException { return fail(); } public Request<? extends T> visitNode(Id.Node id) throws StateRestApiException { return fail(); } - public Request<? extends T> visitPartition(Id.Partition id) throws StateRestApiException { return fail(); } } @@ -50,7 +46,7 @@ public class UnitPathResolver<T> { this.fleetControllers = new HashMap<>(fleetControllers); } - public RemoteClusterControllerTaskScheduler resolveFleetController(String path[]) throws StateRestApiException { + public RemoteClusterControllerTaskScheduler resolveFleetController(String[] path) throws StateRestApiException { if (path.length == 0) return null; RemoteClusterControllerTaskScheduler fc = fleetControllers.get(path[0]); if (fc == null) { @@ -59,7 +55,7 @@ public class UnitPathResolver<T> { return fc; } - public Request<? extends T> visit(String path[], Visitor<T> visitor) throws StateRestApiException { + public Request<? extends T> visit(String[] path, Visitor<T> visitor) throws StateRestApiException { if (path.length == 0) { return visitor.visitGlobal(); } @@ -87,15 +83,6 @@ public class UnitPathResolver<T> { if (path.length == 3) { return visitor.visitNode(node); } - Id.Partition partition; - try{ - partition = new Id.Partition(node, Integer.valueOf(path[3])); - } catch (NumberFormatException e) { - throw new MissingUnitException(path, 3); - } - if (path.length == 4) { - return visitor.visitPartition(partition); - } throw new MissingUnitException(path, 4); } diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/restapiv2/requests/PartitionStateRequest.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/restapiv2/requests/PartitionStateRequest.java deleted file mode 100644 index 345a998e873..00000000000 --- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/restapiv2/requests/PartitionStateRequest.java +++ /dev/null @@ -1,68 +0,0 @@ -// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. -package com.yahoo.vespa.clustercontroller.core.restapiv2.requests; - -import com.yahoo.vdslib.state.NodeState; -import com.yahoo.vespa.clustercontroller.core.RemoteClusterControllerTask; -import com.yahoo.vespa.clustercontroller.core.hostinfo.Metrics; -import com.yahoo.vespa.clustercontroller.core.restapiv2.Id; -import com.yahoo.vespa.clustercontroller.core.restapiv2.Request; -import com.yahoo.vespa.clustercontroller.core.restapiv2.Response; -import com.yahoo.vespa.clustercontroller.utils.staterestapi.errors.StateRestApiException; - -import java.util.Set; -import java.util.logging.Logger; - -//TODO Remove once we have ensured that partition level is no longer used (it has never been) -public class PartitionStateRequest extends Request<Response.PartitionResponse> { - private static final Logger log = Logger.getLogger(PartitionStateRequest.class.getName()); - private final Id.Partition id; - private final Set<VerboseReport> verboseReports; - - public PartitionStateRequest(Id.Partition id, Set<VerboseReport> verboseReports) { - super(MasterState.MUST_BE_MASTER); - this.id = id; - this.verboseReports = verboseReports; - } - - @Override - public Response.PartitionResponse calculateResult(RemoteClusterControllerTask.Context context) - throws StateRestApiException { - Response.PartitionResponse result = new Response.PartitionResponse(); - if (verboseReports.contains(VerboseReport.STATISTICS)) { - fillInMetrics(context.cluster.getNodeInfo(id.getNode()).getHostInfo().getMetrics(), result); - } - NodeState nodeState = context.currentConsolidatedState.getNodeState(id.getNode()); - result.addState("generated", new Response.UnitStateImpl(nodeState)); - - return result; - } - - private static void fillInMetrics(Metrics metrics, Response.PartitionResponse result) { - for (Metrics.Metric metric: metrics.getMetrics()) { - fillInMetricValue(metric.getName(), metric.getValue(), result); - } - } - - private static void fillInMetricValue( - String name, Metrics.Value value, Response.PartitionResponse result) { - if (name.equals("vds.datastored.alldisks.docs")) { - if (value.getLast() == null) { - log.warning("Proper doc count value did not exist in value set."); - return; - } - result.addMetric("unique-document-count", value.getLast()); - } else if (name.equals("vds.datastored.alldisks.bytes")) { - if (value.getLast() == null) { - log.warning("Proper doc size value did not exist in value set."); - return; - } - result.addMetric("unique-document-total-size", value.getLast()); - } else if (name.equals("vds.datastored.alldisks.buckets")) { - if (value.getLast() == null) { - log.warning("Proper bucket count value did not exist in value set."); - return; - } - result.addMetric("bucket-count", value.getLast()); - } - } -} |