diff options
| author | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2021-09-13 14:48:02 +0200 |
|---|---|---|
| committer | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2021-09-17 16:48:02 +0200 |
| commit | 5f0b6b372487d79594cf59010822e160f351e0be (patch) | |
| tree | acad4d2e496da334bafc1fd256e73bbd3d5c481c /opendc-telemetry/opendc-telemetry-compute/src | |
| parent | eef8ea3ab40a4e4a12ba96f839c35c5804884bc1 (diff) | |
refactor(telemetry): Simplify CoroutineMetricReader
This change simplifies the CoroutineMetricReader implementation by
removing the seperation of reader and exporter jobs.
Diffstat (limited to 'opendc-telemetry/opendc-telemetry-compute/src')
| -rw-r--r-- | opendc-telemetry/opendc-telemetry-compute/src/main/kotlin/org/opendc/telemetry/compute/Helpers.kt | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/opendc-telemetry/opendc-telemetry-compute/src/main/kotlin/org/opendc/telemetry/compute/Helpers.kt b/opendc-telemetry/opendc-telemetry-compute/src/main/kotlin/org/opendc/telemetry/compute/Helpers.kt index d3d983b9..01df0e69 100644 --- a/opendc-telemetry/opendc-telemetry-compute/src/main/kotlin/org/opendc/telemetry/compute/Helpers.kt +++ b/opendc-telemetry/opendc-telemetry-compute/src/main/kotlin/org/opendc/telemetry/compute/Helpers.kt @@ -33,6 +33,7 @@ import org.opendc.compute.service.driver.HostState import org.opendc.telemetry.compute.table.ServiceData import org.opendc.telemetry.sdk.metrics.export.CoroutineMetricReader import java.time.Clock +import java.time.Duration /** * Attach the specified monitor to the OpenDC Compute service. @@ -42,7 +43,7 @@ public suspend fun withMonitor( clock: Clock, metricProducer: MetricProducer, monitor: ComputeMonitor, - exportInterval: Long = 5L * 60 * 1000, /* Every 5 min (which is the granularity of the workload trace) */ + exportInterval: Duration = Duration.ofMinutes(5), /* Every 5 min (which is the granularity of the workload trace) */ block: suspend CoroutineScope.() -> Unit ): Unit = coroutineScope { // Monitor host events |