Module: EsHttpOperation::Helpers
- Included in:
- EsMigrationDsl
- Defined in:
- lib/wukong-migrate/elasticsearch_operations.rb
Instance Method Summary collapse
- #alias_index_op(action, index, als) ⇒ 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) ⇒ Object
96 97 98 |
# File 'lib/wukong-migrate/elasticsearch_operations.rb', line 96 def alias_index_op (action, index, als) AliasIndex.receive(action: action, index: index, alias_name: als) end |
#create_index_op(index, settings) ⇒ Object
80 81 82 |
# File 'lib/wukong-migrate/elasticsearch_operations.rb', line 80 def create_index_op(index, settings) CreateIndex.receive(index: index, settings: settings) end |
#delete_index_op(index, obj_type = nil) ⇒ Object
88 89 90 |
# File 'lib/wukong-migrate/elasticsearch_operations.rb', line 88 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
92 93 94 |
# File 'lib/wukong-migrate/elasticsearch_operations.rb', line 92 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
84 85 86 |
# File 'lib/wukong-migrate/elasticsearch_operations.rb', line 84 def update_settings_op(index, settings) UpdateIndexSettings.receive(index: index, settings: settings) end |