healthcheck!

in lib/logstash/outputs/opensearch/http_client/pool.rb [226:245]

• 16 lines of code
• 2 McCabe index (conditional complexity)

    def healthcheck!
      
      @state_mutex.synchronize { @url_info.select {|url,meta| meta[:state] != :alive } }.each do |url,meta|
        begin
          health_check_request(url)
          
          logger.warn("Restored connection to OpenSearch instance", url: url.sanitized.to_s)
          
          version = get_version(url)
          @state_mutex.synchronize do
            meta[:version] = version
            set_last_version(version, url)
            meta[:state] = :alive
          end
        rescue HostUnreachableError, BadResponseCodeError => e
          logger.warn("Attempted to resurrect connection to dead OpenSearch instance, but got an error", url: url.sanitized.to_s, exception: e.class, message: e.message)
        end
      end
    end