From 86d35fcec83057e346e4982b5a6908f25342a392 Mon Sep 17 00:00:00 2001 From: mjkwiatkowski Date: Sun, 15 Feb 2026 18:26:59 +0100 Subject: feat: opendc -> postgresql connection works --- .../kotlin/org/opendc/demo/DemoComputeMonitor.kt | 42 ++++++++++++++++++++++ 1 file changed, 42 insertions(+) create mode 100644 opendc-demo/src/main/kotlin/org/opendc/demo/DemoComputeMonitor.kt (limited to 'opendc-demo/src/main/kotlin/org/opendc/demo/DemoComputeMonitor.kt') diff --git a/opendc-demo/src/main/kotlin/org/opendc/demo/DemoComputeMonitor.kt b/opendc-demo/src/main/kotlin/org/opendc/demo/DemoComputeMonitor.kt new file mode 100644 index 00000000..f59f90a1 --- /dev/null +++ b/opendc-demo/src/main/kotlin/org/opendc/demo/DemoComputeMonitor.kt @@ -0,0 +1,42 @@ +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 = "" +} -- cgit v1.2.3