Contents

class FnordMetric::Logger

  def self.import(logfile_path)
    expire = FnordMetric.options[:event_queue_ttl]
    redis  = Redis.new
 
    @opts[:channels] ||= []
    @opts[:channels] = @opts[:channels].map(&:to_s) 

    dump_file = File.open(logfile_path, 'r')
    num_lines = %x{wc -l #{logfile_path}}.to_i
    puts "importing #{num_lines} events..."

    dump_file.each_with_log(num_lines) do |line, ind|
      (8**64).to_s(36).tap do |uuid|
        redis.set    "fnordmetric-event-#{uuid}", line
        redis.lpush  "fnordmetric-queue"        , uuid
        redis.expire "fnordmetric-event-#{uuid}", expire
      end
    end
  end

  def initialize(opts)
    @opts = opts
    opts.fetch(:file)

    FnordMetric.register(self)
  end

  def initialized 
    logfile_path = @opts[:file]

    events = Queue.new
    dump_file = File.open(logfile_path, 'a+')

    fetcher = Thread.new do
      loop do
        event = events.pop

        dump_file.write(event.to_json+"\n")
        dump_file.flush
      end
    end

    listener = Thread.new do  
      backend = FnordMetric.backend
      backend.subscribe do |event|
        events << event if log_channel?(event["_channel"])
      end
    end

    FnordMetric.log "logging to #{logfile_path}"
  end


private

  def log_channel?(channel)
    return !!@opts[:channels] if !channel
    @opts[:channels].include?(channel.to_s)
  end

end

Version data entries

12 entries across 12 versions & 3 rubygems

Version	Path
johnf-fnordmetric-1.2.10	lib/fnordmetric/logger.rb
fnordmetric-1.2.9	lib/fnordmetric/logger.rb
johnf-fnordmetric-1.2.7	lib/fnordmetric/logger.rb
bp-fnordmetric-1.2.7	lib/fnordmetric/logger.rb
fnordmetric-1.2.7	lib/fnordmetric/logger.rb
fnordmetric-1.2.6	lib/fnordmetric/logger.rb
fnordmetric-1.2.4	lib/fnordmetric/logger.rb
fnordmetric-1.2.1	lib/fnordmetric/logger.rb
fnordmetric-1.2.0	lib/fnordmetric/logger.rb
fnordmetric-1.0.1	lib/fnordmetric/logger.rb
fnordmetric-1.0.0	lib/fnordmetric/logger.rb
fnordmetric-0.9.7	lib/fnordmetric/logger.rb