app/no.nav.aap.behandlingsflyt

Package-level declarations

Types

App

class App

AppConfig

internal object AppConfig

BackfillKrav

class BackfillKrav(val dataSource: DataSource, val gatewayProvider: GatewayProvider)

BackfillSakstatusDatadeling

class BackfillSakstatusDatadeling(val dataSource: DataSource, gatewayProvider: GatewayProvider)

Engangs-backfill: sender oppdatert sakstatus til api-intern for behandlinger med trukket søknad eller avbrutt revurdering, siden disse sakene kan ha fått lagret en utdatert status hos api-intern fra før SakstatusDatadelingService begynte å ta hensyn til trukket/avbrutt. Nye tilfeller trenger ikke backfill, siden BehandlingHendelseServiceImpl allerede sender oppdatert status ved hver behandlingshendelse.

BackfillStansOpphør

class BackfillStansOpphør(val dataSource: DataSource, val gatewayProvider: GatewayProvider)

DbConfig

class DbConfig(val url: String = System.getenv( "NAIS_DATABASE_BEHANDLINGSFLYT_BEHANDLINGSFLYT_JDBC_URL" ), val username: String = System.getenv("NAIS_DATABASE_BEHANDLINGSFLYT_BEHANDLINGSFLYT_USERNAME"), val password: String = System.getenv("NAIS_DATABASE_BEHANDLINGSFLYT_BEHANDLINGSFLYT_PASSWORD"))

JsonDeserializerInstitusjonsOppholdHendelse

class JsonDeserializerInstitusjonsOppholdHendelse : Deserializer<InstitusjonsOppholdHendelseKafkaMelding>

StatusPagesConfigHelper

object StatusPagesConfigHelper

Properties

log

private val log: Logger?

postgresConfig

val postgresConfig: Properties

teamLogs

private val teamLogs: Logger?

Functions

aktiverPostgresLogging

private fun aktiverPostgresLogging()

initDatasource

fun initDatasource(dbConfig: DbConfig, maximumPoolSize: Int = AppConfig.hikariMaxPoolSize, prometheus: PrometheusMeterRegistry = no.nav.aap.behandlingsflyt.prometheus, poolName: String? = null): HikariDataSource

isLeader

fun isLeader(log: Logger): Boolean

lukkRessurser

private fun lukkRessurser(log: Logger, resources: List<AutoCloseable>)

main

fun main()

server

internal fun Application.server(dbConfig: DbConfig, repositoryRegistry: RepositoryRegistry, gatewayProvider: GatewayProvider, prometheus: PrometheusMeterRegistry = no.nav.aap.behandlingsflyt.prometheus)

startKafkakonsumenter

private fun Application.startKafkakonsumenter(dataSource: HikariDataSource, repositoryRegistry: RepositoryRegistry, gatewayProvider: GatewayProvider)

startKonsument

private fun <K, V> Application.startKonsument(konsument: KafkaKonsument<K, V>)

startMotor

fun Application.startMotor(dataSource: HikariDataSource, repositoryRegistry: RepositoryRegistry, gatewayProvider: GatewayProvider, prometheus: PrometheusMeterRegistry = no.nav.aap.behandlingsflyt.prometheus): Motor

utledSubtypesTilMottattHendelseDTO

fun utledSubtypesTilMottattHendelseDTO(): List<Class<*>>

verifiserTidssone

private fun Application.verifiserTidssone(dataSource: HikariDataSource)