lib/pupa/processor.rb in pupa-0.2.2 vs lib/pupa/processor.rb in pupa-0.2.3

- old
+ new

@@ -29,13 +29,14 @@ # @param [String] memcached_password the Memcached password # @param [String] database_url the database URL # @param [Boolean] validate whether to validate JSON documents # @param [String] level the log level # @param [String,IO] logdev the log device + # @param [Hash] faraday_options Faraday initialization options # @param [Hash] options criteria for selecting the methods to run - def initialize(output_dir, pipelined: false, cache_dir: nil, expires_in: 86400, value_max_bytes: 1048576, memcached_username: nil, memcached_password: nil, database_url: 'mongodb://localhost:27017/pupa', validate: true, level: 'INFO', logdev: STDOUT, options: {}) + def initialize(output_dir, pipelined: false, cache_dir: nil, expires_in: 86400, value_max_bytes: 1048576, memcached_username: nil, memcached_password: nil, database_url: 'mongodb://localhost:27017/pupa', validate: true, level: 'INFO', logdev: STDOUT, faraday_options: {}, options: {}) @store = DocumentStore.new(output_dir, pipelined: pipelined) - @client = Client.new(cache_dir: cache_dir, expires_in: expires_in, value_max_bytes: value_max_bytes, memcached_username: memcached_username, memcached_password: memcached_password, level: level, logdev: logdev) + @client = Client.new(cache_dir: cache_dir, expires_in: expires_in, value_max_bytes: value_max_bytes, memcached_username: memcached_username, memcached_password: memcached_password, level: level, logdev: logdev, faraday_options: faraday_options) @connection = Connection.new(database_url) @logger = Logger.new('pupa', level: level, logdev: logdev) @validate = validate @options = options @report = {}