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 = {}