class Nark::InfluxDBEmitter
Attributes
influxdb_client[R]
Public Class Methods
new(*args)
click to toggle source
# File lib/nark/influxdb_emitter.rb, line 5 def initialize(*args) @influxdb_client = InfluxDB::Client.new(*args) end
Public Instance Methods
emit(collection_name, data, timestamp = nil)
click to toggle source
# File lib/nark/influxdb_emitter.rb, line 9 def emit(collection_name, data, timestamp = nil) data.merge!(time: timestamp.to_i) if timestamp influxdb_client.write_point(collection_name, data) end
emit_bulk(data_hash)
click to toggle source
# File lib/nark/influxdb_emitter.rb, line 15 def emit_bulk(data_hash) data_hash.each do |collection_name, data| influxdb_client.write_point(collection_name, data) end end