CircuitBreaker

class CircuitBreaker(val timeoutInMillis: Long = 200, val maxFailures: Int = 3, val retryIntervalInMillis: Long = 300) {

    fun <T> withCircuitBreaker(function: () -> T, fallback: () -> T): T {

        if (open() && !shouldRetry()) return fallback()

        val future = Executors.newSingleThreadExecutor().submit(function)

        return try {
            future.get(timeoutInMillis, TimeUnit.MILLISECONDS).apply {
                reset()
            }
        } catch (e: Exception) {
            fail()
            fallback()
        } finally {
            future.cancel(true)
        }
    }