vertx / io.vertx.kotlin.cassandra / io.vertx.cassandra.CassandraClient

Extensions for io.vertx.cassandra.CassandraClient

closeAwait

suspend fun CassandraClient.closeAwait(): Unit

Suspending version of method io.vertx.cassandra.CassandraClient.close

executeAwait

suspend fun CassandraClient.executeAwait(query: String): ResultSet
suspend fun CassandraClient.executeAwait(statement: Statement<*>): ResultSet

Suspending version of method io.vertx.cassandra.CassandraClient.execute

executeWithFullFetchAwait

suspend fun CassandraClient.executeWithFullFetchAwait(query: String): List<Row>
suspend fun CassandraClient.executeWithFullFetchAwait(statement: Statement<*>): List<Row>

Suspending version of method io.vertx.cassandra.CassandraClient.executeWithFullFetch

prepareAwait

suspend fun CassandraClient.prepareAwait(query: String): PreparedStatement

Suspending version of method io.vertx.cassandra.CassandraClient.prepare

queryStreamAwait

suspend fun CassandraClient.queryStreamAwait(sql: String): CassandraRowStream
suspend fun CassandraClient.queryStreamAwait(statement: Statement<*>): CassandraRowStream

Suspending version of method io.vertx.cassandra.CassandraClient.queryStream