in src/main/scala/com/gu/fastly/Lambda.scala [275:300]
private def sendPurgeCountMetric(contentType: Option[ContentType]): Unit = {
val contentTypeDimension = contentType.map { ct =>
new Dimension()
.withName("contentType")
.withValue(ct.name);
}
val dimensions = Seq(contentTypeDimension).flatten
val metric = new MetricDatum()
.withMetricName("purges")
.withUnit(StandardUnit.None)
.withDimensions(dimensions.asJavaCollection)
.withValue(1)
val putMetricDataRequest = new PutMetricDataRequest()
.withNamespace("fastly-cache-purger")
.withMetricData(metric)
try {
cloudWatchClient.putMetricData(putMetricDataRequest)
} catch {
case t: Throwable =>
println("Warning; cloudwatch metrics ping failed: " + t.getMessage)
}
}