summaryrefslogtreecommitdiffstats
path: root/node-repository/src
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@gmail.com>2021-03-18 11:04:27 +0100
committerJon Bratseth <bratseth@gmail.com>2021-03-18 11:04:27 +0100
commit980a6180525633cf715d20cb965acc69474998d1 (patch)
treef7496c7ca9448fbb4a77eb95df63d936599130a3 /node-repository/src
parente9adf54ff957f0e21b26cc00b44b28f440dc4c05 (diff)
Move to ClusterModel
Diffstat (limited to 'node-repository/src')
-rw-r--r--node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/Autoscaler.java3
-rw-r--r--node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/ClusterModel.java6
2 files changed, 7 insertions, 2 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/Autoscaler.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/Autoscaler.java
index 321340331b1..9834f898113 100644
--- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/Autoscaler.java
+++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/Autoscaler.java
@@ -77,9 +77,8 @@ public class Autoscaler {
" nodes, but require from " + clusterNodes.size());
var currentAllocation = new AllocatableClusterResources(clusterNodes.asList(), nodeRepository, cluster.exclusive());
- var clusterTimeseries = metricsDb.getClusterTimeseries(application.id(), cluster.id());
var target = ResourceTarget.idealLoad(clusterModel.scalingDuration(),
- clusterTimeseries,
+ clusterModel.clusterTimeseries(),
clusterModel.nodeTimeseries(),
currentAllocation,
application,
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/ClusterModel.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/ClusterModel.java
index 198287ef1bb..32ddd52ca40 100644
--- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/ClusterModel.java
+++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/ClusterModel.java
@@ -26,6 +26,7 @@ public class ClusterModel {
// Lazily initialized members
private ClusterNodesTimeseries nodeTimeseries = null;
+ private ClusterTimeseries clusterTimeseries = null;
public ClusterModel(Application application,
Cluster cluster,
@@ -44,6 +45,11 @@ public class ClusterModel {
return nodeTimeseries = new ClusterNodesTimeseries(scalingDuration(), cluster, nodes, metricsDb);
}
+ public ClusterTimeseries clusterTimeseries() {
+ if (clusterTimeseries != null) return clusterTimeseries;
+ return clusterTimeseries = metricsDb.getClusterTimeseries(application.id(), cluster.id());
+ }
+
public boolean isStable() {
return isStable(nodes, nodeRepository);
}