Sha256: 0c7290d8e97d6df245fd5ea0e87f2c28f7212ac087e48ee7bb0f47943173a48e
Contents?: true
Size: 1.4 KB
Versions: 5
Compression:
Stored size: 1.4 KB
Contents
<%-
case @endpoint_name
when 'mtermvectors'
-%>
if ids
body = { :ids => ids }
else
body = arguments[:body]
end
<%- when 'cluster.reroute', 'cluster.put_settings' %>
body = arguments[:body] || {}
<%- when 'ml.find_file_structure' %>
body = <%= __utils %>.__bulkify(arguments.delete(:body))
<%- else -%>
<%= ' '*(@namespace_depth+3) %>body = <%= @spec['body'].nil? ? 'nil' : 'arguments[:body]' %>
<%- end -%>
<%- if ['bulk', 'msearch', 'msearch_template', 'find_structure'].include? @method_name -%>
<%= self.send("#{@method_name}_body_helper".to_s) %>
headers.merge!("Content-Type" => "application/x-ndjson")
<%= ' '*(@namespace_depth+4) %>perform_request(method, path, params, payload, headers).body
<%- elsif @method_name == 'ping' -%>
<%= ping_perform_request %>
<%- else -%>
<%- if needs_ignore_404?(@endpoint_name) %>
<%= __utils %>.__rescue_from_not_found do
perform_request(method, path, params, body, headers).status == 200 ? true : false
end
<%- elsif needs_complex_ignore_404?(@endpoint_name) -%>
if Array(arguments[:ignore]).include?(404)
<%= __utils %>.__rescue_from_not_found { perform_request(method, path, params, body, headers).body }
else
perform_request(method, path, params, body, headers).body
end
<%- else -%>
perform_request(method, path, params, body, headers).body
<%- end -%>
<%- end -%>
<%= ' '*(@namespace_depth+3) %>end
Version data entries
5 entries across 5 versions & 1 rubygems