diff options
Diffstat (limited to 'controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/CostReportMaintainer.java')
-rw-r--r-- | controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/CostReportMaintainer.java | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/CostReportMaintainer.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/CostReportMaintainer.java index 77febb71ca6..2298c3c92fe 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/CostReportMaintainer.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/CostReportMaintainer.java @@ -7,6 +7,7 @@ import com.yahoo.vespa.hosted.controller.Controller; import com.yahoo.vespa.hosted.controller.api.integration.noderepository.NodeRepositoryClientInterface; import com.yahoo.vespa.hosted.controller.restapi.cost.CostCalculator; import com.yahoo.vespa.hosted.controller.restapi.cost.CostReportConsumer; +import com.yahoo.vespa.hosted.controller.restapi.cost.config.SelfHostedCostConfig; import java.time.Clock; import java.time.Duration; @@ -26,6 +27,7 @@ public class CostReportMaintainer extends Maintainer { private final CostReportConsumer consumer; private final NodeRepositoryClientInterface nodeRepository; private final Clock clock; + private final SelfHostedCostConfig selfHostedCostConfig; @Inject @SuppressWarnings("WeakerAccess") @@ -33,15 +35,17 @@ public class CostReportMaintainer extends Maintainer { CostReportConsumer consumer, JobControl jobControl, NodeRepositoryClientInterface nodeRepository, - Clock clock) { + Clock clock, + SelfHostedCostConfig selfHostedCostConfig) { super(controller, interval, jobControl, "CostReportMaintainer", EnumSet.of(SystemName.main)); this.consumer = consumer; this.nodeRepository = Objects.requireNonNull(nodeRepository, "node repository must be non-null"); this.clock = clock; + this.selfHostedCostConfig = selfHostedCostConfig; } @Override protected void maintain() { - consumer.Consume(CostCalculator.toCsv(CostCalculator.calculateCost(nodeRepository, controller(), clock))); + consumer.Consume(CostCalculator.toCsv(CostCalculator.calculateCost(nodeRepository, controller(), clock, selfHostedCostConfig))); } } |