lib/dexter/processor.rb in pgdexter-0.2.1 vs lib/dexter/processor.rb in pgdexter-0.3.0

- old
+ new

@@ -3,11 +3,17 @@ include Logging def initialize(logfile, options) @logfile = logfile - @collector = Collector.new(min_time: options[:min_time]) - @log_parser = LogParser.new(logfile, @collector) + @collector = Collector.new(min_time: options[:min_time], min_calls: options[:min_calls]) + @log_parser = + if options[:input_format] == "csv" + CsvLogParser.new(logfile, @collector) + else + LogParser.new(logfile, @collector) + end + @indexer = Indexer.new(options) @starting_interval = 3 @interval = options[:interval]