Module: ProxES::Services::ES

Included in:
Forwarder
Defined in:
lib/proxes/services/es.rb

Instance Method Summary collapse

Instance Method Details

#client ⇒ Object 



10
11
12
13
14
15
16
17
18
19
20
21
 
# File 'lib/proxes/services/es.rb', line 10

def client
  @client ||= Elasticsearch::Client.new(
    url: ENV['ELASTICSEARCH_URL'],
    transport_options: {
      ssl: {
        verify: ENV['SSL_VERIFY_NONE'].to_i != 1,
        cert_store: ssl_store
      }
    },
    logger: Ditty::Services::Logger.instance
  )
end

#cluster_health(level = 'cluster') ⇒ Object 



33
34
35
 
# File 'lib/proxes/services/es.rb', line 33

def cluster_health(level = 'cluster')
  client.cluster.health level: level
end

#conn ⇒ Object 



29
30
31
 
# File 'lib/proxes/services/es.rb', line 29

def conn
  client.transport.connections.get_connection.connection
end

#ssl_store ⇒ Object 



23
24
25
26
27
 
# File 'lib/proxes/services/es.rb', line 23

def ssl_store
  store = OpenSSL::X509::Store.new
  store.set_default_paths
  store
end