class InfluxORM::Connection

Attributes

client_config[R]
config[R]
configuration[R]
database[R]

Public Class Methods

new(options, configuration) click to toggle source
# File lib/influx_orm/connection.rb, line 5
def initialize(options, configuration)
  @config = options.with_indifferent_access
  @configuration = configuration
end

Public Instance Methods

db() click to toggle source
# File lib/influx_orm/connection.rb, line 10
def db
  @db ||= InfluxDB::Client.new(config)
end
import(data) click to toggle source
# File lib/influx_orm/connection.rb, line 22
def import(data)
  log("IMPORT #{data}") { db.write_points(data) }
end
insert(table_name, point) click to toggle source
# File lib/influx_orm/connection.rb, line 18
def insert(table_name, point)
  log("INSERT to #{table_name}: #{point}") { db.write_point(table_name, point) }
end
query(sql) click to toggle source
# File lib/influx_orm/connection.rb, line 14
def query(sql)
  log(sql) { db.query(sql) }
end

Private Instance Methods

log(log, &block) click to toggle source
# File lib/influx_orm/connection.rb, line 28
def log(log, &block)
  t = Time.now
  block.call
ensure
  c = (Time.now - t) * 1000
  configuration.logger.info("[InfluxORM] (%.3f ms) %s" % [c, log])
end