lib/dexter/processor.rb in pgdexter-0.3.3 vs lib/dexter/processor.rb in pgdexter-0.3.4

- old
+ new

@@ -4,29 +4,31 @@ def initialize(logfile, options) @logfile = logfile @collector = Collector.new(min_time: options[:min_time], min_calls: options[:min_calls]) + @indexer = Indexer.new(options) + @log_parser = - if options[:input_format] == "csv" + if @logfile == :pg_stat_activity + PgStatActivityParser.new(@indexer, @collector) + elsif options[:input_format] == "csv" CsvLogParser.new(logfile, @collector) else LogParser.new(logfile, @collector) end - @indexer = Indexer.new(options) - @starting_interval = 3 @interval = options[:interval] @mutex = Mutex.new @last_checked_at = {} log "Started" end def perform - if @logfile == STDIN + if [STDIN, :pg_stat_activity].include?(@logfile) Thread.abort_on_exception = true Thread.new do sleep(@starting_interval) loop do begin