Module: ElasticSearch::Transport::IndexAdminProtocol

Included in:
BaseProtocol
Defined in:
lib/elasticsearch/transport/base_protocol.rb

Instance Method Summary collapse

Instance Method Details

#alias_index(operations, options = {}) ⇒ Object 



120
121
122
 
# File 'lib/elasticsearch/transport/base_protocol.rb', line 120

def alias_index(operations, options={})
  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, create_options={}, options={})
  standard_request(:put, {:index => index}, {}, encoder.encode(create_options))
end

#create_river(type, create_options = {}, options = {}) ⇒ Object 



164
165
166
 
# File 'lib/elasticsearch/transport/base_protocol.rb', line 164

def create_river(type, create_options={}, options={})
  standard_request(:put, {:index => "_river", :type => type, :op => "_meta"}, options, encoder.encode(create_options))
end

#delete_index(index, options = {}) ⇒ Object 



116
117
118
 
# File 'lib/elasticsearch/transport/base_protocol.rb', line 116

def delete_index(index, options={})
  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, options={})
  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, options={})
  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, options={})
  standard_request(:post, {:index => index_list, :op => "_flush"}, options, "")
end

#get_aliases(index, options = {}) ⇒ Object 



124
125
126
 
# File 'lib/elasticsearch/transport/base_protocol.rb', line 124

def get_aliases(index, options={})
  standard_request(:get, {:index => index, :op => "_aliases"}, options)
end

#get_river(type, options = {}) ⇒ Object 



168
169
170
 
# File 'lib/elasticsearch/transport/base_protocol.rb', line 168

def get_river(type, options={})
  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, options)
  standard_request(:get, {:index => index, :op => "_settings"}, options)
end

#index_mapping(index_list, options = {}) ⇒ Object 



132
133
134
 
# File 'lib/elasticsearch/transport/base_protocol.rb', line 132

def index_mapping(index_list, options={})
  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, options={})
  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, options={})
  standard_request(:post, {:index => index_list, :op => "_optimize"}, options, {})
end

#refresh(index_list, options = {}) ⇒ Object 



152
153
154
 
# File 'lib/elasticsearch/transport/base_protocol.rb', line 152

def refresh(index_list, options={})
  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, options={})
  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, options={})
  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, options)
  standard_request(:put, {:index => index, :type => type, :op => "_mapping"}, options, 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, options)
  standard_request(:put, {:index => index, :op => "_settings"}, options, encoder.encode(settings))
end