initialize

in lib/logstash/outputs/amazon_es/http_client/manticore_adapter.rb [24:56]

• 24 lines of code
• 15 McCabe index (conditional complexity)

    def initialize(logger, options={})
      @logger = logger
      options = options.clone || {}
      options[:ssl] = options[:ssl] || {}

      
      options[:automatic_retries] = 0
      
      options[:cookies] = false

      @client_params = {:headers => DEFAULT_HEADERS.merge(options[:headers]|| {}),}

      @port =  options[:port] || 9200
      @protocol =  options[:protocol] || 'http'
      @region =   options[:region] || 'us-east-1'
      @service_name = options[:service_name] || 'es'
      aws_access_key_id =  options[:aws_access_key_id] || nil
      aws_secret_access_key = options[:aws_secret_access_key] || nil
      session_token = options[:session_token] || nil
      profile = options[:profile] || 'default'
      instance_cred_retries = options[:instance_profile_credentials_retries] || 0
      instance_cred_timeout = options[:instance_profile_credentials_timeout] || 1

      credential_config = CredentialConfig.new(aws_access_key_id, aws_secret_access_key, session_token, profile, instance_cred_retries, instance_cred_timeout, @region)
      @credentials = Aws::CredentialProviderChain.new(credential_config).resolve

      if options[:proxy]
        options[:proxy] = manticore_proxy_hash(options[:proxy])
      end
      
      @manticore = ::Manticore::Client.new(options)
    end