Module: ElasticSearch::Transport::IndexAdminProtocol
- Included in:
- BaseProtocol
- Defined in:
- lib/elasticsearch/transport/base_protocol.rb
Instance Method Summary collapse
- #alias_index(operations, options = {}) ⇒ Object
- #create_index(index, create_options = {}, options = {}) ⇒ Object
- #create_river(type, create_options = {}, options = {}) ⇒ Object
- #delete_index(index, options = {}) ⇒ Object
- #delete_mapping(index, type, options = {}) ⇒ Object
- #delete_river(type, options = {}) ⇒ Object
- #flush(index_list, options = {}) ⇒ Object
- #get_aliases(index, options = {}) ⇒ Object
- #get_river(type, options = {}) ⇒ Object
- #get_settings(index, options) ⇒ Object
- #index_mapping(index_list, options = {}) ⇒ Object
- #index_status(index_list, options = {}) ⇒ Object
- #optimize(index_list, options = {}) ⇒ Object
- #refresh(index_list, options = {}) ⇒ Object
- #river_status(type, options = {}) ⇒ Object
- #snapshot(index_list, options = {}) ⇒ Object
- #update_mapping(index, type, mapping, options) ⇒ Object
- #update_settings(index, settings, options) ⇒ Object
Instance Method Details
#alias_index(operations, options = {}) ⇒ Object
120 121 122 |
# File 'lib/elasticsearch/transport/base_protocol.rb', line 120 def alias_index(operations, ={}) standard_request(:post, {:op => "_aliases"}, {}, encoder.encode(operations)) end |
#create_index(index, create_options = {}, options = {}) ⇒ Object
112 113 114 |
# File 'lib/elasticsearch/transport/base_protocol.rb', line 112 def create_index(index, ={}, ={}) standard_request(:put, {:index => index}, {}, encoder.encode()) end |
#create_river(type, create_options = {}, options = {}) ⇒ Object
164 165 166 |
# File 'lib/elasticsearch/transport/base_protocol.rb', line 164 def create_river(type, ={}, ={}) standard_request(:put, {:index => "_river", :type => type, :op => "_meta"}, , encoder.encode()) end |
#delete_index(index, options = {}) ⇒ Object
116 117 118 |
# File 'lib/elasticsearch/transport/base_protocol.rb', line 116 def delete_index(index, ={}) standard_request(:delete, {:index => index}) end |
#delete_mapping(index, type, options = {}) ⇒ Object
136 137 138 |
# File 'lib/elasticsearch/transport/base_protocol.rb', line 136 def delete_mapping(index, type, ={}) standard_request(:delete, {:index => index, :type => type, :op => "_mapping"}) end |
#delete_river(type, options = {}) ⇒ Object
176 177 178 179 180 |
# File 'lib/elasticsearch/transport/base_protocol.rb', line 176 def delete_river(type, ={}) params = {:index => "_river"} params[:type] = type unless type.nil? standard_request(:delete, params) end |
#flush(index_list, options = {}) ⇒ Object
148 149 150 |
# File 'lib/elasticsearch/transport/base_protocol.rb', line 148 def flush(index_list, ={}) standard_request(:post, {:index => index_list, :op => "_flush"}, , "") end |
#get_aliases(index, options = {}) ⇒ Object
124 125 126 |
# File 'lib/elasticsearch/transport/base_protocol.rb', line 124 def get_aliases(index, ={}) standard_request(:get, {:index => index, :op => "_aliases"}, ) end |
#get_river(type, options = {}) ⇒ Object
168 169 170 |
# File 'lib/elasticsearch/transport/base_protocol.rb', line 168 def get_river(type, ={}) standard_request(:get, {:index => "_river", :type => type, :op => "_meta"}) end |
#get_settings(index, options) ⇒ Object
144 145 146 |
# File 'lib/elasticsearch/transport/base_protocol.rb', line 144 def get_settings(index, ) standard_request(:get, {:index => index, :op => "_settings"}, ) end |
#index_mapping(index_list, options = {}) ⇒ Object
132 133 134 |
# File 'lib/elasticsearch/transport/base_protocol.rb', line 132 def index_mapping(index_list, ={}) standard_request(:get, {:index => index_list, :op => "_mapping"}) end |
#index_status(index_list, options = {}) ⇒ Object
108 109 110 |
# File 'lib/elasticsearch/transport/base_protocol.rb', line 108 def index_status(index_list, ={}) standard_request(:get, {:index => index_list, :op => "_status"}) end |
#optimize(index_list, options = {}) ⇒ Object
160 161 162 |
# File 'lib/elasticsearch/transport/base_protocol.rb', line 160 def optimize(index_list, ={}) standard_request(:post, {:index => index_list, :op => "_optimize"}, , {}) end |
#refresh(index_list, options = {}) ⇒ Object
152 153 154 |
# File 'lib/elasticsearch/transport/base_protocol.rb', line 152 def refresh(index_list, ={}) standard_request(:post, {:index => index_list, :op => "_refresh"}, {}, "") end |
#river_status(type, options = {}) ⇒ Object
172 173 174 |
# File 'lib/elasticsearch/transport/base_protocol.rb', line 172 def river_status(type, ={}) standard_request(:get, {:index => "_river", :type => type, :op => "_status"}) end |
#snapshot(index_list, options = {}) ⇒ Object
156 157 158 |
# File 'lib/elasticsearch/transport/base_protocol.rb', line 156 def snapshot(index_list, ={}) standard_request(:post, {:index => index_list, :type => "_gateway", :op => "snapshot"}, {}, "") end |
#update_mapping(index, type, mapping, options) ⇒ Object
128 129 130 |
# File 'lib/elasticsearch/transport/base_protocol.rb', line 128 def update_mapping(index, type, mapping, ) standard_request(:put, {:index => index, :type => type, :op => "_mapping"}, , encoder.encode(mapping)) end |
#update_settings(index, settings, options) ⇒ Object
140 141 142 |
# File 'lib/elasticsearch/transport/base_protocol.rb', line 140 def update_settings(index, settings, ) standard_request(:put, {:index => index, :op => "_settings"}, , encoder.encode(settings)) end |