diff options
Diffstat (limited to 'opendc-compute/opendc-compute-simulator/src')
2 files changed, 4 insertions, 2 deletions
diff --git a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/provisioner/ComputeMonitorProvisioningStep.kt b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/provisioner/ComputeMonitorProvisioningStep.kt index 753cde16..09bc375d 100644 --- a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/provisioner/ComputeMonitorProvisioningStep.kt +++ b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/provisioner/ComputeMonitorProvisioningStep.kt @@ -35,13 +35,14 @@ public class ComputeMonitorProvisioningStep( private val serviceDomain: String, private val monitor: ComputeMonitor, private val exportInterval: Duration, + private val startTime: Duration = Duration.ofMillis(0), ) : ProvisioningStep { override fun apply(ctx: ProvisioningContext): AutoCloseable { val service = requireNotNull( ctx.registry.resolve(serviceDomain, ComputeService::class.java), ) { "Compute service $serviceDomain does not exist" } - val metricReader = ComputeMetricReader(ctx.dispatcher, service, monitor, exportInterval) + val metricReader = ComputeMetricReader(ctx.dispatcher, service, monitor, exportInterval, startTime) return AutoCloseable { metricReader.close() } } } diff --git a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/provisioner/ComputeSteps.kt b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/provisioner/ComputeSteps.kt index 452f08ad..8597b6f4 100644 --- a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/provisioner/ComputeSteps.kt +++ b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/provisioner/ComputeSteps.kt @@ -57,8 +57,9 @@ public fun registerComputeMonitor( serviceDomain: String, monitor: ComputeMonitor, exportInterval: Duration = Duration.ofMinutes(5), + startTime: Duration = Duration.ofMillis(0), ): ProvisioningStep { - return ComputeMonitorProvisioningStep(serviceDomain, monitor, exportInterval) + return ComputeMonitorProvisioningStep(serviceDomain, monitor, exportInterval, startTime) } /** |