in lib/logstash/outputs/opensearch/http_client.rb [320:340]
def build_pool(options)
adapter = build_adapter(options)
pool_options = {
:sniffing => sniffing,
:sniffer_delay => options[:sniffer_delay],
:sniffing_path => options[:sniffing_path],
:healthcheck_path => options[:healthcheck_path],
:resurrect_delay => options[:resurrect_delay],
:url_normalizer => self.method(:host_to_url),
:metric => options[:metric]
}
pool_options[:scheme] = self.scheme if self.scheme
pool_class = ::LogStash::Outputs::OpenSearch::HttpClient::Pool
full_urls = @options[:hosts].map {|h| host_to_url(h) }
pool = pool_class.new(@logger, adapter, full_urls, pool_options)
pool.start
pool
end