KandraRuntime

class KandraRuntime(val session: CqlSession, val batchEngine: BatchEngine, val codec: KandraCodec)

Entry point for all Kandra operations. Obtained from application.kandra in Ktor routes.

Tracks inFlightCount for graceful shutdown drain and isShuttingDown to reject new queries after shutdown is signalled.

application.kandra.batch {
    userRepo.saveInBatch(user)
    walletRepo.saveInBatch(wallet)
}

Constructors

constructor(session: CqlSession, batchEngine: BatchEngine, codec: KandraCodec)

Delegating to batchEngine so the shutdown hook and execute guards share one AtomicBoolean.

val session: CqlSession

suspend fun batch(block: suspend KandraBatchScope.() -> Unit)

Executes all operations in block as a single LOGGED batch.

Blocking variant of batch for use in non-suspend contexts.

Returns true when ScyllaDB is reachable. Safe to use in health check endpoints.

Creates a blocking repository for entityClass. For blocking contexts only — use suspendRepository in Ktor routes.

Creates a suspend (coroutine-friendly) repository for entityClass. Preferred for Ktor routes.