Skip to content

Commit d6bb5f7

Browse files
committed
Generate code using new template with additional perform_request arg
1 parent 56f642e commit d6bb5f7

File tree

460 files changed

+3493
-473
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

460 files changed

+3493
-473
lines changed

elasticsearch-api/lib/elasticsearch/api/actions/async_search/delete.rb

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,14 @@ module Actions
3030
# @see https://www.elastic.co/guide/en/elasticsearch/reference/current/async-search.html
3131
#
3232
def delete(arguments = {})
33+
request_opts = { endpoint: arguments[:endpoint] || "async_search.delete" }
34+
35+
defined_params = [:id].inject({}) do |set_variables, variable|
36+
set_variables[variable] = arguments[variable] if arguments.key?(variable)
37+
set_variables
38+
end
39+
request_opts[:defined_params] = defined_params unless defined_params.empty?
40+
3341
raise ArgumentError, "Required argument 'id' missing" unless arguments[:id]
3442

3543
arguments = arguments.clone
@@ -44,7 +52,7 @@ def delete(arguments = {})
4452
params = {}
4553

4654
Elasticsearch::API::Response.new(
47-
perform_request(method, path, params, body, headers)
55+
perform_request(method, path, params, body, headers, request_opts)
4856
)
4957
end
5058
end

elasticsearch-api/lib/elasticsearch/api/actions/async_search/get.rb

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,14 @@ module Actions
3333
# @see https://www.elastic.co/guide/en/elasticsearch/reference/current/async-search.html
3434
#
3535
def get(arguments = {})
36+
request_opts = { endpoint: arguments[:endpoint] || "async_search.get" }
37+
38+
defined_params = [:id].inject({}) do |set_variables, variable|
39+
set_variables[variable] = arguments[variable] if arguments.key?(variable)
40+
set_variables
41+
end
42+
request_opts[:defined_params] = defined_params unless defined_params.empty?
43+
3644
raise ArgumentError, "Required argument 'id' missing" unless arguments[:id]
3745

3846
arguments = arguments.clone
@@ -47,7 +55,7 @@ def get(arguments = {})
4755
params = Utils.process_params(arguments)
4856

4957
Elasticsearch::API::Response.new(
50-
perform_request(method, path, params, body, headers)
58+
perform_request(method, path, params, body, headers, request_opts)
5159
)
5260
end
5361
end

elasticsearch-api/lib/elasticsearch/api/actions/async_search/status.rb

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,14 @@ module Actions
3030
# @see https://www.elastic.co/guide/en/elasticsearch/reference/current/async-search.html
3131
#
3232
def status(arguments = {})
33+
request_opts = { endpoint: arguments[:endpoint] || "async_search.status" }
34+
35+
defined_params = [:id].inject({}) do |set_variables, variable|
36+
set_variables[variable] = arguments[variable] if arguments.key?(variable)
37+
set_variables
38+
end
39+
request_opts[:defined_params] = defined_params unless defined_params.empty?
40+
3341
raise ArgumentError, "Required argument 'id' missing" unless arguments[:id]
3442

3543
arguments = arguments.clone
@@ -44,7 +52,7 @@ def status(arguments = {})
4452
params = {}
4553

4654
Elasticsearch::API::Response.new(
47-
perform_request(method, path, params, body, headers)
55+
perform_request(method, path, params, body, headers, request_opts)
4856
)
4957
end
5058
end

elasticsearch-api/lib/elasticsearch/api/actions/async_search/submit.rb

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,14 @@ module Actions
7272
# @see https://www.elastic.co/guide/en/elasticsearch/reference/current/async-search.html
7373
#
7474
def submit(arguments = {})
75+
request_opts = { endpoint: arguments[:endpoint] || "async_search.submit" }
76+
77+
defined_params = [:index].inject({}) do |set_variables, variable|
78+
set_variables[variable] = arguments[variable] if arguments.key?(variable)
79+
set_variables
80+
end
81+
request_opts[:defined_params] = defined_params unless defined_params.empty?
82+
7583
arguments = arguments.clone
7684
headers = arguments.delete(:headers) || {}
7785

@@ -88,7 +96,7 @@ def submit(arguments = {})
8896
params = Utils.process_params(arguments)
8997

9098
Elasticsearch::API::Response.new(
91-
perform_request(method, path, params, body, headers)
99+
perform_request(method, path, params, body, headers, request_opts)
92100
)
93101
end
94102
end

elasticsearch-api/lib/elasticsearch/api/actions/autoscaling/delete_autoscaling_policy.rb

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,14 @@ module Actions
3030
# @see https://www.elastic.co/guide/en/elasticsearch/reference/current/autoscaling-delete-autoscaling-policy.html
3131
#
3232
def delete_autoscaling_policy(arguments = {})
33+
request_opts = { endpoint: arguments[:endpoint] || "autoscaling.delete_autoscaling_policy" }
34+
35+
defined_params = [:name].inject({}) do |set_variables, variable|
36+
set_variables[variable] = arguments[variable] if arguments.key?(variable)
37+
set_variables
38+
end
39+
request_opts[:defined_params] = defined_params unless defined_params.empty?
40+
3341
raise ArgumentError, "Required argument 'name' missing" unless arguments[:name]
3442

3543
arguments = arguments.clone
@@ -44,7 +52,7 @@ def delete_autoscaling_policy(arguments = {})
4452
params = {}
4553

4654
Elasticsearch::API::Response.new(
47-
perform_request(method, path, params, body, headers)
55+
perform_request(method, path, params, body, headers, request_opts)
4856
)
4957
end
5058
end

elasticsearch-api/lib/elasticsearch/api/actions/autoscaling/get_autoscaling_capacity.rb

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,8 @@ module Actions
2929
# @see https://www.elastic.co/guide/en/elasticsearch/reference/current/autoscaling-get-autoscaling-capacity.html
3030
#
3131
def get_autoscaling_capacity(arguments = {})
32+
request_opts = { endpoint: arguments[:endpoint] || "autoscaling.get_autoscaling_capacity" }
33+
3234
arguments = arguments.clone
3335
headers = arguments.delete(:headers) || {}
3436

@@ -39,7 +41,7 @@ def get_autoscaling_capacity(arguments = {})
3941
params = {}
4042

4143
Elasticsearch::API::Response.new(
42-
perform_request(method, path, params, body, headers)
44+
perform_request(method, path, params, body, headers, request_opts)
4345
)
4446
end
4547
end

elasticsearch-api/lib/elasticsearch/api/actions/autoscaling/get_autoscaling_policy.rb

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,14 @@ module Actions
3030
# @see https://www.elastic.co/guide/en/elasticsearch/reference/current/autoscaling-get-autoscaling-policy.html
3131
#
3232
def get_autoscaling_policy(arguments = {})
33+
request_opts = { endpoint: arguments[:endpoint] || "autoscaling.get_autoscaling_policy" }
34+
35+
defined_params = [:name].inject({}) do |set_variables, variable|
36+
set_variables[variable] = arguments[variable] if arguments.key?(variable)
37+
set_variables
38+
end
39+
request_opts[:defined_params] = defined_params unless defined_params.empty?
40+
3341
raise ArgumentError, "Required argument 'name' missing" unless arguments[:name]
3442

3543
arguments = arguments.clone
@@ -44,7 +52,7 @@ def get_autoscaling_policy(arguments = {})
4452
params = {}
4553

4654
Elasticsearch::API::Response.new(
47-
perform_request(method, path, params, body, headers)
55+
perform_request(method, path, params, body, headers, request_opts)
4856
)
4957
end
5058
end

elasticsearch-api/lib/elasticsearch/api/actions/autoscaling/put_autoscaling_policy.rb

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,14 @@ module Actions
3131
# @see https://www.elastic.co/guide/en/elasticsearch/reference/current/autoscaling-put-autoscaling-policy.html
3232
#
3333
def put_autoscaling_policy(arguments = {})
34+
request_opts = { endpoint: arguments[:endpoint] || "autoscaling.put_autoscaling_policy" }
35+
36+
defined_params = [:name].inject({}) do |set_variables, variable|
37+
set_variables[variable] = arguments[variable] if arguments.key?(variable)
38+
set_variables
39+
end
40+
request_opts[:defined_params] = defined_params unless defined_params.empty?
41+
3442
raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
3543
raise ArgumentError, "Required argument 'name' missing" unless arguments[:name]
3644

@@ -46,7 +54,7 @@ def put_autoscaling_policy(arguments = {})
4654
params = {}
4755

4856
Elasticsearch::API::Response.new(
49-
perform_request(method, path, params, body, headers)
57+
perform_request(method, path, params, body, headers, request_opts)
5058
)
5159
end
5260
end

elasticsearch-api/lib/elasticsearch/api/actions/bulk.rb

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,14 @@ module Actions
4141
# @see https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-bulk.html
4242
#
4343
def bulk(arguments = {})
44+
request_opts = { endpoint: arguments[:endpoint] || "bulk" }
45+
46+
defined_params = [:index].inject({}) do |set_variables, variable|
47+
set_variables[variable] = arguments[variable] if arguments.key?(variable)
48+
set_variables
49+
end
50+
request_opts[:defined_params] = defined_params unless defined_params.empty?
51+
4452
raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
4553

4654
arguments = arguments.clone
@@ -66,7 +74,7 @@ def bulk(arguments = {})
6674

6775
headers.merge!("Content-Type" => "application/x-ndjson")
6876
Elasticsearch::API::Response.new(
69-
perform_request(method, path, params, payload, headers)
77+
perform_request(method, path, params, payload, headers, request_opts)
7078
)
7179
end
7280
end

elasticsearch-api/lib/elasticsearch/api/actions/cat/aliases.rb

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,14 @@ module Actions
3737
# @see https://www.elastic.co/guide/en/elasticsearch/reference/current/cat-alias.html
3838
#
3939
def aliases(arguments = {})
40+
request_opts = { endpoint: arguments[:endpoint] || "cat.aliases" }
41+
42+
defined_params = [:name].inject({}) do |set_variables, variable|
43+
set_variables[variable] = arguments[variable] if arguments.key?(variable)
44+
set_variables
45+
end
46+
request_opts[:defined_params] = defined_params unless defined_params.empty?
47+
4048
arguments = arguments.clone
4149
headers = arguments.delete(:headers) || {}
4250

@@ -54,7 +62,7 @@ def aliases(arguments = {})
5462
params[:h] = Utils.__listify(params[:h]) if params[:h]
5563

5664
Elasticsearch::API::Response.new(
57-
perform_request(method, path, params, body, headers)
65+
perform_request(method, path, params, body, headers, request_opts)
5866
)
5967
end
6068
end

0 commit comments

Comments
 (0)