From 4562f52c9b540944200b33d4ffbd60b3cbc5ee79 Mon Sep 17 00:00:00 2001 From: mjkwiatkowski Date: Wed, 17 Jun 2026 18:08:56 +0200 Subject: feat: managed to retrieve metric-by-metric from Redis in real time --- .../main/kotlin/org/opendc/experiments/base/runner/ExperimentCli.kt | 2 +- .../kotlin/org/opendc/experiments/base/runner/ExperimentListener.kt | 5 +++-- 2 files changed, 4 insertions(+), 3 deletions(-) (limited to 'opendc-experiments/opendc-experiments-base/src/main/kotlin') diff --git a/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ExperimentCli.kt b/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ExperimentCli.kt index 1fe597ea..55aed21b 100644 --- a/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ExperimentCli.kt +++ b/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ExperimentCli.kt @@ -49,7 +49,7 @@ internal class ExperimentCommand : CliktCommand(name = "experiment") { override fun run() { try { val experiment = getExperiment(experimentPath) - HTTPClient.getInstance()?.sendExperiment(experimentPath) + //HTTPClient.getInstance()?.sendExperiment(experimentPath) runExperiment(experiment) } catch (e: IOException) { println("${e.message}") diff --git a/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ExperimentListener.kt b/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ExperimentListener.kt index de759c0f..c221543d 100644 --- a/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ExperimentListener.kt +++ b/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ExperimentListener.kt @@ -14,6 +14,7 @@ import org.opendc.common.utils.Redis */ public fun runListener() { PostgresqlDB() - Redis().run() + val redisClient = Redis.getInstance() + redisClient?.readOne() JavalinRunner() -} \ No newline at end of file +} -- cgit v1.2.3