Class: Mindex::Elasticsearch

Inherits:
Delegator
  • Object
show all
Defined in:
lib/mindex/elasticsearch.rb

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(options) ⇒ Elasticsearch

Returns a new instance of Elasticsearch.



23
24
25
# File 'lib/mindex/elasticsearch.rb', line 23

def initialize(options)
  @delegate_sd_obj ||= ::Elasticsearch::Client.new(options)
end

Class Method Details

.connect(options = {}) ⇒ Object



7
8
9
10
11
12
13
# File 'lib/mindex/elasticsearch.rb', line 7

def self.connect(options = {})
  new({
    url:      Mindex.config.elasticsearch_url,
    user:     Mindex.config.elasticsearch_user,
    password: Mindex.config.elasticsearch_pass
  }.merge(Mindex.config.elasticsearch_options || {}).merge(options || {}))
end

Instance Method Details

#__getobj__Object



27
28
29
# File 'lib/mindex/elasticsearch.rb', line 27

def __getobj__
  @delegate_sd_obj
end

#__setobj__(obj) ⇒ Object



31
32
33
# File 'lib/mindex/elasticsearch.rb', line 31

def __setobj__(obj)
  @delegate_sd_obj = obj
end

#versionObject



15
16
17
# File 'lib/mindex/elasticsearch.rb', line 15

def version
  info['version']['number']
end

#version_gte?(expected_version) ⇒ Boolean

Returns:

  • (Boolean)


19
20
21
# File 'lib/mindex/elasticsearch.rb', line 19

def version_gte?(expected_version)
  Gem::Version.new(version) >= Gem::Version.new(expected_version)
end