module ElasticsearchHermes
Constants
- VERSION
Attributes
configuration[W]
Public Class Methods
client()
click to toggle source
# File lib/elasticsearch_hermes/elasticsearch_hermes.rb, line 33 def self.client @client ||= ::Elasticsearch::Client.new(default_connect_options) end
configuration()
click to toggle source
# File lib/elasticsearch_hermes/elasticsearch_hermes.rb, line 10 def self.configuration @configuration ||= Configuration.new end
connect!()
click to toggle source
# File lib/elasticsearch_hermes/elasticsearch_hermes.rb, line 41 def self.connect! return unless client info = @client.info cluster_version = info['version']['number'] msg = "Connected to Elastic version #{cluster_version}." Logger.log(msg) end
default_connect_options()
click to toggle source
# File lib/elasticsearch_hermes/elasticsearch_hermes.rb, line 22 def self.default_connect_options base_es_urls = configuration.es_url urls = base_es_urls.split(',').compact.uniq options = { url: urls, retry_on_failure: configuration.retry_on_failure, log: configuration.enable_logs } options end
fields()
click to toggle source
# File lib/elasticsearch_hermes/elasticsearch_hermes.rb, line 37 def self.fields configuration.fields end
refresh()
click to toggle source
# File lib/elasticsearch_hermes/elasticsearch_hermes.rb, line 50 def self.refresh client.indices.refresh end
reset()
click to toggle source
# File lib/elasticsearch_hermes/elasticsearch_hermes.rb, line 14 def self.reset @configuration = Configuration.new end
setup() { |configuration| ... }
click to toggle source
# File lib/elasticsearch_hermes/elasticsearch_hermes.rb, line 18 def self.setup yield(configuration) end