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

Extensions for io.vertx.cassandra.CassandraClient

connectAwait

suspend fun CassandraClient.connectAwait(): Unit
suspend fun CassandraClient.connectAwait(keyspace: String): Unit

Connect to a Cassandra service.

disconnectAwait

suspend fun CassandraClient.disconnectAwait(): Unit

Disconnects from the Cassandra service.

executeAwait

suspend fun CassandraClient.executeAwait(query: String): ResultSet

Execute the query and provide a handler for consuming results.

suspend fun CassandraClient.executeAwait(statement: Statement): ResultSet

Execute the statement and provide a handler for consuming results.

executeWithFullFetchAwait

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

Execute the query and provide a handler for consuming results.

prepareAwait

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

Prepares the provided query string.

queryStreamAwait

suspend fun CassandraClient.queryStreamAwait(sql: String): CassandraRowStream

Executes the given SQL SELECT statement which returns the results of the query as a read stream.

suspend fun CassandraClient.queryStreamAwait(statement: Statement): CassandraRowStream

Executes the given SQL statement which returns the results of the query as a read stream.