build_adapter

in lib/logstash/outputs/amazon_es/http_client.rb [250:291]

• 25 lines of code
• 8 McCabe index (conditional complexity)

    def build_adapter(options)
      timeout = options[:timeout] || 0
      
      adapter_options = {
        :socket_timeout => timeout,
        :request_timeout => timeout,
      }

      adapter_options[:proxy] = client_settings[:proxy] if client_settings[:proxy]

      adapter_options[:check_connection_timeout] = client_settings[:check_connection_timeout] if client_settings[:check_connection_timeout]

      
      if client_settings[:pool_max]
        adapter_options[:pool_max] = client_settings[:pool_max]
      end

      
      if client_settings[:pool_max_per_route]
        adapter_options[:pool_max_per_route] = client_settings[:pool_max_per_route]
      end

      adapter_options[:ssl] = ssl_options if self.scheme == 'https'

      adapter_options[:headers] = client_settings[:headers] if client_settings[:headers]

      adapter_options[:region] = options[:region]

      adapter_options[:service_name] = options[:service_name]

      adapter_options[:port] = options[:port]

      adapter_options[:protocol] = options[:protocol]

      adapter_options[:aws_access_key_id] = options[:aws_access_key_id]

      adapter_options[:aws_secret_access_key] = options[:aws_secret_access_key]

      adapter_class = ::LogStash::Outputs::AmazonElasticSearch::HttpClient::ManticoreAdapter
      adapter = adapter_class.new(@logger, adapter_options)
    end