override def flush()

in path-manager/app/services/Metrics.scala [86:96]

• 10 lines of code
• 1 McCabe index (conditional complexity)

  override def flush(dimensions: Dimension*) = Seq(
    new MetricDatum()
      .withMetricName(metricName)
      .withDimensions(dimensions: _*)
      .withValue(_count.getAndSet(0).toDouble)
      .withUnit(StandardUnit.Count)
      .withTimestamp(new Date())
  )
}

class CloudWatchReporter(metrics: Seq[CloudWatchMetric], actorSystem: ActorSystem) extends AwsInstanceTags {