From 8d899e29dbd757f6df320212d6e0d77ce8216ab9 Mon Sep 17 00:00:00 2001
From: Fabian Mastenbroek <mail.fabianm@gmail.com>
Date: Tue, 14 Sep 2021 15:38:38 +0200
Subject: refactor(telemetry): Standardize compute scheduler metrics

This change updates the OpenDC compute service implementation with
multiple meters that follow the OpenTelemetry conventions.
---
 .../org/opendc/experiments/capelin/Portfolio.kt    | 11 +++++----
 .../export/parquet/ParquetServiceDataWriter.kt     | 28 +++++++++++-----------
 2 files changed, 20 insertions(+), 19 deletions(-)

(limited to 'opendc-experiments/opendc-experiments-capelin/src/main')

diff --git a/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/Portfolio.kt b/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/Portfolio.kt
index f7f9336e..3ec424f1 100644
--- a/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/Portfolio.kt
+++ b/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/Portfolio.kt
@@ -153,11 +153,12 @@ abstract class Portfolio(name: String) : Experiment(name) {
 
         val monitorResults = collectServiceMetrics(clock.millis(), simulator.producers[0])
         logger.debug {
-            "Finish " +
-                "SUBMIT=${monitorResults.instanceCount} " +
-                "FAIL=${monitorResults.failedInstanceCount} " +
-                "QUEUE=${monitorResults.queuedInstanceCount} " +
-                "RUNNING=${monitorResults.activeHostCount}"
+            "Scheduler " +
+                "Success=${monitorResults.attemptsSuccess} " +
+                "Failure=${monitorResults.attemptsFailure} " +
+                "Error=${monitorResults.attemptsError} " +
+                "Pending=${monitorResults.serversPending} " +
+                "Active=${monitorResults.serversActive}"
         }
     }
 }
diff --git a/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/export/parquet/ParquetServiceDataWriter.kt b/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/export/parquet/ParquetServiceDataWriter.kt
index e1428fe7..29b48878 100644
--- a/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/export/parquet/ParquetServiceDataWriter.kt
+++ b/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/export/parquet/ParquetServiceDataWriter.kt
@@ -36,13 +36,13 @@ public class ParquetServiceDataWriter(path: File, bufferSize: Int) :
 
     override fun convert(builder: GenericRecordBuilder, data: ServiceData) {
         builder["timestamp"] = data.timestamp
-        builder["host_total_count"] = data.hostCount
-        builder["host_available_count"] = data.activeHostCount
-        builder["instance_total_count"] = data.instanceCount
-        builder["instance_active_count"] = data.runningInstanceCount
-        builder["instance_inactive_count"] = data.finishedInstanceCount
-        builder["instance_waiting_count"] = data.queuedInstanceCount
-        builder["instance_failed_count"] = data.failedInstanceCount
+        builder["hosts_up"] = data.hostsUp
+        builder["hosts_down"] = data.hostsDown
+        builder["servers_pending"] = data.serversPending
+        builder["servers_active"] = data.serversActive
+        builder["attempts_success"] = data.attemptsSuccess
+        builder["attempts_failure"] = data.attemptsFailure
+        builder["attempts_error"] = data.attemptsError
     }
 
     override fun toString(): String = "service-writer"
@@ -53,13 +53,13 @@ public class ParquetServiceDataWriter(path: File, bufferSize: Int) :
             .namespace("org.opendc.telemetry.compute")
             .fields()
             .requiredLong("timestamp")
-            .requiredInt("host_total_count")
-            .requiredInt("host_available_count")
-            .requiredInt("instance_total_count")
-            .requiredInt("instance_active_count")
-            .requiredInt("instance_inactive_count")
-            .requiredInt("instance_waiting_count")
-            .requiredInt("instance_failed_count")
+            .requiredInt("hosts_up")
+            .requiredInt("hosts_down")
+            .requiredInt("servers_pending")
+            .requiredInt("servers_active")
+            .requiredInt("attempts_success")
+            .requiredInt("attempts_failure")
+            .requiredInt("attempts_error")
             .endRecord()
     }
 }
-- 
cgit v1.2.3