kandra-runtime/io.kandra.runtime

Package-level declarations

Types

class BatchEngine(session: CqlSession, statementBuilder: StatementBuilder, scope: CoroutineScope, eventListener: KandraEventListener? = null, retryConfig: RetryConfig = RetryConfig(), debugConfig: DebugConfig = DebugConfig(), codec: KandraCodec = KandraCodec.default)

Executes save, update, delete, and saveAll operations using LOGGED batch statements.

Default consistency levels applied to all operations.

Query debug and observability settings.

DSL scope for building a caller-controlled LOGGED batch.

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

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

class QueryExecutor(session: CqlSession, schema: TableSchema, statementBuilder: StatementBuilder, codec: KandraCodec = KandraCodec.default, debugConfig: DebugConfig = DebugConfig())

Translates QueryContext predicates into CQL SELECT statements and decodes results.

Retry policy for transient ScyllaDB failures.

class StatementBuilder(session: CqlSession, codec: KandraCodec = KandraCodec.default, debugConfig: DebugConfig = DebugConfig(), consistencyConfig: ConsistencyConfig = ConsistencyConfig(), cacheSize: Int = 1000)

Builds BoundStatement instances for all CRUD operations.