Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -51,6 +51,8 @@ module Actions
def clear_scroll(arguments = {})
request_opts = { endpoint: arguments[:endpoint] || 'clear_scroll' }

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]

arguments = arguments.clone
headers = arguments.delete(:headers) || {}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -46,6 +46,8 @@ module Actions
def close_point_in_time(arguments = {})
request_opts = { endpoint: arguments[:endpoint] || 'close_point_in_time' }

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]

arguments = arguments.clone
headers = arguments.delete(:headers) || {}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -56,17 +56,14 @@ module Actions
def allocation_explain(arguments = {})
request_opts = { endpoint: arguments[:endpoint] || 'cluster.allocation_explain' }

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]

arguments = arguments.clone
headers = arguments.delete(:headers) || {}

body = arguments.delete(:body)

method = if body
Elasticsearch::API::HTTP_POST
else
Elasticsearch::API::HTTP_GET
end

method = Elasticsearch::API::HTTP_POST
path = '_cluster/allocation/explain'
params = Utils.process_params(arguments)

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -59,6 +59,8 @@ module Actions
def reroute(arguments = {})
request_opts = { endpoint: arguments[:endpoint] || 'cluster.reroute' }

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]

arguments = arguments.clone
headers = arguments.delete(:headers) || {}

Expand Down
2 changes: 2 additions & 0 deletions elasticsearch-api/lib/elasticsearch/api/actions/count.rb
Original file line number Diff line number Diff line change
Expand Up @@ -94,6 +94,8 @@ def count(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]

arguments = arguments.clone
headers = arguments.delete(:headers) || {}

Expand Down
8 changes: 2 additions & 6 deletions elasticsearch-api/lib/elasticsearch/api/actions/explain.rb
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,7 @@ def explain(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'index' missing" unless arguments[:index]
raise ArgumentError, "Required argument 'id' missing" unless arguments[:id]

Expand All @@ -87,12 +88,7 @@ def explain(arguments = {})

_index = arguments.delete(:index)

method = if body
Elasticsearch::API::HTTP_POST
else
Elasticsearch::API::HTTP_GET
end

method = Elasticsearch::API::HTTP_POST
path = "#{Utils.listify(_index)}/_explain/#{Utils.listify(_id)}"
params = Utils.process_params(arguments)

Expand Down
9 changes: 3 additions & 6 deletions elasticsearch-api/lib/elasticsearch/api/actions/field_caps.rb
Original file line number Diff line number Diff line change
Expand Up @@ -72,19 +72,16 @@ def field_caps(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]

arguments = arguments.clone
headers = arguments.delete(:headers) || {}

body = arguments.delete(:body)

_index = arguments.delete(:index)

method = if body
Elasticsearch::API::HTTP_POST
else
Elasticsearch::API::HTTP_GET
end

method = Elasticsearch::API::HTTP_POST
path = if _index
"#{Utils.listify(_index)}/_field_caps"
else
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -102,6 +102,7 @@ def search(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'index' missing" unless arguments[:index]

arguments = arguments.clone
Expand All @@ -111,12 +112,7 @@ def search(arguments = {})

_index = arguments.delete(:index)

method = if body
Elasticsearch::API::HTTP_POST
else
Elasticsearch::API::HTTP_GET
end

method = Elasticsearch::API::HTTP_POST
path = "#{Utils.listify(_index)}/_fleet/_fleet_search"
params = Utils.process_params(arguments)

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -58,6 +58,7 @@ def explore(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'index' missing" unless arguments[:index]

arguments = arguments.clone
Expand All @@ -67,12 +68,7 @@ def explore(arguments = {})

_index = arguments.delete(:index)

method = if body
Elasticsearch::API::HTTP_POST
else
Elasticsearch::API::HTTP_GET
end

method = Elasticsearch::API::HTTP_POST
path = "#{Utils.listify(_index)}/_graph/explore"
params = Utils.process_params(arguments)

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -59,6 +59,7 @@ def move_to_step(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'index' missing" unless arguments[:index]

arguments = arguments.clone
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,6 +53,7 @@ def put_lifecycle(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'policy' missing" unless arguments[:policy]

arguments = arguments.clone
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -56,19 +56,16 @@ def analyze(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]

arguments = arguments.clone
headers = arguments.delete(:headers) || {}

body = arguments.delete(:body)

_index = arguments.delete(:index)

method = if body
Elasticsearch::API::HTTP_POST
else
Elasticsearch::API::HTTP_GET
end

method = Elasticsearch::API::HTTP_POST
path = if _index
"#{Utils.listify(_index)}/_analyze"
else
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -86,6 +86,7 @@ def clone(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'index' missing" unless arguments[:index]
raise ArgumentError, "Required argument 'target' missing" unless arguments[:target]

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -78,6 +78,7 @@ def create(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'index' missing" unless arguments[:index]

arguments = arguments.clone
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -59,6 +59,7 @@ def put_data_lifecycle(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'name' missing" unless arguments[:name]

arguments = arguments.clone
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -59,6 +59,7 @@ def put_data_stream_options(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'name' missing" unless arguments[:name]

arguments = arguments.clone
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -86,6 +86,7 @@ def rollover(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'alias' missing" unless arguments[:alias]

arguments = arguments.clone
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -78,6 +78,7 @@ def shrink(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'index' missing" unless arguments[:index]
raise ArgumentError, "Required argument 'target' missing" unless arguments[:target]

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -81,6 +81,7 @@ def split(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'index' missing" unless arguments[:index]
raise ArgumentError, "Required argument 'target' missing" unless arguments[:target]

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -69,19 +69,16 @@ def validate_query(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]

arguments = arguments.clone
headers = arguments.delete(:headers) || {}

body = arguments.delete(:body)

_index = arguments.delete(:index)

method = if body
Elasticsearch::API::HTTP_POST
else
Elasticsearch::API::HTTP_GET
end

method = Elasticsearch::API::HTTP_POST
path = if _index
"#{Utils.listify(_index)}/_validate/query"
else
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -50,6 +50,7 @@ def completion(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'inference_id' missing" unless arguments[:inference_id]

arguments = arguments.clone
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -55,6 +55,7 @@ def inference(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'inference_id' missing" unless arguments[:inference_id]

arguments = arguments.clone
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,7 @@ def put_ai21(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'task_type' missing" unless arguments[:task_type]
raise ArgumentError, "Required argument 'ai21_inference_id' missing" unless arguments[:ai21_inference_id]

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,7 @@ def put_alibabacloud(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'task_type' missing" unless arguments[:task_type]

unless arguments[:alibabacloud_inference_id]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,7 @@ def put_amazonbedrock(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'task_type' missing" unless arguments[:task_type]

unless arguments[:amazonbedrock_inference_id]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,7 @@ def put_amazonsagemaker(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'task_type' missing" unless arguments[:task_type]

unless arguments[:amazonsagemaker_inference_id]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,6 +53,7 @@ def put_anthropic(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'task_type' missing" unless arguments[:task_type]

unless arguments[:anthropic_inference_id]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,7 @@ def put_azureaistudio(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'task_type' missing" unless arguments[:task_type]

unless arguments[:azureaistudio_inference_id]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -57,6 +57,7 @@ def put_azureopenai(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'task_type' missing" unless arguments[:task_type]

unless arguments[:azureopenai_inference_id]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,7 @@ def put_cohere(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'task_type' missing" unless arguments[:task_type]

unless arguments[:cohere_inference_id]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,6 +53,7 @@ def put_contextualai(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'task_type' missing" unless arguments[:task_type]

unless arguments[:contextualai_inference_id]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -82,6 +82,7 @@ def put_custom(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'task_type' missing" unless arguments[:task_type]

unless arguments[:custom_inference_id]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,7 @@ def put_deepseek(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'task_type' missing" unless arguments[:task_type]

unless arguments[:deepseek_inference_id]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,6 +53,7 @@ def put_elasticsearch(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'task_type' missing" unless arguments[:task_type]

unless arguments[:elasticsearch_inference_id]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,6 +53,7 @@ def put_elser(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'task_type' missing" unless arguments[:task_type]
raise ArgumentError, "Required argument 'elser_inference_id' missing" unless arguments[:elser_inference_id]

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,7 @@ def put_googleaistudio(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'task_type' missing" unless arguments[:task_type]

unless arguments[:googleaistudio_inference_id]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,7 @@ def put_googlevertexai(arguments = {})
end
request_opts[:defined_params] = defined_params unless defined_params.empty?

raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
raise ArgumentError, "Required argument 'task_type' missing" unless arguments[:task_type]

unless arguments[:googlevertexai_inference_id]
Expand Down
Loading
Loading