in app/services/Agents.scala [208:232]
private def refreshHistory(
agent: AtomicReference[List[(DateTime, Double)]],
metricName: String
): Unit = {
cloudWatch
.get(amiableConfigProvider.cloudwatchReadNamespace, metricName)
.fold(
{ err =>
logger.warn(
s"Failed to update historical data for metric '$metricName': ${err.logString}"
)
},
{ dataOpt =>
dataOpt.fold {
logger
.warn(s"Failed to fetch historical data for metric '$metricName'")
} { data =>
logger.debug(
s"Found ${data.size} historical datapoints for metric '$metricName'"
)
agent.set(data)
}
}
)
}