diff options
Diffstat (limited to 'opendc-demo')
| -rw-r--r-- | opendc-demo/build.gradle.kts | 4 | ||||
| -rw-r--r-- | opendc-demo/src/main/kotlin/org/opendc/demo/DemoComputeMonitor.kt | 42 | ||||
| -rw-r--r-- | opendc-demo/src/main/kotlin/org/opendc/demo/RunRequest.kt | 2 |
3 files changed, 0 insertions, 48 deletions
diff --git a/opendc-demo/build.gradle.kts b/opendc-demo/build.gradle.kts index 02972f44..d5a84120 100644 --- a/opendc-demo/build.gradle.kts +++ b/opendc-demo/build.gradle.kts @@ -28,9 +28,5 @@ plugins { } dependencies { - // Source: https://mvnrepository.com/artifact/org.apache.kafka/kafka-clients - implementation("org.apache.kafka:kafka-clients:4.1.1") - implementation(libs.jackson.core) implementation(project(mapOf("path" to "::opendc-compute:opendc-compute-simulator"))) - } 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") } |
