feat: managed to retrieve metric-by-metric from Redis in real timeHEADmaster

2 files changed, 2 insertions, 3 deletions

diff --git a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/scheduler/SmartScheduler.kt b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/scheduler/SmartScheduler.kt
index baadd806..0edd97cf 100644
--- a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/scheduler/SmartScheduler.kt
+++ b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/scheduler/SmartScheduler.kt
@@ -60,9 +60,6 @@ public class SmartScheduler : ComputeScheduler {
         return SchedulingResult(SchedulingResultType.EMPTY)
     }
 
-    // Benefits of a digital twin: during operations you make sure what is happening in the real world.
-    // The use-case is making split-second automated decisions before operators can make them.
-    // Make a strong case for making a Digital Twin.
     override fun removeTask(
         task: ServiceTask,
         host: HostView?,
diff --git a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/telemetry/KafkaComputeMonitor.kt b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/telemetry/KafkaComputeMonitor.kt
index c8368af2..ddd4a28a 100644
--- a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/telemetry/KafkaComputeMonitor.kt
+++ b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/telemetry/KafkaComputeMonitor.kt
@@ -47,6 +47,8 @@ public class KafkaComputeMonitor : ComputeMonitor {
                     .setTasksactive(reader.tasksActive)
                     .setCpuutilization(reader.cpuUtilization)
                     .setEnergyusage(reader.energyUsage)
+                    .setUptime(reader.uptime.toDouble())
+                    .setDowntime(reader.downtime.toDouble())
                     .build()
             this.send(packet)