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