kandra-core/io.kandra.core/KandraMetrics

KandraMetrics

Callback interface for recording query execution metrics.

Implement this to bridge Kandra into any metrics backend (Micrometer, Dropwizard, etc.). Wire it via io.kandra.ktor.KandraConfig.metrics in the Kandra Ktor plugin.

install(Kandra) {
    metrics {
        enabled = true
        recorder = KandraMetrics { table, op, durationMs ->
            meterRegistry.timer("kandra.query", "table", table, "operation", op)
                .record(durationMs, TimeUnit.MILLISECONDS)
        }
    }
}

Functions

record

abstract fun record(tableName: String, operation: String, durationMs: Long)

Called after every query execution (both blocking and suspend paths).