lib/dexter/processor.rb in pgdexter-0.4.0 vs lib/dexter/processor.rb in pgdexter-0.4.1
- old
+ new
@@ -11,9 +11,11 @@
@log_parser =
if @logfile == :pg_stat_activity
PgStatActivityParser.new(@indexer, @collector)
elsif options[:input_format] == "csv"
CsvLogParser.new(logfile, @collector)
+ elsif options[:input_format] == "json"
+ JsonLogParser.new(logfile, @collector)
elsif options[:input_format] == "sql"
SqlLogParser.new(logfile, @collector)
else
LogParser.new(logfile, @collector)
end