Module: ElasticsearchHermes
- Defined in:
- lib/elasticsearch_hermes/hook.rb,
lib/elasticsearch_hermes/index.rb,
lib/elasticsearch_hermes/query.rb,
lib/elasticsearch_hermes/errors.rb,
lib/elasticsearch_hermes/logger.rb,
lib/elasticsearch_hermes/railtie.rb,
lib/elasticsearch_hermes/version.rb,
lib/elasticsearch_hermes/result/hit.rb,
lib/elasticsearch_hermes/result/base.rb,
lib/elasticsearch_hermes/configuration.rb,
lib/elasticsearch_hermes/indexing/model.rb,
lib/elasticsearch_hermes/indexing/helper.rb,
lib/elasticsearch_hermes/elasticsearch_hermes.rb
Defined Under Namespace
Modules: Hook, Indexing, Query, Result
Classes: Configuration, HermesErrors, Index, Logger, Railtie
Constant Summary
collapse
- VERSION =
'0.0.8'
Class Attribute Summary collapse
Class Method Summary
collapse
Class Attribute Details
.configuration ⇒ Object
10
11
12
|
# File 'lib/elasticsearch_hermes/elasticsearch_hermes.rb', line 10
def self.configuration
@configuration ||= Configuration.new
end
|
Class Method Details
.client ⇒ Object
33
34
35
|
# File 'lib/elasticsearch_hermes/elasticsearch_hermes.rb', line 33
def self.client
@client ||= ::Elasticsearch::Client.new(default_connect_options)
end
|
.connect! ⇒ Object
41
42
43
44
45
46
47
48
|
# 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 ⇒ Object
22
23
24
25
26
27
28
29
30
31
|
# 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 ⇒ Object
37
38
39
|
# File 'lib/elasticsearch_hermes/elasticsearch_hermes.rb', line 37
def self.fields
configuration.fields
end
|
.refresh ⇒ Object
50
51
52
|
# File 'lib/elasticsearch_hermes/elasticsearch_hermes.rb', line 50
def self.refresh
client.indices.refresh
end
|
.reset ⇒ Object
14
15
16
|
# File 'lib/elasticsearch_hermes/elasticsearch_hermes.rb', line 14
def self.reset
@configuration = Configuration.new
end
|
.setup {|configuration| ... } ⇒ Object
18
19
20
|
# File 'lib/elasticsearch_hermes/elasticsearch_hermes.rb', line 18
def self.setup
yield(configuration)
end
|