diff options
author | Harald Musum <musum@yahooinc.com> | 2022-08-13 19:54:17 +0200 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2022-08-13 19:54:17 +0200 |
commit | 524aa1541cadc3ca9a8d4e19bfe6ddc608b0ade1 (patch) | |
tree | e17771f6b5e1b7a76158e5950d15c5d4d60a82f6 /clustercontroller-core | |
parent | d29794a319a78daafc4e691b5f76432ecda32d5e (diff) |
Simplify
Diffstat (limited to 'clustercontroller-core')
2 files changed, 12 insertions, 21 deletions
diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/FleetController.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/FleetController.java index 4097810b633..ac33398120f 100644 --- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/FleetController.java +++ b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/FleetController.java @@ -22,7 +22,6 @@ import com.yahoo.vespa.clustercontroller.core.status.ClusterStateRequestHandler; import com.yahoo.vespa.clustercontroller.core.status.LegacyIndexPageRequestHandler; import com.yahoo.vespa.clustercontroller.core.status.LegacyNodePageRequestHandler; import com.yahoo.vespa.clustercontroller.core.status.NodeHealthRequestHandler; -import com.yahoo.vespa.clustercontroller.core.status.RunDataExtractor; import com.yahoo.vespa.clustercontroller.core.status.statuspage.StatusPageResponse; import com.yahoo.vespa.clustercontroller.core.status.statuspage.StatusPageServer; import com.yahoo.vespa.clustercontroller.core.status.statuspage.StatusPageServerInterface; @@ -101,13 +100,6 @@ public class FleetController implements NodeListener, SlobrokListener, SystemSta // deriving is done. private Set<String> configuredBucketSpaces = Collections.emptySet(); - private final RunDataExtractor dataExtractor = new RunDataExtractor() { - @Override - public FleetControllerOptions getOptions() { return options; } - @Override - public ContentCluster getCluster() { return cluster; } - }; - public FleetController(FleetControllerContext context, Timer timer, EventLog eventLog, @@ -155,8 +147,7 @@ public class FleetController implements NodeListener, SlobrokListener, SystemSta new ClusterStateRequestHandler(stateVersionTracker)); this.statusRequestRouter.addHandler( "^/$", - new LegacyIndexPageRequestHandler(timer, cluster, masterElectionHandler, stateVersionTracker, eventLog, - timer.getCurrentTimeInMillis(), dataExtractor)); + new LegacyIndexPageRequestHandler(timer, cluster, masterElectionHandler, stateVersionTracker, eventLog, options)); propagateOptions(); } @@ -1240,4 +1231,5 @@ public class FleetController implements NodeListener, SlobrokListener, SystemSta public EventLog getEventLog() { return eventLog; } + } diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/status/LegacyIndexPageRequestHandler.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/status/LegacyIndexPageRequestHandler.java index 96dc114c734..4f20b3d0cdc 100644 --- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/status/LegacyIndexPageRequestHandler.java +++ b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/status/LegacyIndexPageRequestHandler.java @@ -36,22 +36,21 @@ public class LegacyIndexPageRequestHandler implements StatusPageServer.RequestHa private final StateVersionTracker stateVersionTracker; private final EventLog eventLog; private final long startedTime; - private final RunDataExtractor data; + private final FleetControllerOptions options; public LegacyIndexPageRequestHandler(Timer timer, ContentCluster cluster, MasterElectionHandler masterElectionHandler, StateVersionTracker stateVersionTracker, EventLog eventLog, - long startedTime, - RunDataExtractor data) { + FleetControllerOptions options) { this.timer = timer; this.cluster = cluster; this.masterElectionHandler = masterElectionHandler; this.stateVersionTracker = stateVersionTracker; this.eventLog = eventLog; - this.startedTime = startedTime; - this.data = data; + this.startedTime = timer.getCurrentTimeInMillis(); + this.options = options; } @Override @@ -63,7 +62,7 @@ public class LegacyIndexPageRequestHandler implements StatusPageServer.RequestHa response.setContentType("text/html"); StringBuilder content = new StringBuilder(); content.append("<!-- Answer to request " + request + " -->\n"); - response.writeHtmlHeader(content, cluster.getName() + " Cluster Controller " + data.getOptions().fleetControllerIndex + " Status Page"); + response.writeHtmlHeader(content, cluster.getName() + " Cluster Controller " + options.fleetControllerIndex + " Status Page"); content.append("<p><font size=\"-1\">") .append(" [ <a href=\"#config\">Current config</a>") .append(" | <a href=\"#clusterstates\">Cluster states</a>") @@ -72,19 +71,19 @@ public class LegacyIndexPageRequestHandler implements StatusPageServer.RequestHa content.append("<table><tr><td>UTC time when creating this page:</td><td align=\"right\">").append(RealTimer.printDateNoMilliSeconds(currentTime, tz)).append("</td></tr>"); //content.append("<tr><td>Fleetcontroller version:</td><td align=\"right\">" + Vtag.V_TAG_PKG + "</td></tr/>"); content.append("<tr><td>Cluster controller uptime:</td><td align=\"right\">" + RealTimer.printDuration(currentTime - startedTime) + "</td></tr></table>"); - if (masterElectionHandler.isAmongNthFirst(data.getOptions().stateGatherCount)) { + if (masterElectionHandler.isAmongNthFirst(options.stateGatherCount)) { // Table overview of all the nodes - writeHtmlState(cluster, content, timer, stateVersionTracker, data.getOptions(), eventLog); + writeHtmlState(cluster, content, timer, stateVersionTracker, options, eventLog); // Current cluster state and cluster state history writeHtmlState(stateVersionTracker, content); } else { // Overview of current config - data.getOptions().writeHtmlState(content); + options.writeHtmlState(content); } // State of master election - masterElectionHandler.writeHtmlState(content, data.getOptions().stateGatherCount); + masterElectionHandler.writeHtmlState(content, options.stateGatherCount); // Overview of current config - data.getOptions().writeHtmlState(content); + options.writeHtmlState(content); // Event log eventLog.writeHtmlState(content, null); response.writeHtmlFooter(content, ""); |