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]