Skip to content

Commit

Permalink
Removing unncessary methods after refactoring
Browse files Browse the repository at this point in the history
Signed-off-by: Pranshu Shukla <[email protected]>
  • Loading branch information
Pranshu-S committed Jul 18, 2024
1 parent 5fffc47 commit a43d725
Showing 1 changed file with 0 additions and 12 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -209,18 +209,6 @@ protected void resolveRequest(NodesRequest request, ClusterState clusterState) {
request.setConcreteNodes(Arrays.stream(nodesIds).map(clusterState.nodes()::get).toArray(DiscoveryNode[]::new));
}

/**
* Returns the concrete nodes from the request node ids which will be later used for routing requests to nodes.
* @param request Requests extended from {@link NodesRequest} which contains target nodeIDs.
* @param clusterState Cluster State fetched from {@link ClusterService}
* @return DiscoveryNode[] which is the collection of {@link DiscoveryNode} representation of NodeIDs from the request
**/
protected DiscoveryNode[] getConcreteNodes(NodesRequest request, ClusterState clusterState) {
assert request.concreteNodes() == null : "request concreteNodes shouldn't be set";
String[] nodesIds = clusterState.nodes().resolveNodes(request.nodesIds());
return Arrays.stream(nodesIds).map(clusterState.nodes()::get).toArray(DiscoveryNode[]::new);
}

/**
* Get a backwards compatible transport action name
*/
Expand Down

0 comments on commit a43d725

Please sign in to comment.