Class: Cassava::Executor

Inherits:
Struct
  • Object
show all
Defined in:
lib/cassava/client.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#logger ⇒ Object

Returns the value of attribute logger

Returns:

  • (Object) —

    the current value of logger



234
235
236
 
# File 'lib/cassava/client.rb', line 234

def logger
  @logger
end

#session ⇒ Object

Returns the value of attribute session

Returns:

  • (Object) —

    the current value of session



234
235
236
 
# File 'lib/cassava/client.rb', line 234

def session
  @session
end

Instance Method Details

#execute(statement, opts = {}) ⇒ Object 



235
236
237
238
239
240
241
 
# File 'lib/cassava/client.rb', line 235

def execute(statement, opts = {})
  log_statement(statement, opts)
  session.execute(statement, opts)
rescue => e
  log_error(e, statement, opts)
  raise e
end

#execute_async(statement, opts = {}) ⇒ Object 



243
244
245
246
 
# File 'lib/cassava/client.rb', line 243

def execute_async(statement, opts = {})
  log_statement(statement, opts)
  session.execute_async(statement, opts)
end

#log_error(e, statement, opts) ⇒ Object 



256
257
258
 
# File 'lib/cassava/client.rb', line 256

def log_error(e, statement, opts)
  logger.debug("Error #{e} executing Cassandra request #{statement.to_s} with options #{opts}")
end

#log_statement(statement, opts) ⇒ Object 



252
253
254
 
# File 'lib/cassava/client.rb', line 252

def log_statement(statement, opts)
  logger.debug("Executing Cassandra request #{statement.to_s} with options #{opts}")
end

#prepare(*args) ⇒ Object 



248
249
250
 
# File 'lib/cassava/client.rb', line 248

def prepare(*args)
  session.prepare(*args)
end