Uziel Sulkies
11/18/2020, 8:32 AMinit {
GlobalScope.launch (<http://Dispatchers.IO|Dispatchers.IO>) {
val logger = LoggerFactory.getLogger(javaClass)
var exceptionsCounter = 0
while (true) {
delay(DELAY_IN_MS_BETWEEN_FLAGS_CHECKS)
try {
getFlags()
.onEach {
featureFlagsStatusGauge.labels(it.key).set(if (it.value) 1.0 else 0.0)
}
exceptionsCounter = 0
} catch (e: Exception) {
exceptionsCounter++
if (exceptionsCounter > 6) logger.warn("Got exception while trying to update feature flags status for $exceptionsCounter times", e)
}
}
}