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