summaryrefslogtreecommitdiffstats
path: root/clustercontroller-core
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2022-08-13 19:54:17 +0200
committerHarald Musum <musum@yahooinc.com>2022-08-13 19:54:17 +0200
commit524aa1541cadc3ca9a8d4e19bfe6ddc608b0ade1 (patch)
treee17771f6b5e1b7a76158e5950d15c5d4d60a82f6 /clustercontroller-core
parentd29794a319a78daafc4e691b5f76432ecda32d5e (diff)
Simplify
Diffstat (limited to 'clustercontroller-core')
-rw-r--r--clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/FleetController.java12
-rw-r--r--clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/status/LegacyIndexPageRequestHandler.java21
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, "");