class Cql::Client::SynchronousClient
@private
Public Class Methods
new(async_client)
click to toggle source
# File lib/cql/client/client.rb, line 518 def initialize(async_client) @async_client = async_client end
Public Instance Methods
async()
click to toggle source
# File lib/cql/client/client.rb, line 565 def async @async_client end
batch(type=:logged, options={}, &block)
click to toggle source
# File lib/cql/client/client.rb, line 557 def batch(type=:logged, options={}, &block) if block_given? synchronous_backtrace { @async_client.batch(type, options, &block).value } else SynchronousBatch.new(@async_client.batch(type, options)) end end
close()
click to toggle source
# File lib/cql/client/client.rb, line 527 def close synchronous_backtrace { @async_client.close.value } self end
connect()
click to toggle source
# File lib/cql/client/client.rb, line 522 def connect synchronous_backtrace { @async_client.connect.value } self end
connected?()
click to toggle source
# File lib/cql/client/client.rb, line 532 def connected? @async_client.connected? end
execute(cql, *args)
click to toggle source
# File lib/cql/client/client.rb, line 544 def execute(cql, *args) synchronous_backtrace do result = @async_client.execute(cql, *args).value result = SynchronousPagedQueryResult.new(result) if result.is_a?(PagedQueryResult) result end end
keyspace()
click to toggle source
# File lib/cql/client/client.rb, line 536 def keyspace @async_client.keyspace end
prepare(cql)
click to toggle source
# File lib/cql/client/client.rb, line 552 def prepare(cql) async_statement = synchronous_backtrace { @async_client.prepare(cql).value } SynchronousPreparedStatement.new(async_statement) end
use(keyspace)
click to toggle source
# File lib/cql/client/client.rb, line 540 def use(keyspace) synchronous_backtrace { @async_client.use(keyspace).value } end