InfluxdbEmitter

influxd_emitter.rb

require 'influxdb'

class InfluxdbEmitter
  def initialize
    @username = "root"
    @password = "root"
    @database = "rbx"

    #InfluxDB::Client.new.create_database(@database)

    @influxdb = InfluxDB::Client.new @database, username: @username,
                                                password: @password
  end

  def start!
    if RUBY_ENGINE != 'rbx'
      puts "Not RBX. Nothing to do here!"
      return
    end

    Thread.new do
      loop do
        metrics = Rubinius::Metrics.data.keys
        metrics.each do |metric|
          @influxdb.write_point(metric, { value: Rubinius::Metrics.data[metric] })
        end

        sleep 1
      end
    end.join
  end
end