From 0c19bb5c4c698140d00f2b766fea15ce54d9ae84 Mon Sep 17 00:00:00 2001 From: carbotaniuman <41451839+carbotaniuman@users.noreply.github.com> Date: Fri, 12 Feb 2021 21:07:36 -0600 Subject: [PATCH] Move metrics up a bit --- src/main/kotlin/mdnet/Main.kt | 4 ++-- src/main/kotlin/mdnet/server/ImageServer.kt | 8 ++++---- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/src/main/kotlin/mdnet/Main.kt b/src/main/kotlin/mdnet/Main.kt index 775d7e5..7c0125f 100644 --- a/src/main/kotlin/mdnet/Main.kt +++ b/src/main/kotlin/mdnet/Main.kt @@ -86,11 +86,11 @@ class Main : Runnable { throw IllegalArgumentException() } - if (!Files.isDirectory(databaseFolder)) { + if (Files.isRegularFile(databaseFolder)) { throw IllegalArgumentException("Database folder $databaseFolder must be a directory") } - if (!Files.isDirectory(cacheFolder)) { + if (Files.isRegularFile(cacheFolder)) { throw IllegalArgumentException("Cache folder $cacheFolder must be a directory") } diff --git a/src/main/kotlin/mdnet/server/ImageServer.kt b/src/main/kotlin/mdnet/server/ImageServer.kt index 76914f0..966e700 100644 --- a/src/main/kotlin/mdnet/server/ImageServer.kt +++ b/src/main/kotlin/mdnet/server/ImageServer.kt @@ -51,6 +51,10 @@ fun getServer( client: HttpHandler ): Http4kServer { val circuitBreakerRegistry = CircuitBreakerRegistry.ofDefaults() + TaggedCircuitBreakerMetrics + .ofCircuitBreakerRegistry(circuitBreakerRegistry) + .bindTo(registry) + val circuitBreaker = circuitBreakerRegistry.circuitBreaker( "upstream", CircuitBreakerConfig.custom() @@ -77,10 +81,6 @@ fun getServer( LOGGER.warn { "Circuit breaker has moved from ${it.stateTransition.fromState} to ${it.stateTransition.toState}" } } - TaggedCircuitBreakerMetrics - .ofCircuitBreakerRegistry(circuitBreakerRegistry) - .bindTo(registry) - val circuited = ResilienceFilters.CircuitBreak( circuitBreaker, isError = { r: Response -> !r.status.successful }