From 8bae0f3053a53aac9d483ae97d99f2e7e80b42ef Mon Sep 17 00:00:00 2001
From: Fabian Mastenbroek <mail.fabianm@gmail.com>
Date: Wed, 1 Sep 2021 22:30:39 +0200
Subject: refactor(capelin): Migrate trace reader to new trace API

This change updates the trace reading classes in the Capelin experiment
to use the new trace API in order to re-use many of the trace reading
parts.
---
 .../kotlin/org/opendc/trace/ResourceColumns.kt     | 22 ++++++++++++++++++
 .../org/opendc/trace/ResourceStateColumns.kt       | 26 ++++++++++++++++++++++
 2 files changed, 48 insertions(+)

(limited to 'opendc-trace/opendc-trace-api')

diff --git a/opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace/ResourceColumns.kt b/opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace/ResourceColumns.kt
index 65055762..8945823a 100644
--- a/opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace/ResourceColumns.kt
+++ b/opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace/ResourceColumns.kt
@@ -23,7 +23,29 @@
 @file:JvmName("ResourceColumns")
 package org.opendc.trace
 
+import java.time.Instant
+
 /**
  * Identifier of the resource.
  */
 public val RESOURCE_ID: TableColumn<String> = stringColumn("resource:id")
+
+/**
+ * Start time for the resource.
+ */
+public val RESOURCE_START_TIME: TableColumn<Instant> = TableColumn("resource:start_time", Instant::class.java)
+
+/**
+ * End time for the resource.
+ */
+public val RESOURCE_END_TIME: TableColumn<Instant> = TableColumn("resource:end_time", Instant::class.java)
+
+/**
+ * Number of CPUs for the resource.
+ */
+public val RESOURCE_NCPUS: TableColumn<Int> = intColumn("resource:num_cpus")
+
+/**
+ * Memory capacity for the resource.
+ */
+public val RESOURCE_MEM_CAPACITY: TableColumn<Double> = doubleColumn("resource:mem_capacity")
diff --git a/opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace/ResourceStateColumns.kt b/opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace/ResourceStateColumns.kt
index 17f52ab6..c2d896a8 100644
--- a/opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace/ResourceStateColumns.kt
+++ b/opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace/ResourceStateColumns.kt
@@ -23,6 +23,7 @@
 @file:JvmName("ResourceStateColumns")
 package org.opendc.trace
 
+import java.time.Duration
 import java.time.Instant
 
 /**
@@ -30,11 +31,26 @@ import java.time.Instant
  */
 public val RESOURCE_STATE_ID: TableColumn<String> = stringColumn("resource_state:id")
 
+/**
+ * The cluster to which the resource belongs.
+ */
+public val RESOURCE_STATE_CLUSTER_ID: TableColumn<String> = stringColumn("resource_state:cluster_id")
+
 /**
  * Timestamp for the state.
  */
 public val RESOURCE_STATE_TIMESTAMP: TableColumn<Instant> = TableColumn("resource_state:timestamp", Instant::class.java)
 
+/**
+ * Duration for the state.
+ */
+public val RESOURCE_STATE_DURATION: TableColumn<Duration> = TableColumn("resource_state:duration", Duration::class.java)
+
+/**
+ * A flag to indicate that the resource is powered on.
+ */
+public val RESOURCE_STATE_POWERED_ON: TableColumn<Boolean> = booleanColumn("resource_state:powered_on")
+
 /**
  * Number of CPUs for the resource.
  */
@@ -55,6 +71,16 @@ public val RESOURCE_STATE_CPU_USAGE: TableColumn<Double> = doubleColumn("resourc
  */
 public val RESOURCE_STATE_CPU_USAGE_PCT: TableColumn<Double> = doubleColumn("resource_state:cpu_usage_pct")
 
+/**
+ * Total CPU demand of the resource in MHz.
+ */
+public val RESOURCE_STATE_CPU_DEMAND: TableColumn<Double> = doubleColumn("resource_state:cpu_demand")
+
+/**
+ * CPU ready percentage.
+ */
+public val RESOURCE_STATE_CPU_READY_PCT: TableColumn<Double> = doubleColumn("resource_state:cpu_ready_pct")
+
 /**
  * Memory capacity of the resource in KB.
  */
-- 
cgit v1.2.3