in hq/app/services/CacheService.scala [128:140]
private def refreshPublicBucketsBox(): Unit = {
logger.info("Started refresh of the public S3 buckets data")
for {
allPublicBuckets <- TrustedAdvisorS3.getAllPublicBuckets(
accounts,
taClients,
s3Clients
)
} yield {
logCacheDataStatus("Public buckets", allPublicBuckets)
publicBucketsBox.send(allPublicBuckets.toMap)
}
}