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