summaryrefslogtreecommitdiff
path: root/opendc-demo/src/main/kotlin/org
diff options
context:
space:
mode:
Diffstat (limited to 'opendc-demo/src/main/kotlin/org')
-rw-r--r--opendc-demo/src/main/kotlin/org/opendc/demo/DemoComputeMonitor.kt42
-rw-r--r--opendc-demo/src/main/kotlin/org/opendc/demo/RunRequest.kt2
2 files changed, 0 insertions, 44 deletions
diff --git a/opendc-demo/src/main/kotlin/org/opendc/demo/DemoComputeMonitor.kt b/opendc-demo/src/main/kotlin/org/opendc/demo/DemoComputeMonitor.kt
deleted file mode 100644
index f59f90a1..00000000
--- a/opendc-demo/src/main/kotlin/org/opendc/demo/DemoComputeMonitor.kt
+++ /dev/null
@@ -1,42 +0,0 @@
-package org.opendc.demo
-
-import com.fasterxml.jackson.databind.ObjectMapper
-import org.apache.kafka.clients.producer.ProducerRecord
-import org.opendc.compute.simulator.telemetry.ComputeMonitor
-import org.opendc.compute.simulator.telemetry.table.host.HostTableReader
-import java.time.Instant
-
-public class DemoComputeMonitor: ComputeMonitor {
- public val metrics : MonitoringMetrics = MonitoringMetrics()
-
- @Override
- override fun record(reader: HostTableReader) {
- metrics.timestamp = reader.timestamp.toEpochMilli()
- metrics.tasksActive = reader.tasksActive
- metrics.clusterName = reader.hostInfo.clusterName
-
- try{
- val objectMapper = ObjectMapper()
- val jsonBytes = objectMapper.writeValueAsBytes(metrics)
- println(metrics.clusterName)
- }
-
- catch(e: Exception){
- println("${e.message}")
- }
- }
-
-}
-public class MonitoringMetrics {
- public var timestamp: Long = 0
- public var tasksActive : Int = 0
- public var cpuUsage : Double = 0.0
- public var cpuUtilisation: Double = 0.0
- public var cpuActiveTime : Long = 0
- public var cpuIdleTime: Long = 0
- public var cpuLostTime: Long = 0
- public var energyUsage: Double = 0.0
- public var uptime: Long = 0
- public var powerDraw: Double = 0.0
- public var clusterName: String = ""
-}
diff --git a/opendc-demo/src/main/kotlin/org/opendc/demo/RunRequest.kt b/opendc-demo/src/main/kotlin/org/opendc/demo/RunRequest.kt
index e24a0af5..c4dfb7ca 100644
--- a/opendc-demo/src/main/kotlin/org/opendc/demo/RunRequest.kt
+++ b/opendc-demo/src/main/kotlin/org/opendc/demo/RunRequest.kt
@@ -23,7 +23,5 @@
package org.opendc.demo
public fun runRequest(request: String) {
- // https://github.com/am-i-helpful/opendc/blob/master/opendc-oda/opendc-oda-experiments/src/main/kotlin/org/opendc/oda/experimentrunner/ODAComputeMonitor.kt
- // Do this here
println("The request is $request\n")
}