in app/services/Agents.scala [57:99]
def oldProdInstanceCountHistory: List[(DateTime, Double)] =
oldProdInstanceCountHistoryAgent.get
def amisAgePercentiles: Option[Percentiles] = amisAgePercentilesAgent.get
def amisAgePercentile25thHistory: List[(DateTime, Double)] =
amisAgePercentile25thHistoryAgent.get
def amisAgePercentile50thHistory: List[(DateTime, Double)] =
amisAgePercentile50thHistoryAgent.get
def amisAgePercentile75thHistory: List[(DateTime, Double)] =
amisAgePercentile75thHistoryAgent.get
def oldInstanceCountByAccount: List[OldInstanceAccountHistory] =
oldInstanceCountByAccountAgent.get
if (environment.mode != Mode.Test) {
refreshAmis()
refreshSSAs()
refreshInstancesInfo()
refreshHistory()
val prismDataSubscription = system.scheduler.scheduleAtFixedRate(
initialDelay = 0.seconds,
interval = refreshInterval
) { () =>
{
logger.debug(s"Refreshing agents")
refreshAmis()
refreshSSAs()
refreshInstancesInfo()
}
}(exec)
val cloudwatchDataSubscription = system.scheduler.scheduleAtFixedRate(
initialDelay = 0.seconds,
interval = 1.hour
) { () =>
refreshHistory()
}(exec)
lifecycle.addStopHook { () =>
prismDataSubscription.cancel()
cloudwatchDataSubscription.cancel()
Future.successful(())
}
}