summaryrefslogtreecommitdiff
path: root/opendc-simulator/opendc-simulator-compute
diff options
context:
space:
mode:
Diffstat (limited to 'opendc-simulator/opendc-simulator-compute')
-rw-r--r--opendc-simulator/opendc-simulator-compute/src/main/java/org/opendc/simulator/compute/power/CarbonModel.java6
1 files changed, 6 insertions, 0 deletions
diff --git a/opendc-simulator/opendc-simulator-compute/src/main/java/org/opendc/simulator/compute/power/CarbonModel.java b/opendc-simulator/opendc-simulator-compute/src/main/java/org/opendc/simulator/compute/power/CarbonModel.java
index 3bbdba66..3cf36ece 100644
--- a/opendc-simulator/opendc-simulator-compute/src/main/java/org/opendc/simulator/compute/power/CarbonModel.java
+++ b/opendc-simulator/opendc-simulator-compute/src/main/java/org/opendc/simulator/compute/power/CarbonModel.java
@@ -133,6 +133,12 @@ public class CarbonModel extends FlowNode {
receiver.updateCarbonIntensity(this.current_fragment.getCarbonIntensity());
}
+ public double[] getForecast(int forecastSize) {
+ return this.fragments.subList(this.fragment_index + 1, this.fragment_index + forecastSize).stream()
+ .mapToDouble(CarbonFragment::getCarbonIntensity)
+ .toArray();
+ }
+
public static <T, U> List<U> castList(List<T> list, Class<U> clazz) {
List<U> result = new ArrayList<>();
for (T element : list) {