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