Module: EsHttpOperation::Helpers
- Included in:
- EsMigrationDsl
- Defined in:
- lib/wukong-migrate/elasticsearch_operations.rb
Instance Method Summary collapse
- #alias_index_op(action, index, als, filter) ⇒ Object
- #create_index_op(index, settings) ⇒ Object
- #delete_index_op(index, obj_type = nil) ⇒ Object
- #update_mapping_op(index, obj_type, mapping) ⇒ Object
- #update_settings_op(index, settings) ⇒ Object
Instance Method Details
#alias_index_op(action, index, als, filter) ⇒ Object
97 98 99 |
# File 'lib/wukong-migrate/elasticsearch_operations.rb', line 97 def alias_index_op (action, index, als, filter) AliasIndex.receive({ action: action, index: index, alias_name: als, filter: filter }.compact_blank) end |
#create_index_op(index, settings) ⇒ Object
81 82 83 |
# File 'lib/wukong-migrate/elasticsearch_operations.rb', line 81 def create_index_op(index, settings) CreateIndex.receive(index: index, settings: settings) end |
#delete_index_op(index, obj_type = nil) ⇒ Object
89 90 91 |
# File 'lib/wukong-migrate/elasticsearch_operations.rb', line 89 def delete_index_op(index, obj_type = nil) DeleteIndex.receive({ index: index, obj_type: obj_type }.compact_blank) end |
#update_mapping_op(index, obj_type, mapping) ⇒ Object
93 94 95 |
# File 'lib/wukong-migrate/elasticsearch_operations.rb', line 93 def update_mapping_op(index, obj_type, mapping) UpdateIndexMapping.receive(index: index, obj_type: obj_type, mapping: mapping) end |
#update_settings_op(index, settings) ⇒ Object
85 86 87 |
# File 'lib/wukong-migrate/elasticsearch_operations.rb', line 85 def update_settings_op(index, settings) UpdateIndexSettings.receive(index: index, settings: settings) end |