Method: Fluent::Plugin::ElasticsearchInput#is_existing_connection

Defined in:
lib/fluent/plugin/in_elasticsearch.rb

#is_existing_connection(host) ⇒ Object 



245
246
247
248
249
250
251
252
253
254
255
256
257
258
 
# File 'lib/fluent/plugin/in_elasticsearch.rb', line 245

def is_existing_connection(host)
  # check if the host provided match the current connection
  return false if @_es.nil?
  return false if @current_config.nil?
  return false if host.length != @current_config.length

  for i in 0...host.length
    if !host[i][:host].eql? @current_config[i][:host] || host[i][:port] != @current_config[i][:port]
      return false
    end
  end

  return true
end