feat(workflow): Add helper tools for workflow simulations

This change adds a new module, opendc-workflow-workload that contains
helper code for constructing workflow simulations using OpenDC.

3 files changed, 7 insertions, 7 deletions

diff --git a/opendc-experiments/opendc-experiments-capelin/src/jmh/kotlin/org/opendc/experiments/capelin/CapelinBenchmarks.kt b/opendc-experiments/opendc-experiments-capelin/src/jmh/kotlin/org/opendc/experiments/capelin/CapelinBenchmarks.kt
index 48a90985..4b35de95 100644
--- a/opendc-experiments/opendc-experiments-capelin/src/jmh/kotlin/org/opendc/experiments/capelin/CapelinBenchmarks.kt
+++ b/opendc-experiments/opendc-experiments-capelin/src/jmh/kotlin/org/opendc/experiments/capelin/CapelinBenchmarks.kt
@@ -67,7 +67,7 @@ class CapelinBenchmarks {
             filters = listOf(ComputeFilter(), VCpuFilter(16.0), RamFilter(1.0)),
             weighers = listOf(CoreRamWeigher(multiplier = 1.0))
         )
-        val runner = ComputeWorkloadRunner(
+        val runner = ComputeServiceHelper(
             coroutineContext,
             clock,
             computeScheduler
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 53c9de11..b548ae58 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
@@ -24,8 +24,8 @@ package org.opendc.experiments.capelin
 
 import com.typesafe.config.ConfigFactory
 import mu.KotlinLogging
+import org.opendc.compute.workload.ComputeServiceHelper
 import org.opendc.compute.workload.ComputeWorkloadLoader
-import org.opendc.compute.workload.ComputeWorkloadRunner
 import org.opendc.compute.workload.createComputeScheduler
 import org.opendc.compute.workload.export.parquet.ParquetComputeMetricExporter
 import org.opendc.compute.workload.grid5000
@@ -109,7 +109,7 @@ abstract class Portfolio(name: String) : Experiment(name) {
                 grid5000(Duration.ofSeconds((operationalPhenomena.failureFrequency * 60).roundToLong()))
             else
                 null
-        val runner = ComputeWorkloadRunner(
+        val runner = ComputeServiceHelper(
             coroutineContext,
             clock,
             computeScheduler,
diff --git a/opendc-experiments/opendc-experiments-capelin/src/test/kotlin/org/opendc/experiments/capelin/CapelinIntegrationTest.kt b/opendc-experiments/opendc-experiments-capelin/src/test/kotlin/org/opendc/experiments/capelin/CapelinIntegrationTest.kt
index 1a8948f3..eedc3131 100644
--- a/opendc-experiments/opendc-experiments-capelin/src/test/kotlin/org/opendc/experiments/capelin/CapelinIntegrationTest.kt
+++ b/opendc-experiments/opendc-experiments-capelin/src/test/kotlin/org/opendc/experiments/capelin/CapelinIntegrationTest.kt
@@ -83,7 +83,7 @@ class CapelinIntegrationTest {
     @Test
     fun testLarge() = runBlockingSimulation {
         val workload = createTestWorkload(1.0)
-        val runner = ComputeWorkloadRunner(
+        val runner = ComputeServiceHelper(
             coroutineContext,
             clock,
             computeScheduler
@@ -131,7 +131,7 @@ class CapelinIntegrationTest {
         val seed = 1
         val workload = createTestWorkload(0.25, seed)
 
-        val simulator = ComputeWorkloadRunner(
+        val simulator = ComputeServiceHelper(
             coroutineContext,
             clock,
             computeScheduler
@@ -180,7 +180,7 @@ class CapelinIntegrationTest {
                 .read(perfInterferenceInput)
                 .withSeed(seed.toLong())
 
-        val simulator = ComputeWorkloadRunner(
+        val simulator = ComputeServiceHelper(
             coroutineContext,
             clock,
             computeScheduler,
@@ -222,7 +222,7 @@ class CapelinIntegrationTest {
     @Test
     fun testFailures() = runBlockingSimulation {
         val seed = 1
-        val simulator = ComputeWorkloadRunner(
+        val simulator = ComputeServiceHelper(
             coroutineContext,
             clock,
             computeScheduler,