Module: Elasticsearch::Model::Indexing::ClassMethods
- Defined in:
- lib/elasticsearch/model/indexing.rb
Instance Method Summary collapse
-
#create_index!(options = {}) ⇒ Object
Creates an index with correct name, automatically passing ‘settings` and `mappings` defined in the model.
-
#delete_index!(options = {}) ⇒ Object
Deletes the index with corresponding name.
-
#index_exists?(options = {}) ⇒ Boolean
Returns true if the index exists.
- #load_settings_from_io(settings) ⇒ Object
-
#mapping(options = {}, &block) ⇒ Object
(also: #mappings)
Defines mappings for the index.
-
#refresh_index!(options = {}) ⇒ Object
Performs the “refresh” operation for the index (useful e.g. in tests).
-
#settings(settings = {}, &block) ⇒ Object
Define settings for the index.
Instance Method Details
#create_index!(options = {}) ⇒ Object
Creates an index with correct name, automatically passing ‘settings` and `mappings` defined in the model
222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 |
# File 'lib/elasticsearch/model/indexing.rb', line 222 def create_index!(={}) = .clone target_index = .delete(:index) || self.index_name settings = .delete(:settings) || self.settings.to_hash mappings = .delete(:mappings) || self.mappings.to_hash delete_index!(.merge index: target_index) if [:force] unless index_exists?(index: target_index) self.client.indices.create index: target_index, body: { settings: settings, mappings: mappings } end end |
#delete_index!(options = {}) ⇒ Object
Deletes the index with corresponding name
265 266 267 268 269 270 271 272 273 274 275 276 277 |
# File 'lib/elasticsearch/model/indexing.rb', line 265 def delete_index!(={}) target_index = .delete(:index) || self.index_name begin self.client.indices.delete index: target_index rescue Exception => e if e.class.to_s =~ /NotFound/ && [:force] STDERR.puts "[!!!] Index does not exist (#{e.class})" else raise e end end end |
#index_exists?(options = {}) ⇒ Boolean
Returns true if the index exists
249 250 251 252 253 |
# File 'lib/elasticsearch/model/indexing.rb', line 249 def index_exists?(={}) target_index = [:index] || self.index_name self.client.indices.exists(index: target_index) rescue false end |
#load_settings_from_io(settings) ⇒ Object
203 204 205 |
# File 'lib/elasticsearch/model/indexing.rb', line 203 def load_settings_from_io(settings) YAML.load(settings.read) end |
#mapping(options = {}, &block) ⇒ Object Also known as: mappings
Defines mappings for the index
The ‘mappings` and `settings` methods are accessible directly on the model class, when it doesn’t already define them. Use the ‘__elasticsearch__` proxy otherwise.
135 136 137 138 139 140 141 142 143 144 145 146 |
# File 'lib/elasticsearch/model/indexing.rb', line 135 def mapping(={}, &block) @mapping ||= Mappings.new(document_type, ) @mapping..update() unless .empty? if block_given? @mapping.instance_eval(&block) return self else @mapping end end |
#refresh_index!(options = {}) ⇒ Object
Performs the “refresh” operation for the index (useful e.g. in tests)
291 292 293 294 295 296 297 298 299 300 301 302 303 |
# File 'lib/elasticsearch/model/indexing.rb', line 291 def refresh_index!(={}) target_index = .delete(:index) || self.index_name begin self.client.indices.refresh index: target_index rescue Exception => e if e.class.to_s =~ /NotFound/ && [:force] STDERR.puts "[!!!] Index does not exist (#{e.class})" else raise e end end end |
#settings(settings = {}, &block) ⇒ Object
Define settings for the index
You can read settings from any object that responds to :read as long as its return value can be parsed as either YAML or JSON.
189 190 191 192 193 194 195 196 197 198 199 200 201 |
# File 'lib/elasticsearch/model/indexing.rb', line 189 def settings(settings={}, &block) settings = YAML.load(settings.read) if settings.respond_to?(:read) @settings ||= Settings.new(settings) @settings.settings.update(settings) unless settings.empty? if block_given? self.instance_eval(&block) return self else @settings end end |