suspend fun CassandraClient.connectAwait(): Unitsuspend fun CassandraClient.connectAwait(keyspace: String): Unit
Connect to a Cassandra service. |
|
suspend fun CassandraClient.disconnectAwait(): Unit
Disconnects from the Cassandra service. |
|
suspend fun CassandraClient.executeAwait(query: String): ResultSet
Execute the query and provide a handler for consuming results. |
|
suspend fun CassandraClient.queryStreamAwait(sql: String): CassandraRowStream
Executes the given SQL SELECT statement which returns the results of the query as a read stream. |