Method: Dexter::Processor#perform

Defined in:
lib/dexter/processor.rb

#perform ⇒ Object 



31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/dexter/processor.rb', line 31

def perform
  if [STDIN, :pg_stat_activity].include?(@logfile)
    Thread.abort_on_exception = true
    Thread.new do
      sleep(@starting_interval)
      loop do
        begin
          process_queries
        rescue PG::ServerError => e
          log "ERROR: #{e.class.name}: #{e.message}"
        end
        sleep(@interval)
      end
    end
  end

  begin
    @log_parser.perform
  rescue Errno::ENOENT => e
    abort "ERROR: #{e.message}"
  end

  process_queries
end