Added some logging to find out what takes time (in context of Prometheus).

Author: flexable777

src/main/kotlin/no/nav/klage/search/config/FunksjonelleGaugesConfiguration.kt

@@ -26,8 +26,8 @@ class FunksjonelleGaugesConfiguration {
     fun registerFunctionalStats(elasticsearchService: ElasticsearchService): MeterBinder {
         return try {
             MeterBinder { registry: MeterRegistry ->
-                Ytelse.values().forEach { ytelse ->
-                    Type.values().forEach { type ->
+                Ytelse.entries.forEach { ytelse ->
+                    Type.entries.forEach { type ->
                         Gauge.builder("funksjonell.ikketildelt") { elasticsearchService.countIkkeTildelt(ytelse, type) }
                             .tag("ytelse", ytelse.navn)
                             .tag("type", type.navn)

src/main/kotlin/no/nav/klage/search/service/ElasticsearchService.kt

@@ -22,6 +22,7 @@ import org.opensearch.search.sort.SortBuilders
 import org.opensearch.search.sort.SortOrder
 import org.springframework.context.ApplicationListener
 import org.springframework.context.event.ContextRefreshedEvent
+import java.lang.System.currentTimeMillis
 import java.time.LocalDate
 import java.util.*
 import java.util.concurrent.TimeUnit
@@ -277,31 +278,55 @@ open class ElasticsearchService(private val esBehandlingRepository: EsBehandling
     }
 
     open fun countIkkeTildelt(ytelse: Ytelse, type: Type): Long {
-        return countByStatusYtelseAndType(IKKE_TILDELT, ytelse, type)
+        return runWithTiming(method = ::countIkkeTildelt.name) {
+            countByStatusYtelseAndType(IKKE_TILDELT, ytelse, type)
+        }
     }
 
     open fun countTildelt(ytelse: Ytelse, type: Type): Long {
-        return countByStatusYtelseAndType(TILDELT, ytelse, type)
+        return runWithTiming(method = ::countTildelt.name) {
+            countByStatusYtelseAndType(TILDELT, ytelse, type)
+        }
     }
 
     open fun countSendtTilMedunderskriver(ytelse: Ytelse, type: Type): Long {
-        return countByStatusYtelseAndType(SENDT_TIL_MEDUNDERSKRIVER, ytelse, type)
+        return runWithTiming(method = ::countSendtTilMedunderskriver.name) {
+            countByStatusYtelseAndType(SENDT_TIL_MEDUNDERSKRIVER, ytelse, type)
+        }
     }
 
     open fun countMedunderskriverValgt(ytelse: Ytelse, type: Type): Long {
-        return countByStatusYtelseAndType(MEDUNDERSKRIVER_VALGT, ytelse, type)
+        return runWithTiming(method = ::countMedunderskriverValgt.name) {
+            countByStatusYtelseAndType(MEDUNDERSKRIVER_VALGT, ytelse, type)
+        }
     }
 
     open fun countReturnertTilSaksbehandler(ytelse: Ytelse, type: Type): Long {
-        return countByStatusYtelseAndType(RETURNERT_TIL_SAKSBEHANDLER, ytelse, type)
+        return runWithTiming(method = ::countReturnertTilSaksbehandler.name) {
+            countByStatusYtelseAndType(RETURNERT_TIL_SAKSBEHANDLER, ytelse, type)
+        }
     }
 
     open fun countAvsluttet(ytelse: Ytelse, type: Type): Long {
-        return countByStatusYtelseAndType(FULLFOERT, ytelse, type)
+        return runWithTiming(method = ::countAvsluttet.name) {
+            countByStatusYtelseAndType(FULLFOERT, ytelse, type)
+        }
     }
 
     open fun countSattPaaVent(ytelse: Ytelse, type: Type): Long {
-        return countByStatusYtelseAndType(SATT_PAA_VENT, ytelse, type)
+        return runWithTiming(method = ::countSattPaaVent.name) {
+            countByStatusYtelseAndType(SATT_PAA_VENT, ytelse, type)
+        }
+    }
+
+    private fun <T> runWithTiming(method: String, block: () -> T): T {
+        val start = currentTimeMillis()
+        try {
+            return block.invoke()
+        } finally {
+            val end = currentTimeMillis()
+            logger.debug("Time it took to call $method: ${end - start} millis")
+        }
     }
 
     private fun countByStatusYtelseAndType(status: EsStatus, ytelse: Ytelse, type: Type): Long {
@@ -313,6 +338,7 @@ open class ElasticsearchService(private val esBehandlingRepository: EsBehandling
     }
 
     open fun countAntallSaksdokumenterIAvsluttedeBehandlingerMedian(ytelse: Ytelse, type: Type): Double {
+        val start = currentTimeMillis()
         val baseQuery: BoolQueryBuilder = QueryBuilders.boolQuery()
         baseQuery.must(QueryBuilders.termQuery(EsBehandling::status.name, FULLFOERT))
         baseQuery.must(QueryBuilders.termQuery(EsBehandling::ytelseId.name, ytelse.id))
@@ -324,7 +350,14 @@ open class ElasticsearchService(private val esBehandlingRepository: EsBehandling
             }
             .toList()
 
-        return getMedian(saksdokumenterPerAvsluttetBehandling)
+        val medianStart = currentTimeMillis()
+        val median = getMedian(saksdokumenterPerAvsluttetBehandling)
+        val medianEnd = currentTimeMillis()
+        logger.debug("Time it took to calculate median for list with ${saksdokumenterPerAvsluttetBehandling.size} elements: ${medianEnd - medianStart} millis")
+
+        val end = currentTimeMillis()
+        logger.debug("Time it took to call ${::countAntallSaksdokumenterIAvsluttedeBehandlingerMedian.name}: ${end - start} millis")
+        return median
     }
 
     open fun countLedigeOppgaverMedUtgaattFristByCriteria(criteria: CountLedigeOppgaverMedUtgaattFristSearchCriteria): Int {